笔记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,晚安

    原文作者:雨轩_99
    原文地址: https://www.jianshu.com/p/d5de7e881f13
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞