第一步：连接数据库
|
1
|
db = pymysql.connect(host='localhost',port =3306,user='root',passwd='root',db='sys',charset='utf8' ) |
第二步：创建表。
|
1
2
3
4
5
6
7
8
9
|
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;""" |
第三步：关闭表。
|
1
2
3
|
cursor.execute(SQL)db.close() |
完整代码如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
# -*- 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,baiincomeSQL = """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() |