PyQt5 数据库处理

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

示例

本章介绍使用静态方法建立与SQLite数据库的连接。

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

QSqlDatabase类的其他方法如下：

QSqlQuery 类具有执行和操作SQL命令的功能。可以执行DDL和DML类型的SQL查询。第一步是使用以下语句创建SQlite数据库：

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

接下来，使用 QSqlQuery() 方法获得Query对象，并调用其最重要的方法exec_()，以一个包含要执行的SQL语句的字符串作为参数。

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

以下脚本使用SQLite创建了一个名为sports.db的数据库，其中包含一个名为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数据库是否创建并在其中添加了上述记录，请使用一个名为 SQLiteStudio 的SQLite图形界面工具。

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

QSqlTableModel对象的声明方式如下-

model = QtSql.QSqlTableModel()

其编辑策略可以设置为以下任何一种 –

示例

在下面的示例中，运动员表被用作模型，并设置了策略为 –

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对象和两个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_())

以上代码产生以下输出 −

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