Pythonのsqlite3におけるトランザクション制御方法

2023年9月26日

Pythonのsqlite3ライブラリを使用してSQLiteデータベースでトランザクションを制御する方法は、以下の手順に従います。

1. データベースに接続します。

python
import sqlite3

conn = sqlite3.connect('mydatabase.db')
cursor = conn.cursor()

2. トランザクションを開始します。トランザクション内の操作は、コミットまたはロールバックまで一括して処理されます。トランザクションは、commit()メソッドでコミットするか、エラーが発生した場合にrollback()メソッドでロールバックすることができます。

python
try:
    # トランザクションを開始
    conn.begin()
    
    # データベース操作を実行
    cursor.execute("INSERT INTO mytable (column1, column2) VALUES (?, ?)", ("value1", "value2"))
    
    # トランザクションをコミット
    conn.commit()
except Exception as e:
    # エラーが発生した場合、トランザクションをロールバック
    conn.rollback()
    print(f"トランザクションがロールバックされました: {e}")

3. トランザクション内でデータベース操作を実行します。トランザクション内の操作は、コミットが行われるまでデータベースに反映されません。

4. トランザクション内でエラーが発生した場合、rollback()メソッドを呼び出してトランザクションをロールバックし、変更を元に戻します。

5. 正常にトランザクションを処理した場合、commit()メソッドを呼び出してトランザクション内の変更をデータベースにコミットします。

トランザクションを制御することは、データベースのデータ整合性を保つために非常に重要です。エラーが発生した場合やデータベースの一貫性を確保するために、トランザクション内で適切なエラーハンドリングを実装することが重要です。