Python 3.x 連接資料庫範例（pymysql 方式）-Python教學-PHP中文網

Python 3.x 連接資料庫範例（pymysql 方式）

高洛峰

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

原創

1401 人瀏覽過

由於 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 在使用方式上是類似的：

#host(str): MySQL伺服器位址
port(int): MySQL伺服器連接埠號碼
user (str): 使用者名稱
passwd(str): 密碼
db(str):
##charset(str): 連線編碼

connection物件支援的方法

cursor()使用此連線建立並回傳遊標
commit() 提交目前交易
rollback() 回滾目前交易

cursor物件支援的方法

##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腳本實作增刪改查與交易處理，原始碼如下：

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

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中文網！ ############