# 连接数据库，创建表

def create_all():

    engine = create_engine(

        'mysql+pymysql://root:123456@127.0.0.1:3306/sqlalchemy_test?charset=utf8',

        max_overflow=0,  # 超过连接池大小外最多创建的连接

        pool_size=5,  # 连接池大小

        pool_timeout=30,  # 池中没有线程最多等待的时间，否则报错

        pool_recycle=-1  # 多久之后对线程池中的线程进行一次连接的回收（重置）

    )

    # 当函数被调用的时候，会执行下面的代码，把所有的表创建

    Base.metadata.create_all(engine)

#删除所有表

def drop_all():

    engine = create_engine(

        'mysql+pymysql://root:123456@127.0.0.1:3306/sqlalchemy_test?charset=utf8',

        max_overflow=0,  # 超过连接池大小外最多创建的连接

        pool_size=5,  # 连接池大小

        pool_timeout=30,  # 池中没有线程最多等待的时间，否则报错

        pool_recycle=-1  # 多久之后对线程池中的线程进行一次连接的回收（重置）

    )

    # 当函数被调用的时候，会执行下面的代码，把所有的表删除

    Base.metadata.drop_all(engine)

# 每次运行当前程序才会执行创建所有表

if __name__ == '__main__':

    create_all()