一般使用mysql或者sqlite。
2. 将两个压缩包解压后的文件都放到刚刚新建的bin文件夹下。
3. 增加path环境变量
4.验证
#表示项目使用sql
QT +=sql
注意：连接sqlite 这里有个坑，就算连接sqlite失败，他也会认为你连接成功，等进行crud时就会失败。
bool bl = m_db.open();
if(!bl)
{
qDebug() << m_db.lastError().text();
return;
}
else
{
// 这个代码可能会误导你
qDebug() << "数据库连接成功了...";
}
#include "mainwindow.h"
#include <QApplication>
#include <QString>
#include <QtSql/QSqlDatabase>
#include <QtSql/QSqlQuery>
#include <QtSql/QSqlError>
#include <QDebug>
int main(int argc, char *argv[])
{
QApplication a(argc, argv);
MainWindow w;
w.show();
//1.根据驱动获取数据库操作实例
QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
//2.加载数据源
db.setHostName("localhost");
//如果没有这个数据库那么会创建，如果存在，那么不会创建
db.setDatabaseName("qt_test.db");
// 3. 连接数据库
bool bl = db.open();
if(!bl)
{
qDebug() << db.lastError().text();
}
else
{
//注意：这个连接成功不能作为正真连接成功数据的标准。如果能操作数据库才算连接成功
qDebug() <<db.databaseName() <<"数据库连接成功了...";
}
QSqlQuery query;
//创建表
query.exec("create table addres(id int primary key, name varchar);");
//插入
query.prepare("INSERT INTO addres (id, name) "
"VALUES (:id, :name)");
query.bindValue(":id", 1002);
query.bindValue(":name", "上海");
query.exec();
//查询
query.exec("select id,name from addres");
// 遍历结果集
while(query.next())
{
// 从当前记录中取出各个字段的值
qDebug() << query.value(0).toString()
<< query.value(1).toString();
}
//修改
query.prepare("update addres set name = :name where id = 1001");
query.bindValue(":name", "广东");
query.exec();
//删除
query.exec("delete from addres where id = 1002");
//查询
query.exec("select id,name from addres");
qDebug() <<"----------";
// 遍历结果集
while(query.next())
{
// 从当前记录中取出各个字段的值
qDebug() << query.value(0).toString()
<< query.value(1).toString();
}
return a.exec();
}
- qt_test.db 创建的位置：
- 程序输出：
- 使用可视化工具查看：
这个封装有点鸡肋。只推荐使用连接数据库的操作，对数据进行crud不推荐使用封装的方法，直接使用QSqlQuery 提供的方法即可。
#ifndef SQLUTIL_H
#define SQLUTIL_H
#include <QObject>
#include <QString>
#include <QtSql/QSqlDatabase>
#include <QtSql/QSqlQuery>
#include <QtSql/QSqlError>
//单例模式封装sql操作
class SqlUtil : public QObject
{
public:
static SqlUtil *instance();
void setDatabaseInfo(QString strDriver,QString strHostName,int port,QString strDatabaseName, QString strUserName, QString strPassWord);
void setDatabaseInfo(QString strDriver,QString strHostName,QString strDatabaseName);
void getDrivers();
void initDatabase();
void closeDatabase();
QSqlDatabase getDb();
/*******************************************
* 执行Sql语句
* 输入值：
* strSql 需要执行的语句 主要包括 增 删 改 操作
* 返回值：返回执行是否成功
*****************************************/
bool executeSql(QString strSql);
bool executeSql(QSqlQuery query);
/*******************************************
* 执行Sql语句
* 输入值：
* variantlistResult 存储查询的结果
* strSql 需要执行的语句 查询操作
* iColumn 查询语句返回的列数
*
* 返回值： 返回查询是否成功
*****************************************/
bool selectData(QList<QVariantList> &variantlistResult,QString strSql,int iColumn);//查询数据
private:
//私有化构造器
explicit SqlUtil();
~SqlUtil();
//数据库实例
QSqlDatabase m_db;
QString m_driver; //驱动
QString m_strHostName; //服务器名称
int m_port; //端口
QString m_strDatabaseName; //数据库名称
QString m_strUserName; //用户名
QString m_strPassWord; //密码
//创建单例连接数据库的实例
static SqlUtil *sqlUtil ;
};
#endif // SQLUTIL_H
#include "sqlutil.h"
#include <QDebug>
//必须让单例指向null，不然会报错
SqlUtil * SqlUtil::sqlUtil = nullptr;
SqlUtil::SqlUtil()
{
}
SqlUtil::~SqlUtil()
{
}
SqlUtil *SqlUtil::instance()
{
if(sqlUtil == nullptr)
{
sqlUtil = new SqlUtil();
return sqlUtil;
}
else
{
return sqlUtil;
}
}
void SqlUtil::setDatabaseInfo(QString strDriver,QString strHostName,int port,QString strDatabaseName, QString strUserName, QString strPassWord)
{
m_driver = strDriver;
m_strHostName = strHostName;
m_port = port;
m_strDatabaseName = strDatabaseName;
m_strUserName = strUserName;
m_strPassWord = strPassWord;
}
void SqlUtil::setDatabaseInfo(QString strDriver,QString strHostName,QString strDatabaseName)
{
m_driver = strDriver;
m_strHostName = strHostName;
m_strDatabaseName = strDatabaseName;
}
//获取QT支持的驱动
void SqlUtil::getDrivers()
{
QStringList ls = QSqlDatabase::drivers();
qDebug() << "当前Qt版本支持的驱动有:"<<ls;
}
//获取操作数据库的实例
void SqlUtil::initDatabase()
{
//mysql
//1.获取数据库操作实例
m_db = QSqlDatabase::addDatabase(m_driver);
//2.加载数据源
m_db.setHostName(m_strHostName);
m_db.setPort(m_port); // 如果使用的是默认端口, 可以不调用该函数
m_db.setDatabaseName(m_strDatabaseName);
m_db.setUserName(m_strUserName);
m_db.setPassword(m_strPassWord);
// 3. 连接数据库
bool bl = m_db.open();
if(!bl)
{
qDebug() << m_db.lastError().text();
return;
}
else
{
qDebug() << "数据库连接成功了...";
}
// 开启事务
//m_db.transaction();
}
void SqlUtil::closeDatabase()
{
if(m_db.isOpen())
{
m_db.close();
qDebug()<<"成功关闭数据库";
}
else
{
qDebug()<<"数据库已关闭";
}
}
QSqlDatabase SqlUtil::getDb(){
return m_db;
}
bool SqlUtil::executeSql(QString strSql)
{
if(!m_db.isOpen())
{
//重连
initDatabase();
if(!m_db.isOpen())
{
qDebug()<<"Failed to connect to root Sql admin";
return false;
}
else
{
qDebug()<<"successed to connect";
}
}
QSqlQuery query;
query.prepare(strSql);
bool bExecute = query.exec();
return bExecute;
}
bool SqlUtil::executeSql(QSqlQuery query)
{
if(!m_db.isOpen())
{
initDatabase();
if(!m_db.isOpen())
{
qDebug()<<"Failed to connect to root Sql admin";
return false;
}
else
{
qDebug()<<"successed to connect";
}
}
bool bExecute = query.exec();
return bExecute;
}
bool SqlUtil::selectData(QList<QVariantList> &variantlistResult, QString strSql, int iColumn)
{
if(!m_db.isOpen())
{
initDatabase();
if(!m_db.isOpen())
{
qDebug()<<"Failed to connect to root Sql admin";
return false;
}
else
{
qDebug()<<"successed to connect";
}
}
QSqlQuery query;
query.prepare(strSql);
bool flag = query.exec();
QVariantList variantlist;
while(query.next())
{
for(int i= 0; i < iColumn; i++)
{
QVariant value = query.value(i);
variantlist.append(value);
}
variantlistResult.push_back(variantlist);
variantlist.clear();
}
return flag;
}
#include "mainwindow.h"
#include <QApplication>
//操作数据库的依赖
#include "sqlutil.h"
int main(int argc, char *argv[])
{
QApplication a(argc, argv);
MainWindow w;
w.setWindowTitle("主页");
w.setWindowIcon(QIcon(":/mainwin/resources/wxb主页.png"));
w.show();
//初始化数据库
SqlUtil *sqlUtil = SqlUtil::instance();
//连接sqlite
sqlUtil->setDatabaseInfo("QSQLITE","localhost","qt.db");
sqlUtil->initDatabase();
return a.exec();
}
2. 使用
//先获取数据库操作对象:SqlUtil::instance()，再操作里面封装好的方法，比如查询，插入，关闭数据库。
SqlUtil::instance()->executeSql(query);
#include "mainwindow.h"
#include <QApplication>
#include <QString>
#include <QtSql/QSqlDatabase>
#include <QtSql/QSqlQuery>
#include <QtSql/QSqlError>
#include <QDebug>
int main(int argc, char *argv[])
{
QApplication a(argc, argv);
MainWindow w;
w.show();
//1.根据驱动获取数据库操作实例
QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
//2.加载数据源
db.setHostName("localhost");
//如果没有这个数据库那么会创建，如果存在，那么不会创建
db.setDatabaseName("qt_test.db");
// 3. 连接数据库
bool bl = db.open();
if(!bl)
{
qDebug() << db.lastError().text();
}
else
{
//注意：这个连接成功不能作为正真连接成功数据的标准。如果能操作数据库才算连接成功
qDebug() <<db.databaseName() <<"数据库连接成功了...";
}
QSqlQuery query;
//创建表
query.exec("create table addres(id int primary key, name varchar);");
//插入
query.prepare("INSERT INTO addres (id, name) "
"VALUES (:id, :name)");
query.bindValue(":id", 1002);
query.bindValue(":name", "上海");
query.exec();
//查询
query.exec("select id,name from addres");
// 遍历结果集
while(query.next())
{
// 从当前记录中取出各个字段的值
qDebug() << query.value(0).toString()
<< query.value(1).toString();
}
//修改
query.prepare("update addres set name = :name where id = 1001");
query.bindValue(":name", "广东");
query.exec();
//删除
query.exec("delete from addres where id = 1002");
//查询
query.exec("select id,name from addres");
qDebug() <<"----------";
// 遍历结果集
while(query.next())
{
// 从当前记录中取出各个字段的值
qDebug() << query.value(0).toString()
<< query.value(1).toString();
}
return a.exec();
}