PyQt5-データベース処理

PyQt5ライブラリには QtSqlモジュール。これは、多くのSQLベースのデータベースと通信するための精巧なクラスシステムです。そのQSqlDatabaseConnectionオブジェクトを介したアクセスを提供します。以下は、現在利用可能なSQLドライバーのリストです-

シニア番号	ドライバーの種類と説明
1	QDB2 IBM DB2
2	QIBASE BorlandInterBaseドライバー
3	QMYSQL MySQLドライバー
4	QOCI Oracle Call Interface Driver
5	QODBC ODBCドライバー（Microsoft SQL Serverを含む）
6	QPSQL PostgreSQLドライバー
7	QSQLITE SQLiteバージョン3以降
8	QSQLITE2 SQLiteバージョン2

例

この章では、静的メソッドを使用してSQLiteデータベースとの接続を確立します-

db = QtSql.QSqlDatabase.addDatabase('QSQLITE')
db.setDatabaseName('sports.db')

QSqlDatabaseクラスの他のメソッドは次のとおりです-

シニア番号	方法と説明
1	setDatabaseName() 接続が求められるデータベースの名前を設定します
2	setHostName() データベースがインストールされているホストの名前を設定します
3	setUserName() 接続用のユーザー名を指定します
4	setPassword() 接続オブジェクトのパスワードがある場合はそれを設定します
5	commit() トランザクションをコミットし、成功した場合はtrueを返します
6	rollback() データベーストランザクションをロールバックします
7	close() 接続を閉じます

QSqlQueryクラスには、SQLコマンドを実行および操作する機能があります。DDLタイプとDMLタイプの両方のSQLクエリを実行できます。最初のステップは、次のステートメントを使用してSQliteデータベースを作成することです-

db = QSqlDatabase.addDatabase('QSQLITE')
db.setDatabaseName('sportsdatabase.db')

次に、でクエリオブジェクトを取得します QSqlQuery() メソッドを実行し、その最も重要なメソッドexec_（）を呼び出します。このメソッドは、実行されるSQLステートメントを含む文字列を引数として取ります。

query = QtSql.QSqlQuery()
query.exec_("create table sportsmen(id int primary key, " "firstname varchar(20), lastname varchar(20))")

次のスクリプトは、5つのレコードが入力されたsportspersonのテーブルを使用してSQLiteデータベースsports.dbを作成します。

import sys
from PyQt5.QtSql import *
from PyQt5.QtCore import *
from PyQt5.QtGui import *
from PyQt5.QtWidgets import *

def createDB():
   db = QSqlDatabase.addDatabase('QSQLITE')
   db.setDatabaseName('sportsdatabase.db')

   if not db.open():
      msg = QMessageBox()
      msg.setIcon(QMessageBox.Critical)
      msg.setText("Error in Database Creation")
      retval = msg.exec_()
      return False
   query = QSqlQuery()

   query.exec_("create table sportsmen(
      id int primary key, ""firstname varchar(20), lastname varchar(20))")

   query.exec_("insert into sportsmen values(101, 'Roger', 'Federer')")
   query.exec_("insert into sportsmen values(102, 'Christiano', 'Ronaldo')")
   query.exec_("insert into sportsmen values(103, 'Ussain', 'Bolt')")
   query.exec_("insert into sportsmen values(104, 'Sachin', 'Tendulkar')")
   query.exec_("insert into sportsmen values(105, 'Saina', 'Nehwal')")
   return True

if __name__ == '__main__':
   app = QApplication(sys.argv)
   createDB()

上記のレコードがsportsmenテーブルに追加された状態でSQLiteデータベースが作成されていることを確認するには、次のSQLiteGuiユーティリティを使用します。 SQLiteStudio。

QSqlTableModelPyQtのクラスは、単一のテーブルでレコードを読み書きするための編集可能なデータモデルを提供する高レベルのインターフェイスです。このモデルは、QTableViewオブジェクト。これは、任意のトップレベルウィンドウに配置できるスクロール可能で編集可能なビューをユーザーに提示します。

QSqlTableModelオブジェクトは次の方法で宣言されます-

model = QtSql.QSqlTableModel()

その編集戦略は、次のいずれかに設定できます。

QSqlTableModel.OnFieldChange	すべての変更はすぐに適用されます
QSqlTableModel.OnRowChange	ユーザーが別の行を選択すると、変更が適用されます
QSqlTableModel.OnManualSubmit	submitAll（）またはrevertAll（）のいずれかが呼び出されるまで、すべての変更がキャッシュされます

例

次の例では、sportspersonテーブルがモデルとして使用され、戦略は次のように設定されています。

model.setTable('sportsmen') 
model.setEditStrategy(QtSql.QSqlTableModel.OnFieldChange)
   model.select()

QTableViewクラスは、PyQtのModel / Viewフレームワークの一部です。QTableViewオブジェクトは次のように作成されます-

view = QtGui.QTableView()
view.setModel(model)
view.setWindowTitle(title)
return view

このQTableViewオブジェクトと2つのQPushButtonウィジェットがトップレベルのQDialogウィンドウに追加されます。追加ボタンのClicked（）シグナルは、モデルテーブルでinsertRow（）を実行するaddrow（）に接続されます。

button.clicked.connect(addrow)
def addrow():
   print model.rowCount()
   ret = model.insertRows(model.rowCount(), 1)
   print ret

削除ボタンに関連付けられたスロットは、ユーザーが選択した行を削除するラムダ関数を実行します。

btn1.clicked.connect(lambda: model.removeRow(view1.currentIndex().row()))

完全なコードは次のとおりです-

import sys
from PyQt5.QtSql import *
from PyQt5.QtCore import *
from PyQt5.QtGui import *
from PyQt5.QtWidgets import *

def initializeModel(model):
   model.setTable('sportsmen')
   model.setEditStrategy(QSqlTableModel.OnFieldChange)
   model.select()
   model.setHeaderData(0, Qt.Horizontal, "ID")
   model.setHeaderData(1, Qt.Horizontal, "First name")
   model.setHeaderData(2, Qt.Horizontal, "Last name")

def createView(title, model):
   view = QTableView()
   view.setModel(model)
   view.setWindowTitle(title)
   return view

def addrow():
   print (model.rowCount())
   ret = model.insertRows(model.rowCount(), 1)
   print (ret)

def findrow(i):
   delrow = i.row()

if __name__ == '__main__':
   app = QApplication(sys.argv)
   db = QSqlDatabase.addDatabase('QSQLITE')
   db.setDatabaseName('sportsdatabase.db')
   model = QSqlTableModel()
   delrow = -1
   initializeModel(model)

   view1 = createView("Table Model (View 1)", model)
   view1.clicked.connect(findrow)

   dlg = QDialog()
   layout = QVBoxLayout()
   layout.addWidget(view1)

   button = QPushButton("Add a row")
   button.clicked.connect(addrow)
   layout.addWidget(button)

   btn1 = QPushButton("del a row")
   btn1.clicked.connect(lambda: model.removeRow(view1.currentIndex().row()))
   layout.addWidget(btn1)

   dlg.setLayout(layout)
   dlg.setWindowTitle("Database Demo")
   dlg.show()
   sys.exit(app.exec_())

上記のコードは次の出力を生成します-

いくつかのレコードを追加および削除してみて、SQLiteStudioに戻ってトランザクションを確認してください。