qt sqlite3连接池

在 Qt 中，可以使用 QSqlDatabase 类来连接数据库，包括 SQLite3 数据库。要实现连接池，可以结合使用 QSqlDatabase 和 QThreadPool 类。以下是一个简单的实现示例：

1. 创建数据库连接池类

class DatabasePool : public QObject
{
    Q_OBJECT

public:
    DatabasePool(QObject *parent = nullptr);
    ~DatabasePool();

    static DatabasePool& instance();

    QSqlDatabase acquire();
    void release(QSqlDatabase db);

private:
    QList<QSqlDatabase> m_pool;
    QMutex m_mutex;
};

2. 实现连接池类的构造函数、析构函数和单例模式

DatabasePool::DatabasePool(QObject *parent)
    : QObject(parent)
{
}

DatabasePool::~DatabasePool()
{
    QMutexLocker locker(&m_mutex);
    for (QSqlDatabase db : m_pool) {
        db.close();
    }
}

DatabasePool& DatabasePool::instance()
{
    static DatabasePool instance;
    return instance;
}

3. 实现 acquire() 和 release() 函数，用于从连接池中获取和释放连接

QSqlDatabase DatabasePool::acquire()
{
    QMutexLocker locker(&m_mutex);
    if (m_pool.isEmpty()) {
        QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
        db.setDatabaseName("database.db");
        db.open();
        m_pool.append(db);
        return db;
    } else {
        return m_pool.takeFirst();
    }
}

void DatabasePool::release(QSqlDatabase db)
{
    QMutexLocker locker(&m_mutex);
    if (db.isValid()) {
        m_pool.append(db);
    }
}

4. 将数据库连接池类和线程池类结合使用

QThreadPool::globalInstance()->setMaxThreadCount(10);

for (int i = 0; i < 100; ++i) {
    QThreadPool::globalInstance()->start([=](){
        QSqlDatabase db = DatabasePool::instance().acquire();
        // do something with db
        DatabasePool::instance().release(db);
    });
}

这样，就可以实现一个简单的 SQLite3 连接池。需要注意的是，这只是一个示例，实际应用中还需要考虑线程安全、连接超时等问题。