PythonはMySQLデータベースを操作します

Python の標準データベース インターフェイスは Python DB-API であり、開発者にデータベース アプリケーション プログラミング インターフェイスを提供します。

Python データベース インターフェイスは多くのデータベースをサポートしており、プロジェクトに合ったデータベースを選択できます:

• GadFly

• mSQL

• MySQL

• PostgreSQL

• Microsoft SQL Server 2000

• Informix

• Interbase

• Oracle

• Sybase

Python データベース インターフェイスと API にアクセスして、サポートされているデータベースの詳細なリストを表示できます。

データベースごとに異なる DB API モジュールをダウンロードする必要があります。たとえば、Oracle データベースと MySQL データにアクセスする必要がある場合は、Oracle および MySQL データベース モジュールをダウンロードする必要があります。

DB-API は、基礎となるさまざまなデータベース システムおよびさまざまなデータベース インターフェイス プログラムに一貫したアクセス インターフェイスを提供するために必要な一連のオブジェクトとデータベース アクセス方法を定義する仕様です。

Python の DB-API は、ほとんどのデータベースのインターフェイスを実装しています。これを使用して各データベースに接続すると、同じ方法で各データベースを操作できます。

Python DB-API の使用プロセス:

• API モジュールを紹介します。

• データベースへの接続を取得します。

• SQL ステートメントとストアド プロシージャを実行します。

• データベース接続を閉じます。

---

MySQLdb とは?

MySQLdb は、Python データベース API 仕様 V2.0 を実装し、MySQL C API に基づいています。

---

MySQLdb のインストール方法

DB-API を使用して MySQL スクリプトを作成するには、MySQL がインストールされていることを確認する必要があります。次のコードをコピーして実行します:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

実行後の出力が次の場合、MySQLdb モジュールがインストールされていないことを意味します:

Traceback (most recent call last):
  File "test.py", line 3, in <module>
    import MySQLdb
ImportError: No module named MySQLdb

MySQLdb をインストールするには、http://sourceforge.net/projects/mysql にアクセスしてください。 -python、(Linux プラットフォームは https://pypi.python.org/pypi/MySQL-python にアクセスできます) ここから、プラットフォームに適したインストール パッケージを選択できます。パッケージは、プリコンパイルされたバイナリ ファイルとソース コードのインストールに分かれています。パッケージ。

バイナリ ファイル配布バージョンを選択した場合、基本的なインストール プロンプトを表示してインストール プロセスを完了できます。ソース コードからインストールする場合は、MySQLdb ディストリビューションの最上位ディレクトリに切り替えて、次のコマンドを入力する必要があります:

$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install

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

---

データベース接続

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

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

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

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

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

• Python MySQLdb モジュールがマシンにインストールされました。

• SQL ステートメントに慣れていない場合は、基本的な SQL チュートリアルを参照してください

例:

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

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

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

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

# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()

print "Database version : %s " % data

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

上記のスクリプトを実行した出力結果は次のとおりです。 :

Database version : 5.0.45

---

データベーステーブルの作成

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

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

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

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

# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表SQL语句
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()

---

データベース挿入操作

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

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.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:
   # Rollback in case there is any error
   db.rollback()

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

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

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.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)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

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

例:

次のコードは、変数を使用して SQL にパラメータを渡します。ステートメント:

..................................
user_id = "test123"
password = "password"

con.execute('insert into Login values("%s", "%s")' % \
             (user_id, password))
..................................

---

データベース クエリ操作

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

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

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

• rowcount: これは読み取り専用プロパティであり、execute( ） 方法。

例:

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

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.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()

上記のスクリプトの実行結果は次のとおりです:

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

---

データベース更新操作

Update 操作は次の目的で使用されます。データ テーブル Data を更新する場合、次の例では、TESTDB テーブル内のすべての SEX フィールドを「M」に変更し、AGE フィールドを 1 つ増やします。

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.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 を超える EMPLOYEE 内のすべてのデータを削除する方法を示しています。

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

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

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

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

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

• Python DB API 2.0 トランザクションには、コミットまたはロールバックの 2 つのメソッドが用意されています。
  例:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.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()

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

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

---

エラー処理

DB API は、データベース操作のいくつかのエラーと例外を定義します。次の表に、これらのエラーと例外を示します。

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