MySQL上でのPythonのデータ操作例を詳しく解説

この記事では、Python3 で PyMySQL を使用してデータベースに接続し、簡単な追加、削除、変更、クエリを実装する方法を紹介します。非常に良い基準値を持っています。以下のエディターで見てみましょう

この記事では、PyMySQL を使用してデータベースに接続し、簡単な追加、削除、変更、クエリを実装するための Python3 を紹介します。

PyMySQLとは何ですか?

PyMySQL は Python 3.x で MySQL サーバーに接続するために使用されるライブラリであり、mysqldb は Python 2.x で使用されます。

PyMySQL のインストール

PyMySQL を使用する前に、PyMySQL がインストールされていることを確認する必要があります。

PyMySQL のダウンロード アドレス: https://github.com/PyMySQL/PyMySQL。

まだインストールされていない場合は、次のコマンドを使用して最新バージョンの PyMySQL をインストールできます:

$ pip install PyMySQL

システムが pip コマンドをサポートしていない場合は、次の方法を使用してインストールできます:

1. git コマンドを使用してインストール パッケージをダウンロードします (手動でダウンロードすることもできます):

$ git clone https://github.com/PyMySQL/PyMySQL
$ cd PyMySQL
$ python3 setup.py install

2. バージョン番号を指定する必要がある場合は、curl コマンドを使用してインストールできます。

$ # X.X 为PyMySQL 的版本号
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python3 setup.py install

注: 上記のモジュールをインストールするための root 権限があることを確認してください。

データベース接続

データベースに接続する前に、次のことを確認してください:

• データベースTESTDBを作成しました

• TESTDBデータベースにテーブルEMPLOYEEを作成しました

• EMPLOYEEテーブルフィールドは FIRST_NAME 、LAST_NAME、AGE、SEX、INCOME です

• データベース TESTDB への接続に使用されるユーザー名は「testuser」、パスワードは「test123」です。自分で設定することも、root ユーザー名とパスワードを直接使用することもできます。 Mysql データベース ユーザーを許可してください Grant コマンドを使用してください

• PyMySQL モジュールがマシンにインストールされています

例:

次の例は Mysql TESTDB データベースにリンクしています:

#!/usr/bin/python3
__author__ = 'mayi'
import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
# 使用 execute() 方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()
print ("Database version : %s " % data)

# 关闭数据库连接
db.close()

データベース テーブル

データベース接続が存在する場合は、execute() メソッドを使用して、次のようにテーブル EMPLOYEE を作成します。

#!/usr/bin/python3
__author__ = 'mayi'
import pymysql

# 开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 使用预处理语句创建表
sql = """CREATE TABLE EMPLOYEE (
 FIRST_NAME CHAR(20) NOT NULL,
 LAST_NAME CHAR(20),
 AGE INT, 
 SEX CHAR(1),
 INCOME FLOAT )"""
cursor.execute(sql)
# 关闭数据库连接
db.close()

データベース挿入操作

次の例では、実行を使用します。テーブル EMPLOYEE にレコードを挿入する SQL Insert ステートメントの例:

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
 LAST_NAME, AGE, SEX, INCOME)
 VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
 # 执行sql语句
 cursor.execute(sql)
 # 提交到数据库执行
 db.commit()
except:
 # 如果发生错误则回滚
 db.rollback()

# 关闭数据库连接
db.close()

上記の例は、次の形式で記述することもできます:

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
 LAST_NAME, AGE, SEX, INCOME) \
 VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
 ('Mac', 'Mohan', 20, 'M', 2000)
try:
 # 执行sql语句
 cursor.execute(sql)
 # 执行sql语句
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

# 关闭数据库连接
db.close()

データベース クエリ操作

Python クエリ Mysql は fetchone() メソッドを使用して取得します単一のデータを取得し、fetchall() メソッドを使用して複数のデータを取得します。

• fetchone(): このメソッドは次のクエリ結果セットを取得します。結果セットはオブジェクトです

• fetchall(): 返されたすべての結果行を受け取ります

• rowcount: これは読み取り専用属性であり、execute() メソッドの実行後に影響を受ける行の数を返します

インスタンス :

給与フィールドが 1000 より大きい EMPLOYEE テーブル内のすべてのデータをクエリします:

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
 WHERE INCOME > '%d'" % (1000)
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 获取所有记录列表
 results = cursor.fetchall()
 for row in results:
 fname = row[0]
 lname = row[1]
 age = row[2]
 sex = row[3]
 income = row[4]
 # 打印结果
 print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
 (fname, lname, age, sex, income ))
except:
 print ("Error: unable to fecth data")

# 关闭数据库连接
db.close()

データベース更新操作

更新操作は、データ テーブル内のデータを更新するために使用されます。 「M」の場合、AGE フィールドは 1 ずつ増分されます。

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
 WHERE SEX = '%c'" % ('M')
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 提交到数据库执行
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

# 关闭数据库连接
db.close()

削除操作

次の例は、データ テーブル内のデータを削除するために使用されます。データ テーブル内の AGE が 20 を超えるすべてのデータを削除します。 従業員:

#!/usr/bin/python3
__author__ = 'mayi'

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 提交修改
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

# 关闭连接
db.close()

トランザクションの実行

トランザクション メカニズムにより、データの一貫性が保証されます。

トランザクションには、原子性、一貫性、分離性、耐久性という 4 つの属性が必要です。これら 4 つのプロパティは、多くの場合、ACID プロパティと呼ばれます。

• 原子性。トランザクションは、分割できない作業単位です。トランザクションに含まれるすべての操作が完了するか、まったく完了しません。

• 一貫性。トランザクションでは、データベースをある整合性状態から別の整合性状態に変更する必要があります。一貫性と原子性は密接に関係しています。

• 孤立。トランザクションの実行は、他のトランザクションによって干渉されることはできません。つまり、トランザクション内で使用される操作とデータは他の同時トランザクションから分離されており、同時に実行されるトランザクションは相互に干渉できません。

• 耐久性。永続性とも呼ばれる継続性は、トランザクションがコミットされると、データベース内のデータに対する変更が永​​続的になることを意味します。後続の操作や障害が影響を与えることはありません。

例

# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 向数据库提交
 db.commit()
except:
 # 发生错误时回滚
 db.rollback()

トランザクションをサポートするデータベースの場合、Python データベース プログラミングでは、カーソルが作成されると、非表示のデータベース トランザクションが自動的に開始されます。

commit() メソッドはカーソルに対するすべての更新操作を実行し、rollback() メソッドは現在のカーソルに対するすべての操作をロールバックします。各メソッドは新しいトランザクションを開始します。

エラー処理

例外	説明
警告	挿入されたデータが切り捨てられるなど、重大な警告がある場合にトリガーされます。 StandardError のサブクラスである必要があります。
Error	警告を除く他のすべてのエラー クラス。 StandardError のサブクラスである必要があります。
InterfaceError	データベース インターフェイス モジュール自体でエラーが発生したときにトリガーされます (データベースのエラーではありません)。 Error のサブクラスである必要があります。
DatabaseError	データベースに関連するエラーが発生したときにトリガーされます。 Error のサブクラスである必要があります。
DataError	ゼロ除算エラー、データ範囲外など、データ処理中にエラーが発生したときにトリガーされます。 DatabaseError のサブクラスである必要があります。
OperationalError	は、ユーザーによって制御されないが、データベースの操作中に発生するエラーを指します。たとえば、接続が予期せず切断される、データベース名が見つからない、トランザクション処理の失敗、メモリ割り当てエラーなどは、データベースを操作するときに発生するエラーです。 DatabaseError のサブクラスである必要があります。
IntegrityError	外部キーチェックの失敗などの整合性関連のエラー。 DatabaseError サブクラスである必要があります。
InternamError	カーソルの失敗、トランザクションの同期の失敗など、データベースの内部エラー。 DatabaseError サブクラスである必要があります。
ProgrammingError	データテーブル（テーブル）が見つからないか、すでに存在している、SQLステートメントの構文エラー、パラメータの数が間違っているなどのプログラミングエラー。 DatabaseError のサブクラスである必要があります。
NotSupportedError	サポートされていないエラーは、データベースでサポートされていない関数または API の使用を指します。たとえば、接続オブジェクトで rollback() 関数が使用されていますが、データベースがトランザクションをサポートしていないか、トランザクションが閉じられているとします。 DatabaseError のサブクラスである必要があります。

以上がMySQL上でのPythonのデータ操作例を詳しく解説の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。