Pyqt5 简明教程

PyQt5 - Database Handling

PyQt5 库包含 QtSql 模块。它是一个复杂的类系统，用于与许多基于 SQL 的数据库通信。它的 QSqlDatabase 提供通过连接对象进行访问。以下是当前可用的 SQL 驱动程序的列表：

Sr.No.

Driver Type & Description

1

QDB2 IBM DB2

2

QIBASE Borland InterBase Driver

3

QMYSQL MySQL Driver

4

QOCI Oracle Call Interface Driver

5

QODBC ODBC 驱动程序（包括 Microsoft SQL Server）

6

QPSQL PostgreSQL Driver

7

QSQLITE SQLite 3 或更高版本

8

QSQLITE2 SQLite version 2

Example

对于本章，使用静态方法与 SQLite 数据库建立连接 −

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

QSqlDatabase 类的其他方法如下：

Sr.No.

Methods & Description

1

setDatabaseName() 设置需要建立连接的数据库的名称

2

setHostName() 设置安装数据库的主机的名称

3

setUserName() 指定用于连接的用户名

4

setPassword() 设置连接对象的密码（如果存在）

5

commit() 提交事务并在成功时返回 true

6

rollback() 回滚数据库事务

7

close() Closes the connection

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))")

下面的脚本创建了一个 sports.db SQLite 数据库，其中包含一个有五条记录填充的 sportsperson 表。

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()

要确认 SQLite 数据库是否已创建并向其添加 sportsmen 表中的上述记录，请使用名为 SQLiteStudio 的 SQLite GUI 实用程序。

database handling

PyQt 中的 QSqlTableModel 类是一个高级接口，它为以单个表的形式读写记录提供了可编辑的数据模型。此模型用于填充 QTableView 对象。它向用户呈现一个可滚动的可编辑视图，可以将其放在任何顶级窗口上。

QSqlTableModel 对象以以下方式声明：

model = QtSql.QSqlTableModel()

可以将其编辑策略设置为下列任意一项 −

QSqlTableModel.OnFieldChange

所有更改都将立即应用

QSqlTableModel.OnRowChange

当用户选择不同的行时将应用更改

QSqlTableModel.OnManualSubmit

所有更改在调用 submitAll() 或 revertAll() 之前都会缓存起来

Example

在以下示例中，sportsperson 表用作模型，并且策略设置为 −

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

QTableView 类是 PyQt 中模型/视图框架的一部分。QTableView 对象创建如下 −

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

该 QTableView 对象和两个 QPushButton 窗口小部件将被添加到顶层 QDialog 窗口。add 按钮的 clicked() 信号连接到 addrow()，后者对模型表格执行 insertRow()。

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

与删除按钮相关联的槽执行一个删除行的 lambda 函数，该行由用户选择。

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_())

上述代码生成以下输出 -

database handling output

尝试添加和删除一些记录，然后返回 SQLiteStudio 以确认事务。