Beispiel für eine Python 3.x-Datenbankverbindung (pymysql-Methode)-Python-Tutorial-php.cn

Beispiel für eine Python 3.x-Datenbankverbindung (pymysql-Methode)

高洛峰

Freigeben： 2017-02-23 15:59:13

Original

1402 Leute haben es durchsucht

Da das MySQLdb-Modul Python3.x noch nicht unterstützt, müssen Sie das pymysql-Modul installieren, wenn Python3.x eine Verbindung zu MySQL herstellen möchte.

Das PyMySQL-Modul kann über Pip installiert werden. Wenn Sie jedoch die Pycharm-IDE verwenden, können Sie Project Python verwenden, um Module von Drittanbietern zu installieren.

[Datei] >> [Projekt: Python] >> [Schaltfläche „Installieren“]

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

Da Python die Datenbankverbindungsschnittstelle vereinheitlicht, sind pymysql und MySQLdb in der Verwendung ähnlich:

pymysql.Connect() Parameterbeschreibung

host(str): MySQL-Serveradresse
port(int): MySQL-Server-Portnummer
user (str): Benutzername
passwd(str): Passwort
db(str): Datenbankname
charset (str): Verbindungskodierung

Vom Verbindungsobjekt unterstützte Methoden

cursor() Verwenden Sie diese Verbindung zum Erstellen und einen Cursor zurückgeben
commit() Die aktuelle Transaktion festschreiben
rollback() Die aktuelle Transaktion zurücksetzen
close() Verbindung schließen

Vom Cursorobjekt unterstützte Methoden

execute(op) Ausführen ein Datenbankabfragebefehl
fetchone() Holen Sie sich die nächste Zeile des Ergebnissatzes
fetchmany(size) Holen Sie sich die nächsten Zeilen des Ergebnismenge
fetchall() Alle Zeilen in der Ergebnismenge abrufen
rowcount() Gibt die Anzahl der Datenelemente oder die Anzahl von zurück betroffene Zeilen
close() Das Cursorobjekt schließen

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

Erstellen Sie zunächst eine Transaktionstabelle, bevor Sie eine Verbindung zur Datenbank herstellen, um das Testen der Funktionen von pymysql zu erleichtern:

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);

Nach dem Login kopieren

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

Verwenden Sie ein Python-Skript, um das Hinzufügen, Löschen, Ändern, Abfragen und die Transaktionsverarbeitung zu implementieren. Der Quellcode lautet wie folgt:

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

Nach dem Login kopieren

============== ====Testergebnisse====================

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

Das Obige ist der gesamte Inhalt dieses Artikels. Ich hoffe, dass er für alle hilfreich ist. Das Lernen ist hilfreich und ich hoffe, dass jeder die chinesische PHP-Website unterstützt.

Weitere Artikel zu Python 3.x-Datenbankverbindungsbeispielen (pymysql-Methode) finden Sie auf der chinesischen PHP-Website!