Python 3.x 连接数据库示例（pymysql 方式）-Python教程-PHP中文网

Python 3.x 连接数据库示例（pymysql 方式）

高洛峰

发布： 2017-02-23 15:59:13

原创

1430 人浏览过

由于 MySQLdb 模块还不支持 Python3.x，所以 Python3.x 如果想连接MySQL需要安装 pymysql 模块。

pymysql 模块可以通过 pip 安装。但如果你使用的是 pycharm IDE，则可以使用 project python 安装第三方模块。

[File] >> [settings] >> [Project: python] >> [Project Interpreter] >> [Install按钮]

Python 3.x 连接数据库示例（pymysql 方式）

由于Python统一了数据库连接的接口，所以 pymysql 和 MySQLdb 在使用方式上是类似的：

pymysql.Connect()参数说明

host(str): MySQL服务器地址
port(int): MySQL服务器端口号
user(str): 用户名
passwd(str): 密码
db(str): 数据库名称
charset(str): 连接编码

connection对象支持的方法

cursor() 使用该连接创建并返回游标
commit() 提交当前事务
rollback() 回滚当前事务
close() 关闭连接

cursor对象支持的方法

execute(op) 执行一个数据库的查询命令
fetchone() 取得结果集的下一行
fetchmany(size) 获取结果集的下几行
fetchall() 获取结果集中的所有行
rowcount() 返回数据条数或影响行数
close() 关闭游标对象

==================MySQL===================

首先在连接数据库之前，先创建一个交易表，方便测试 pymysql 的功能：

DROP TABLE IF EXISTS `trade`;

CREATE TABLE `trade` (
 `id` int(4) unsigned NOT NULL AUTO_INCREMENT,
 `name` varchar(6) NOT NULL COMMENT &#39;用户真实姓名&#39;,
 `account` varchar(11) NOT NULL COMMENT &#39;银行储蓄账号&#39;,
 `saving` decimal(8,2) unsigned NOT NULL DEFAULT &#39;0.00&#39; COMMENT &#39;账户储蓄金额&#39;,
 `expend` decimal(8,2) unsigned NOT NULL DEFAULT &#39;0.00&#39; COMMENT &#39;账户支出总计&#39;,
 `income` decimal(8,2) unsigned NOT NULL DEFAULT &#39;0.00&#39; COMMENT &#39;账户收入总计&#39;,
 PRIMARY KEY (`id`),
 UNIQUE KEY `name_UNIQUE` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
INSERT INTO `trade` VALUES (1,&#39;乔布斯&#39;,&#39;18012345678&#39;,0.00,0.00,0.00);

登录后复制

==================Python===================

使用Python脚本实现增删改查和事务处理，源码如下：

import pymysql.cursors

# 连接数据库
connect = pymysql.Connect(
  host=&#39;localhost&#39;,
  port=3310,
  user=&#39;woider&#39;,
  passwd=&#39;3243&#39;,
  db=&#39;python&#39;,
  charset=&#39;utf8&#39;
)

# 获取游标
cursor = connect.cursor()

# 插入数据
sql = "INSERT INTO trade (name, account, saving) VALUES ( &#39;%s&#39;, &#39;%s&#39;, %.2f )"
data = (&#39;雷军&#39;, &#39;13512345678&#39;, 10000)
cursor.execute(sql % data)
connect.commit()
print(&#39;成功插入&#39;, cursor.rowcount, &#39;条数据&#39;)

# 修改数据
sql = "UPDATE trade SET saving = %.2f WHERE account = &#39;%s&#39; "
data = (8888, &#39;13512345678&#39;)
cursor.execute(sql % data)
connect.commit()
print(&#39;成功修改&#39;, cursor.rowcount, &#39;条数据&#39;)

# 查询数据
sql = "SELECT name,saving FROM trade WHERE account = &#39;%s&#39; "
data = (&#39;13512345678&#39;,)
cursor.execute(sql % data)
for row in cursor.fetchall():
  print("Name:%s\tSaving:%.2f" % row)
print(&#39;共查找出&#39;, cursor.rowcount, &#39;条数据&#39;)

# 删除数据
sql = "DELETE FROM trade WHERE account = &#39;%s&#39; LIMIT %d"
data = (&#39;13512345678&#39;, 1)
cursor.execute(sql % data)
connect.commit()
print(&#39;成功删除&#39;, cursor.rowcount, &#39;条数据&#39;)

# 事务处理
sql_1 = "UPDATE trade SET saving = saving + 1000 WHERE account = &#39;18012345678&#39; "
sql_2 = "UPDATE trade SET expend = expend + 1000 WHERE account = &#39;18012345678&#39; "
sql_3 = "UPDATE trade SET income = income + 2000 WHERE account = &#39;18012345678&#39; "

try:
  cursor.execute(sql_1) # 储蓄增加1000
  cursor.execute(sql_2) # 支出增加1000
  cursor.execute(sql_3) # 收入增加2000
except Exception as e:
  connect.rollback() # 事务回滚
  print(&#39;事务处理失败&#39;, e)
else:
  connect.commit() # 事务提交
  print(&#39;事务处理成功&#39;, cursor.rowcount)

# 关闭连接
cursor.close()
connect.close()

登录后复制

==================测试结果===================

Python 3.x 连接数据库示例（pymysql 方式）