diff --git a/Web/DoubanMovieWeb/DB.py b/Web/DoubanMovieWeb/DB.py new file mode 100644 index 0000000..22a3a27 --- /dev/null +++ b/Web/DoubanMovieWeb/DB.py @@ -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 + + +