前言
在qt中访问数据库涉及到几个关键步骤，主要包括加载数据库驱动、建立数据库连接、执行sql语句、读取结果等。下面将详细介绍这些步骤，并给出一个简单的示例，这里假设使用的是sqlite数据库。
记得首先在pro文件中添加qt = sql
1. 加载数据库驱动
qt通过数据库驱动程序来支持不同类型的数据库，例如sqlite、mysql、postgresql等。在实际使用前，通常需要确保已经包含了相应的数据库驱动模块。对于sqlite，由于qt内置了对其的支持，无需额外安装驱动。
#include#include #include // 如果使用其他数据库，可能需要包含对应的头文件，例如： // #include // 对于mysql // #include // 对于postgresql
注意： 当前qt是否已经安装将要使用的数据库驱动，可以使用qsqldatabase::drivers()去查看
#include#include int main(int argc, char *argv[]) { qcoreapplication a(argc, argv); //输出所有已经支持的数据库驱动 qstringlist drivers = qsqldatabase::drivers(); foreach (const qstring &driver, drivers) { qdebug() << driver; } return a.exec(); }
2. 创建数据库连接
创建数据库连接通常涉及指定数据库类型（如果是sqlite，则通常不需要用户名、密码和数据库地址，因为sqlite数据库文件是本地文件）。
qsqldatabase db = qsqldatabase::adddatabase("qsqlite"); // 对于sqlite
// 或者
// qsqldatabase db = qsqldatabase::adddatabase("qmysql"); // 对于mysql
// qsqldatabase db = qsqldatabase::adddatabase("qpsql"); // 对于postgresql
db.sethostname("localhost"); // 对于远程数据库，设置主机名或ip
db.setdatabasename("/path/to/mydatabase.db"); // 对于sqlite，这是数据库文件路径；对于其他数据库则是数据库名
db.setusername("username"); // 非sqlite数据库的用户名
db.setpassword("password"); // 非sqlite数据库的密码
if (!db.open()) {
qdebug() << "failed to connect to database: " << db.lasterror().text();
return false; // 连接失败
}
3. 执行sql查询或命令
使用qsqlquery类执行sql语句。
qsqlquery query;
// 插入数据
query.prepare("insert into mytable (column1, column2) values (?, ?)");
query.addbindvalue(value1);
query.addbindvalue(value2);
if (!query.exec()) {
qdebug() << "insert error: " << query.lasterror().text();
} else {
qdebug() << "row inserted successfully.";
}
// 查询数据
query.clear();
query.prepare("select * from mytable where id = ?");
query.bindvalue(0, someid);
if (query.exec()) {
while (query.next()) {
qstring value1 = query.value(0).tostring();
int value2 = query.value(1).toint();
// ... 处理查询结果 ...
}
} else {
qdebug() << "select error: " << query.lasterror().text();
}
4. 关闭数据库连接
在完成所有数据库操作后，关闭连接以释放资源。
db.close();
示例完整代码片段
#include#include #include #include int main(int argc, char *argv[]) { qcoreapplication a(argc, argv); qsqldatabase db = qsqldatabase::adddatabase("qsqlite"); db.setdatabasename(":memory:"); // 使用内存数据库，也可以替换为实际文件路径 if (!db.open()) { qdebug() << "cannot open database: " << db.lasterror().text(); return 1; } // 创建表 qsqlquery createquery; createquery.exec("create table if not exists mytable (id integer primary key, column1 varchar(40), column2 int)"); // 插入数据 qsqlquery insertquery; insertquery.prepare("insert into mytable (column1, column2) values (?, ?)"); insertquery.addbindvalue("example value"); insertquery.addbindvalue(123); if (!insertquery.exec()) { qdebug() << "insert error: " << insertquery.lasterror().text(); } else { qdebug() << "row inserted successfully."; } // 查询数据 qsqlquery selectquery; selectquery.prepare("select * from mytable"); if (selectquery.exec()) { while (selectquery.next()) { qstring column1value = selectquery.value(1).tostring(); int column2value = selectquery.value(2).toint(); qdebug() << "column1: " << column1value << ", column2: " << column2value; } } else { qdebug() << "select error: " << selectquery.lasterror().text(); } db.close(); return a.exec(); }
以上代码演示了如何使用qt连接sqlite数据库，执行创建表、插入数据和查询数据的操作。
注意
- 对于不同的数据库类型，配置连接参数的方式会有所不同，但执行sql的基本模式是相似的。
- 上述代码中使用的sqlite数据库的内存模式。访问速度非常快。适合作为临时的缓存数据库使用。
打开多个数据库
在qt程序中同时打开和操作多个数据库，可以通过创建多个qsqldatabase实例来实现。每个数据库实例都有自己的名字（connection name），这样可以区分不同数据库连接。以下是一个简单的示例，展示如何同时打开两个sqlite数据库：
#include#include #include #include int main(int argc, char *argv[]) { qapplication a(argc, argv); // 打开第一个sqlite数据库 qsqldatabase db1 = qsqldatabase::adddatabase("qsqlite"); db1.setdatabasename("first_db.sqlite"); if (!db1.open()) { qdebug() << "failed to open the first database: " << db1.lasterror().text(); return 1; } // 执行第一个数据库的查询 qsqlquery query1(db1); query1.exec("create table if not exists table1 (id integer primary key, name text)"); if (!query1.isactive()) qdebug() << "error creating table in first db: " << query1.lasterror().text(); // 打开第二个sqlite数据库 qsqldatabase db2 = qsqldatabase::adddatabase("qsqlite"); db2.setdatabasename("second_db.sqlite"); if (!db2.open()) { qdebug() << "failed to open the second database: " << db2.lasterror().text(); db1.close(); return 1; } // 执行第二个数据库的查询 qsqlquery query2(db2); query2.exec("create table if not exists table2 (id integer primary key, name text)"); if (!query2.isactive()) qdebug() << "error creating table in second db: " << query2.lasterror().text(); // 不论操作成功与否，记得在不再使用时关闭数据库连接 db1.close(); db2.close(); return a.exec(); }
在上述示例中，我们创建了两个不同的sqlite数据库连接，并分别为它们创建了表。当然，你可以根据需要连接不同类型（如mysql、postgresql等）的数据库，只需在调用adddatabase时指定正确的数据库驱动名称即可。
务必注意，当在多线程环境中操作数据库时，即使qt的数据库模块是线程安全的，也应该确保在同一时刻仅在一个线程中操作单个数据库连接，或者正确地管理线程间的同步，防止数据竞争问题。同时，也要确保在不再需要时关闭数据库连接，以避免资源泄露。
使用建议
- 数据库处理通常在主线程，如果必要在其他线程中访问数据库，切记在哪个线程访问数据库就在哪个线程中打开数据库。
- 如果甲方对数据库没有硬性要求，建议使用sqlite。
- 在连接远程数据库进行查询数据的时候，如果遇到访问缓慢情况，建议开启
qsqlquery的setforwardonly(true)。可以看到奇迹的发生。
