1、連接數據庫
db = pymysql.connect(host='localhost',port =3306,user='root',passwd='root',db='sys',charset='utf8' )
2、創建表
在創建表時,注意是否創建過該表,如果創建過就刪除
cursor.execute("drop table if EXISTS income")
SQL = """CREATE TABLE `income` ( `id` int(11) NOT NULL AUTO_INCREMENT, `datetime` varchar(20) DEFAULT NULL, `ironincome` decimal(20,2) DEFAULT NULL, `generalincome` decimal(20,2) DEFAULT NULL, `baiincome` decimal(20,2) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; """
3、關閉表
cursor.execute(SQL)
db.close()
完整代碼如下
# -*- coding:utf-8 -*- import pymysql # 打開數據庫 db = pymysql.connect(host='localhost',port =3306,user='root',passwd='root',db='sys',charset='utf8' ) #使用cursor()方法獲取操作游標 cursor = db.cursor() #如果數據表已經存在使用execute()方法刪除表 cursor.execute("drop table if EXISTS income") #創建數據庫SQL語句 #time,ironincome,general_income,baiincome SQL = """CREATE TABLE `income` ( `id` int(11) NOT NULL AUTO_INCREMENT, `datetime` varchar(20) DEFAULT NULL, `ironincome` decimal(20,2) DEFAULT NULL, `generalincome` decimal(20,2) DEFAULT NULL, `baiincome` decimal(20,2) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; """ cursor.execute(SQL) db.close()