第一步：連接數據庫
|
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()
|