笔记04：pymysql：动态添加表

pymysql：动态添加表

考虑到以后数据量非常大全部放在一张表里的话，肯定是不合理的，想到了分类处理数据，按类别建表存储（表的数据结构是相同的），因为没有找到用sqlalchemy动态创建多表的方式，改用pymysql进行数据库的操作

# -*- coding: utf-8 -*-


import pymysql

'''
1、连接数据库
'''
def connect():
    conn = pymysql.connect(host='localhost',
                           port = 3306,
                           user = 'root',
                           password = '',
                           db = 'dd_db',
                           charset = 'utf8'
                           )
    return conn

'''
2、动态添加表：根据表名创建
'''
def addTable(tablename):
    sql = '''create table day{} (
    name varchar(64) not null,
    age int
    )'''.format(tablename)
    print(sql)
    conn = connect()
    cursor = conn.cursor()
    
    try:
        cursor.execute(sql)
        conn.commit()#要记得写这句话，提交请求。
    except Exception as e:
        conn.rollback()#表存在就回滚操作
        print(e)
    finally:
        cursor.close()
        conn.close()

if __name__ == '__main__':
    addTable('002321')
    for i in range(10):
        addTable('00000'+str(i))

时间：2018年4月1日23:20:51，晚安