官方文档是C++的代码,转成python3代码后.

直接上代码

from PyQt5.QtSql import QSqlDatabase, QSqlQuery

from PyQt5.QtSql import *

class DbDao(QObject):

# 初始化并连接数据库

def __init__(self):

QObject.__init__(self)

self.db = QSqlDatabase.addDatabase("QMYSQL");

self.db.setHostName("*.*.*.*");

self.db.setDatabaseName("*");

self.db.setUserName("*");

self.db.setPassword("*");

ok = self.db.open()

print('数据库连接:' + str(ok))

# 判断是否打开

def getIsOpen(self):

return self.db.isOpen

# 查询

def query(self):

query = QSqlQuery(self.db)

query.exec("select * from chat_room")

while (query.next()):

print(query.value(0))

print(query.value(1))

print(query.value(2))

# 插入

def insert(self):

query = QSqlQuery(self.db)

query.prepare("insert into chat_room (room_id,room_title,need_password,password,ownner_id)"

"values (?,?,?,?,?)")

query.addBindValue(1004)

query.addBindValue("聊天室3")

query.addBindValue(1)

query.addBindValue(000000)

query.addBindValue(111)

result =query.exec_()

print(result)

# query = QSqlQuery(self.db)

# result=query.exec_("insert into chat_room (room_id,room_title,need_password,password,ownner_id)"

# """values (1001,'聊天室3',1,0000,11)""");

# print(result)

# 更新

def update(self):

query = QSqlQuery(self.db)

# query.prepare("update chat_room set room_title ="+"聊天"+" where room_id = "+str(1004))

result =query.exec_("""update chat_room set room_title ="聊天" where room_id = 1004""")

# result = query.exec_()

print(result)

# 删除

def delete(self):

query = QSqlQuery(self.db)

query.prepare("delete from chat_room where room_id ="+str(1003))

result =query.exec_()

print(result)

调用:

dbDao=DbDao()

ifdbDao.getIsOpen():

# dbDao.openConn()# dbDao.insert()# dbDao.query()# dbDao.delete()dbDao.update()