mirror of
https://gitee.com/insArvin/nypc_python_advanced.git
synced 2026-04-18 01:12:29 +08:00
add Web/DoubanMovieWeb/DB.py.
Signed-off-by: iamzhaohaibo <941604465@qq.com>
This commit is contained in:
33
Web/DoubanMovieWeb/DB.py
Normal file
33
Web/DoubanMovieWeb/DB.py
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
from sqlalchemy import MetaData, create_engine, Table, Column, String, Integer, text
|
||||||
|
|
||||||
|
|
||||||
|
class DB:
|
||||||
|
def __init__(self):
|
||||||
|
self.metadata = MetaData()
|
||||||
|
# 实际运行时需配置真实数据库连接
|
||||||
|
self.engine = create_engine( 'mysql+pymysql://用户名:密码@主机:端口/数据库名?charset=utf8mb4', echo=False)
|
||||||
|
|
||||||
|
def connect(self):
|
||||||
|
try:
|
||||||
|
return self.engine.connect()
|
||||||
|
except Exception as e:
|
||||||
|
print('连接异常', e)
|
||||||
|
|
||||||
|
def table(self):
|
||||||
|
douban_movie = Table(
|
||||||
|
'douban_movie', self.metadata,
|
||||||
|
Column('id', Integer, primary_key=True),
|
||||||
|
Column('m_id', String(32), unique=True),
|
||||||
|
Column('m_title', String(32)),
|
||||||
|
Column('m_score', String(8)),
|
||||||
|
Column('m_rank', String(32)),
|
||||||
|
Column('m_types', String(120)),
|
||||||
|
Column('m_regions', String(120)),
|
||||||
|
Column('m_release_date', String(120)),
|
||||||
|
Column('m_actors', String(255)),
|
||||||
|
Column('m_cover_url', String(120)),
|
||||||
|
)
|
||||||
|
return douban_movie
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
Reference in New Issue
Block a user