C++如何连接MySQL或SQLite数据库_C++数据库连接与查询操作示例

C++中常用MySQL和SQLite数据库,MySQL通过MySQL Connector/C++库连接,使用X DevAPI进行会话、查询操作;SQLite则用sqlite3 C接口,轻量无需服务器。示例展示了MySQL的连接、查询及SQLite的建表、插入、查询流程,编译需链接相应库。注意事项包括版本兼容性、SQL注入防护与错误处理,适用于网络服务或本地存储场景。

在C++中连接数据库,常用的是MySQL和SQLite。两者使用方式不同,但都能通过第三方库实现数据操作。下面分别介绍如何用C++连接MySQL和SQLite,并进行基本的查询操作。

连接MySQL数据库

要连接MySQL,可以使用官方提供的MySQL Connector/C++库。这个库支持基于C++的API来操作MySQL数据库。

步骤1:安装MySQL Connector/C++
你可以从MySQL官网下载Connector/C++,或通过包管理器安装。例如在Ubuntu上:

sudo apt-get install libmysqlcppconn-dev

步骤2:包含头文件并链接库
编译时需要链接-lmysqlcppconn

示例代码:连接MySQL并查询数据

#include 
#include 

int main() { try { // 建立会话 mysqlx::Session session("localhost", 33060, "root", "your_password");

    // 选择数据库
    mysqlx::Schema db = session.getSchema("testdb");

    // 获取表
    mysqlx::Table table = db.getTable("users");

    // 查询所有记录
    mysqlx::RowResult result = table.select("id", "name").execute();

    // 遍历结果
    for (const auto &row : result) {
        std::cout zuojiankuohaophpcnzuojiankuohaophpcn "ID: " zuojiankuohaophpcnzuojiankuohaophpcn row[0] zuojiankuohaophpcnzuojiankuohaophpcn ", Name: " zuojiankuohaophpcnzuojiankuohaophpcn row[1] zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    }

    session.close();
} catch (const std::exception &e) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "Error: " zuojiankuohaophpcnzuojiankuohaophpcn e.what() zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
}
return 0;

}

编译命令:
g++ -o mysql_demo mysql_demo.cpp -lmysqlcppconn

连接SQLite数据库

SQLite更轻量,无需服务器,适合本地应用。常用的是sqlite3 C接口,被广泛用于C++项目。

步骤1:安装SQLite开发库
在Ubuntu上运行:

sudo apt-get install libsqlite3-dev

步骤2:包含sqlite3.h并链接-lsqlite3

示例代码:打开SQLite数据库并执行查询

#include 
#include 
#include 

// 回调函数:处理每一行数据 static int callback(void *data, int argc, char argv, char azColName) { for (int i = 0; i < argc; ++i) { std::cout << azColName[i] << " = " << (argv[i] ? argv[i] : "NULL") << "; "; } std::cout << std::endl; return 0; }

int main() { sqlite3 db; char errMsg = nullptr; int rc;

// 打开数据库(如果不存在会自动创建)
rc = sqlite3_open("example.db", &db);
if (rc) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "Can't open database: " zuojiankuohaophpcnzuojiankuohaophpcn sqlite3_errmsg(db) zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    return 1;
}

// 创建表
std::string createSQL = "CREATE TABLE IF NOT EXISTS users ("
                        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
                        "name TEXT NOT NULL);";

rc = sqlite3_exec(db, createSQL.c_str(), nullptr, nullptr, &errMsg);
if (rc != SQLITE_OK) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "SQL error: " zuojiankuohaophpcnzuojiankuohaophpcn errMsg zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    sqlite3_free(errMsg);
}

// 插入测试数据
std::string insertSQL = "INSERT INTO users (name) VALUES ('Alice'), ('Bob');";
rc = sqlite3_exec(db, insertSQL.c_str(), nullptr, nullptr, &errMsg);
if (rc != SQLITE_OK) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "Insert error: " zuojiankuohaophpcnzuojiankuohaophpcn errMsg zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    sqlite3_free(errMsg);
}

// 查询数据
std::string selectSQL = "SELECT * FROM users;";
rc = sqlite3_exec(db, selectSQL.c_str(), callback, nullptr, &errMsg);
if (rc != SQLITE_OK) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "Select error: " zuojiankuohaophpcnzuojiankuohaophpcn errMsg zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    sqlite3_free(errMsg);
}

sqlite3_close(db);
return 0;

}

编译命令:
g++ -o sqlite_demo sqlite_demo.cpp -lsqlite3

关键注意事项

  • MySQL Connector/C++ 使用X DevAPI(推荐)或Classic API,注意版本兼容性。
  • SQLite是文件型数据库,操作前确认路径权限。
  • 生产环境中应使用预处理语句防止SQL注入,尤其是用户输入参与拼接时。
  • 记得检查返回值和错误信息,避免程序崩溃。

基本上就这些。两种数据库各有用途,MySQL适合网络服务,SQLite适合嵌入式或本地存储。掌握基础连接和查询后,可进一步学习事务、索引和性能优化。