PyQt - การจัดการฐานข้อมูล

PyQt API มีระบบคลาสที่ซับซ้อนเพื่อสื่อสารกับฐานข้อมูลที่ใช้ SQL จำนวนมาก QSqlDatabase ให้การเข้าถึงผ่านอ็อบเจ็กต์ Connection ต่อไปนี้เป็นรายการไดรเวอร์ SQL ที่มีอยู่ในปัจจุบัน -

ซีเนียร์	ประเภทไดรเวอร์และคำอธิบาย
1	QDB2 IBM DB2
2	QIBASE ไดรเวอร์ Borland InterBase
3	QMYSQL ไดร์เวอร์ MySQL
4	QOCI ไดรเวอร์ Oracle Call Interface
5	QODBC ODBC Driver (รวมถึง 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() ทำธุรกรรมและส่งคืนจริงหากสำเร็จ
6	rollback() ย้อนกลับธุรกรรมฐานข้อมูล
7	close() ปิดการเชื่อมต่อ

คลาส QSqlQuery มีฟังก์ชันในการดำเนินการและจัดการคำสั่ง SQL สามารถเรียกใช้แบบสอบถาม SQL ทั้งประเภท DDL และ DML ได้ วิธีการที่สำคัญที่สุดในคลาสคือ exec_ () ซึ่งใช้เป็นอาร์กิวเมนต์สตริงที่มีคำสั่ง SQL ที่จะดำเนินการ

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

สคริปต์ต่อไปนี้สร้างฐานข้อมูล SQLite sports.db ด้วยตารางของ sportsperson ที่เติมด้วยเร็กคอร์ดห้ารายการ

from PyQt4 import QtSql, QtGui

def createDB():
   db = QtSql.QSqlDatabase.addDatabase('QSQLITE')
   db.setDatabaseName('sports.db')
	
   if not db.open():
      QtGui.QMessageBox.critical(None, QtGui.qApp.tr("Cannot open database"),
         QtGui.qApp.tr("Unable to establish a database connection.\n"
            "This example needs SQLite support. Please read "
            "the Qt SQL driver documentation for information "
            "how to build it.\n\n" "Click Cancel to exit."),
         QtGui.QMessageBox.Cancel)
			
      return False
		
   query = QtSql.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__':
   import sys
	
   app = QtGui.QApplication(sys.argv)
   createDB()

คลาส QSqlTableModel ใน PyQt เป็นอินเทอร์เฟซระดับสูงที่จัดเตรียมโมเดลข้อมูลที่แก้ไขได้สำหรับการอ่านและเขียนเรกคอร์ดในตารางเดียว โมเดลนี้ใช้เพื่อเติมข้อมูลวัตถุ QTableView นำเสนอมุมมองแบบเลื่อนและแก้ไขให้กับผู้ใช้ซึ่งสามารถวางไว้บนหน้าต่างระดับบนสุดใดก็ได้

วัตถุ QTableModel ถูกประกาศในลักษณะต่อไปนี้ -

model = QtSql.QSqlTableModel()

กลยุทธ์การแก้ไขสามารถตั้งค่าได้ดังต่อไปนี้ -

QSqlTableModel OnFieldChange	การเปลี่ยนแปลงทั้งหมดจะมีผลทันที
QSqlTableModel OnRowChange	การเปลี่ยนแปลงจะถูกนำไปใช้เมื่อผู้ใช้เลือกแถวอื่น
QSqlTableModel OnManualSubmit	การเปลี่ยนแปลงทั้งหมดจะถูกแคชจนกว่าจะมีการเรียก submitAll () หรือ revertAll ()

ตัวอย่าง

ในตัวอย่างต่อไปนี้ใช้ตาราง sportsperson เป็นต้นแบบและกำหนดกลยุทธ์เป็น -

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

   model.select()

คลาส QTableView เป็นส่วนหนึ่งของเฟรมเวิร์ก Model / View ใน PyQt วัตถุ QTableView ถูกสร้างขึ้นดังนี้ -

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

ออบเจ็กต์ QTableView นี้และวิดเจ็ต QPushButton สองรายการจะถูกเพิ่มลงในหน้าต่าง QDialog ระดับบนสุด สัญญาณคลิก () ของปุ่มเพิ่มเชื่อมต่อกับ addrow () ซึ่งทำหน้าที่ insertRow () บนตารางโมเดล

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 PyQt4 import QtCore, QtGui, QtSql
import sportsconnection

def initializeModel(model):
   model.setTable('sportsmen')
   model.setEditStrategy(QtSql.QSqlTableModel.OnFieldChange)
   model.select()
   model.setHeaderData(0, QtCore.Qt.Horizontal, "ID")
   model.setHeaderData(1, QtCore.Qt.Horizontal, "First name")
   model.setHeaderData(2, QtCore.Qt.Horizontal, "Last name")
	
def createView(title, model):
   view = QtGui.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 = QtGui.QApplication(sys.argv)
   db = QtSql.QSqlDatabase.addDatabase('QSQLITE')
   db.setDatabaseName('sports.db')
   model = QtSql.QSqlTableModel()
   delrow = -1
   initializeModel(model)
	
   view1 = createView("Table Model (View 1)", model)
   view1.clicked.connect(findrow)
	
   dlg = QtGui.QDialog()
   layout = QtGui.QVBoxLayout()
   layout.addWidget(view1)
	
   button = QtGui.QPushButton("Add a row")
   button.clicked.connect(addrow)
   layout.addWidget(button)
	
   btn1 = QtGui.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_())

รหัสด้านบนสร้างผลลัพธ์ต่อไปนี้ -