[C++ Qt] SQLite 数据库连接池

希纱

特点如下：

---

1. 单例模式

   • 使用单例模式确保全局只有一个连接池实例
   • 禁用了拷贝构造和赋值操作符

2. 连接管理

   • 支持最大连接数限制 (m_maxConnections)
   • 支持初始连接数设置 (initialConnections)
   • 使用原子计数器 (m_connectionCounter) 跟踪连接总数
   • 维护可用连接队列 (m_availableConnections) 和使用中连接集合 (m_inUseConnections)

3. 线程安全

   • 使用互斥锁保护共享资源
   • 使用条件变量实现等待/唤醒机制
   • 使用原子操作进行计数

4. 智能指针管理

   • 使用 shared_ptr 自动管理连接的生命周期
   • DBConnection 析构时自动释放连接回连接池

5. 连接复用机制

   • 优先使用可用连接
   • 当无可用连接且未达到最大连接数时创建新连接
   • 支持连接有效性检查和自动重连

6. 错误处理

   • 连接创建失败时的回滚机制
   • 连接无效时的重新创建机制
   • 超时等待机制（5秒超时）

7. 资源清理

   • 支持关闭所有连接
   • 正确处理事务回滚
   • 清理无效连接

8. 数据库表管理

   • 支持表结构同步
   • 支持字段类型变更

   • 支持新增和删除字段

暂时没做其它功能, 有需求的同学自行扩展~

希纱

有点儿小修改, 改了一下同步表的逻辑, 现已支持复合主键:
bool SqliteUtils::SyncTable(const QString& tableName, const QMap<QString, FieldDefinition>& fieldDefinitions) {
    auto dbConnection = AcquireDBConnection();
    if (!dbConnection) {
        return false;
    }

    QSqlQuery sqlQuery(dbConnection->database());
    sqlQuery.prepare("SELECT name FROM sqlite_master WHERE type='table' AND name = :tableName");
    sqlQuery.bindValue(":tableName", tableName);

    if (!sqlQuery.exec()) {
        return false;
    }

    bool tableExists = sqlQuery.next();
    if (!tableExists) {
        QStringList fieldDefinitionList;
        QStringList primaryKeys;

        QString createTableSql = QString("CREATE TABLE %1 (").arg(tableName);
        for (auto it = fieldDefinitions.constBegin(); it != fieldDefinitions.constEnd(); ++it) {
            if (it.key() == "PRIMARY KEY") {
                if (!it.value().defaultValue.isEmpty()) {
                    primaryKeys.append(it.value().defaultValue);
                }
                continue;
            }

            QString fieldSql = QString("%1 %2").arg(it.key(), it.value().fieldType);

            if (it.value().notNull) {
                fieldSql += " NOT NULL";
            }

            if (!it.value().defaultValue.isEmpty()) {
                fieldSql += QString(" DEFAULT %1").arg(it.value().defaultValue);
            }

            if (it.value().isPrimaryKey) {
                fieldSql += " PRIMARY KEY";
            }

            fieldDefinitionList.append(fieldSql);
        }

        if (!primaryKeys.isEmpty()) {
            fieldDefinitionList.append(QString("PRIMARY KEY %1").arg(primaryKeys.join(", ")));
        }

        createTableSql += fieldDefinitionList.join(", ") + ")";
        return sqlQuery.exec(createTableSql);
    } else {
        sqlQuery.prepare(QString("PRAGMA table_info(%1)").arg(tableName));
        if (!sqlQuery.exec()) {
            return false;
        }

        bool requireUpdate = false;
        QMap<QString, QString> existingFieldTypes;
        while (sqlQuery.next()) {
            QString fieldName = sqlQuery.value(1).toString();
            QString fieldType = sqlQuery.value(2).toString();

            existingFieldTypes[fieldName] = fieldType;
            if (!fieldDefinitions.contains(fieldName)) {
                requireUpdate = true;
                continue;
            }

            if (fieldDefinitions[fieldName].fieldType.toUpper() != fieldType.toUpper()) {
                requireUpdate = true;
            }
        }

        for (auto it = fieldDefinitions.constBegin(); it != fieldDefinitions.constEnd(); ++it) {
            if (!existingFieldTypes.contains(it.key())) {
                requireUpdate = true;
                break;
            }
        }

        if (requireUpdate) {
            QString tempTableName = QString("%1_%2").arg(tableName).arg(QDateTime::currentMSecsSinceEpoch());

            QStringList selectFields;
            QStringList fieldDefinitionList;
            QStringList primaryKeys;
            QStringList actualFields;

            QString createTempTableSql = QString("CREATE TABLE %1 (").arg(tempTableName);
            for (auto it = fieldDefinitions.constBegin(); it != fieldDefinitions.constEnd(); ++it) {
                if (it.key() == "PRIMARY KEY") {
                    if (!it.value().defaultValue.isEmpty()) {
                        primaryKeys.append(it.value().defaultValue);
                    }
                    continue;
                }
                actualFields.append(it.key());

                QString fieldSql = QString("%1 %2").arg(it.key(), it.value().fieldType);

                if (it.value().notNull) {
                    fieldSql += " NOT NULL";
                }

                if (!it.value().defaultValue.isEmpty()) {
                    fieldSql += QString(" DEFAULT %1").arg(it.value().defaultValue);
                }

                if (it.value().isPrimaryKey) {
                    fieldSql += " PRIMARY KEY";
                }

                fieldDefinitionList.append(fieldSql);

                if (existingFieldTypes.contains(it.key())) {
                    if (it.value().fieldType.toUpper() == "INTEGER") {
                        selectFields.append(QString("CAST(ROUND(CASE WHEN %1 GLOB '*[0-9]*' THEN %1 ELSE 0 END) AS INTEGER) AS %1").arg(it.key()));
                    } else if (it.value().fieldType.toUpper() == "REAL") {
                        selectFields.append(QString("CAST(CASE WHEN %1 GLOB '*[0-9]*' THEN %1 ELSE 0 END AS REAL) AS %1").arg(it.key()));
                    } else if (it.value().fieldType.toUpper() == "TEXT") {
                        selectFields.append(QString("CAST(%1 AS TEXT) AS %1").arg(it.key()));
                    } else {
                        selectFields.append(it.key());
                    }
                } else {
                    if (!it.value().defaultValue.isEmpty()) {
                        selectFields.append(QString("%1 AS %2").arg(it.value().defaultValue, it.key()));
                    } else {
                        selectFields.append("NULL AS " + it.key());
                    }
                }
            }

            if (!primaryKeys.isEmpty()) {
                fieldDefinitionList.append(QString("PRIMARY KEY %1").arg(primaryKeys.join(", ")));
            }

            createTempTableSql += fieldDefinitionList.join(", ") + ")";
            if (!sqlQuery.exec(createTempTableSql)) {
                return false;
            }

            QString copyDataSql = QString("INSERT INTO %1 (%2) SELECT %3 FROM %4").arg(tempTableName, actualFields.join(", "), selectFields.join(", "), tableName);
            if (!sqlQuery.exec(copyDataSql)) {
                return false;
            }

            QString dropTableSql = QString("DROP TABLE IF EXISTS %1").arg(tableName);
            if (!sqlQuery.exec(dropTableSql)) {
                return false;
            }

            QString renameTableSql = QString("ALTER TABLE %1 RENAME TO %2").arg(tempTableName, tableName);
            return sqlQuery.exec(renameTableSql);
        } else {
            return true;
        }
    }
}

面具，

xxbing

学习数据库连接正需要

吾爱学技术

感谢分享，很给力！~

corking

感谢分享！

98小青年

nbifdsffdgfdgdfgfdgdfgdf

大墩墩

666666666666666666666666666666666666666666

year1970

感谢分享

yuxuanju

感谢分享学习。