Python 3.x データベース接続例 (pymysql メソッド)

MySQLdb モジュールはまだ Python3.x をサポートしていないため、Python3.x が MySQL に接続したい場合は、pymysql モジュールをインストールする必要があります。

pymysqlモジュールはpip経由でインストールできます。ただし、pycharm IDE を使用している場合は、プロジェクト Python を使用してサードパーティのモジュールをインストールできます。

[ファイル] >> [設定] >> [プロジェクトインタープリター] >> [インストールボタン]

したがって、pymysql と MySQLdb は使用法が似ています:

pymysql.Connect() パラメーターの説明

• host(str): MySQL サーバーのアドレス

• port(int): MySQL サーバーのポート番号

• user (str): ユーザー名

• passwd(str): パスワード

• db(str): データベース名

• charset(str): 接続エンコーディング

接続オブジェクトのサポート メソッド

• cursor() は接続を使用してカーソルを作成し、返します

• commit() は現在のトランザクションをコミットします

• rollback() は現在のトランザクションをロールバックします

• close()サポートされているメソッドカーソルオブジェクトによる

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 '用户真实姓名',
 `account` varchar(11) NOT NULL COMMENT '银行储蓄账号',
 `saving` decimal(8,2) unsigned NOT NULL DEFAULT '0.00' COMMENT '账户储蓄金额',
 `expend` decimal(8,2) unsigned NOT NULL DEFAULT '0.00' COMMENT '账户支出总计',
 `income` decimal(8,2) unsigned NOT NULL DEFAULT '0.00' COMMENT '账户收入总计',
 PRIMARY KEY (`id`),
 UNIQUE KEY `name_UNIQUE` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
INSERT INTO `trade` VALUES (1,'乔布斯','18012345678',0.00,0.00,0.00);

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

Pythonスクリプトを使用追加、削除、変更、クエリ、トランザクション処理を実装するためのソースコードは以下の通りです:

import pymysql.cursors

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

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

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

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

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

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

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

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

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

============= =======テスト結果=========== =======

以上がこの記事の全内容です。皆さんも勉強してください。また、皆さんが PHP 中国語 Web サイトをサポートしてくれることを願っています。

その他の Python 3.x データベース接続例 (pymysql メソッド) 関連記事については、PHP 中国語 Web サイトに注目してください。