mirror of
https://gitee.com/insArvin/nypc_python_advanced.git
synced 2026-04-17 21:42:29 +08:00
34 lines
1.1 KiB
Python
34 lines
1.1 KiB
Python
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_movies', 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_type', 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
|
|
|
|
|
|
|