Python を mysql データベースに接続する正しい方法
- 高洛峰オリジナル
- 2017-01-10 13:43:001175ブラウズ
Python データベース インターフェイスは多くのデータベースをサポートしており、プロジェクトに合ったデータベースを選択できます:
GadFly
mSQL
MySQL
PostgreSQL
Microsoft SQL Server 2000
Informix
Interbase
Sやべーす
データベースごとに異なる DB API モジュールをダウンロードする必要があります。たとえば、Oracle データベースと MySQL データにアクセスする必要がある場合は、Oracle および MySQL データベース モジュールをダウンロードする必要があります。
DB-API は、基礎となるさまざまなデータベース システムおよびさまざまなデータベース インターフェイス プログラムに一貫したアクセス インターフェイスを提供するために必要な一連のオブジェクトとデータベース アクセス方法を定義する仕様です。
Python の DB-API は、ほとんどのデータベースのインターフェイスを実装しています。これを使用して各データベースに接続すると、同じ方法で各データベースを操作できます。
Python DB-API の使用プロセス:
API モジュールを紹介します。
データベースへの接続を取得します。
SQL ステートメントとストアド プロシージャを実行します。
データベース接続を閉じます。
1. MySQLdb とは何ですか?
MySQLdb は、Python データベース API 仕様 V2.0 を実装しており、MySQL C API に基づいています。
2. 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 ディストリビューションの最上位ディレクトリに切り替えて、次のコマンドを入力する必要があります:
$ 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 権限があることを確認してください。
3. データベース接続
データベースに接続する前に、次のことを確認してください:
データベース TESTDB を作成しました。
TESTDB データベースにテーブル EMPLOYEE を作成しました
EMPLOYEE テーブルのフィールドは FIRST_NAME、 LAST_NAME、年齢、性別、収入。
データベース TESTDB への接続に使用するユーザー名は「testuser」、パスワードは「test123」です。自分で設定することも、root ユーザー名とパスワードを直接使用することもできます。MySQL データベースのユーザー認証には、Grant コマンドを使用してください。
Python MySQLdb モジュールがマシンにインストールされました。
例:
次の例は、Mysql の TESTDB データベースにリンクします:
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","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
4. データベース テーブルを作成します
データベース接続が存在する場合では、execute() メソッドを使用します。データベースのテーブルを作成し、次のようにテーブル EMPLOYEE を作成します。
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","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()
5. データベース挿入操作
次の例では、SQL INSERT ステートメントを使用してテーブル EMPLOYEE にレコードを挿入します。
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","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","codecloud","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))
..................................
6. データベース クエリ操作
Python は Mysql にクエリを実行して fetchone() メソッドを使用して 1 つのデータを取得し、fetchall() メソッドを使用して複数のデータを取得します。
fetchone(): このメソッドは次のクエリ結果セットを取得します。結果セットはオブジェクトです。
fetchall(): 返されたすべての結果行を受け取ります。
rowcount: これは読み取り専用のプロパティであり、execute() メソッドの実行後に影響を受ける行の数を返します。
例:
給与フィールドが 1000 より大きい EMPLOYEE テーブル内のすべてのデータをクエリします:
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","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
7.データベース更新操作
Update この操作は、データ テーブル内のデータを更新するために使用されます。次の例では、TESTDB テーブル内のすべての SEX フィールドが 'M' に変更され、AGE フィールドが 1 ずつ増加します。
トランザクションを実行する
トランザクションメカニズムにより、データの一貫性が保証されます。
トランザクションには、原子性、一貫性、分離性、耐久性という 4 つの属性が必要です。これら 4 つのプロパティは、多くの場合、ACID プロパティと呼ばれます。
原子性。トランザクションは、分割できない作業単位です。トランザクションに含まれるすべての操作は完了するか、何も行われません。
一貫性。トランザクションでは、データベースをある整合性状態から別の整合性状態に変更する必要があります。一貫性と原子性は密接に関係しています。
孤立。トランザクションの実行は、他のトランザクションによって干渉されることはできません。つまり、トランザクション内で使用される操作とデータは他の同時トランザクションから分離されており、同時に実行されるトランザクションは相互に干渉できません。
耐久性。永続性とも呼ばれる継続性は、トランザクションがコミットされると、データベース内のデータに対する変更が永続的になることを意味します。後続の操作や障害が影響を与えることはありません。
Python DB API 2.0 トランザクションは、コミットまたはロールバックの 2 つのメソッドを提供します。
例:
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","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()
トランザクションをサポートするデータベースの場合、Python データベース プログラミングでは、カーソルが作成されると、非表示のデータベース トランザクションが自動的に開始されます。
commit() メソッドはカーソルのすべての更新操作をロールバックし、rollback() メソッドは現在のカーソルのすべての操作をロールバックします。各メソッドは新しいトランザクションを開始します。
エラー処理
DB API は、いくつかのデータベース操作エラーと例外を定義します。次の表に、これらのエラーと例外を示します。
上記がこの記事の全内容です。皆様の学習に役立つことを願っています。
Python を mysql データベースに接続する正しい姿勢に関連するその他の記事については、PHP 中国語 Web サイトに注目してください。