第一步：连接数据库
|
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,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()
|