一篇文章详解Qt中如何访问数据库_C/C++

前言

在qt中访问数据库涉及到几个关键步骤，主要包括加载数据库驱动、建立数据库连接、执行sql语句、读取结果等。下面将详细介绍这些步骤，并给出一个简单的示例，这里假设使用的是sqlite数据库。

记得首先在pro文件中添加qt += sql

1. 加载数据库驱动

qt通过数据库驱动程序来支持不同类型的数据库，例如sqlite、mysql、postgresql等。在实际使用前，通常需要确保已经包含了相应的数据库驱动模块。对于sqlite，由于qt内置了对其的支持，无需额外安装驱动。

#include <qsqldatabase>
#include <qsqlquery>
#include <qsqlerror>

// 如果使用其他数据库，可能需要包含对应的头文件，例如：
// #include <qmysqldriver> // 对于mysql
// #include <qpsqldriver> // 对于postgresql

注意： 当前qt是否已经安装将要使用的数据库驱动，可以使用qsqldatabase::drivers()去查看

#include <qtsql>  
#include <qdebug>  
  
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 <qcoreapplication>
#include <qsqldatabase>
#include <qsqlquery>
#include <qsqlerror>

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 <qapplication>
#include <qsqldatabase>
#include <qsqlquery>
#include <qdebug>

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的数据库模块是线程安全的，也应该确保在同一时刻仅在一个线程中操作单个数据库连接，或者正确地管理线程间的同步，防止数据竞争问题。同时，也要确保在不再需要时关闭数据库连接，以避免资源泄露。