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

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

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

由于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()

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

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持PHP中文网。

更多Python 3.x 连接数据库示例（pymysql 方式）相关文章请关注PHP中文网！