C++怎么连接和操作MySQL数据库_C++数据库编程与API使用

最常用方式是使用MySQL C API进行数据库操作。需先安装开发库,包含mysql.h头文件并链接libmysqlclient库,通过mysql_init、mysql_real_connect等函数完成连接与查询,使用mysql_query执行SQL语句,mysql_store_result获取结果集,逐行读取后释放资源;为防SQL注入应使用预处理语句;也可选MySQL Connector/C++实现面向对象操作,但C API更轻量稳定。

要在C++中连接和操作MySQL数据库,最常用的方式是使用MySQL官方提供的C API(即 MySQL Connector/C),并通过其封装的C++接口或直接调用C函数进行数据库操作。虽然MySQL也提供了专门的C++连接器(MySQL Connector/C++),但目前更稳定且广泛使用的是基于C API的开发方式。

1. 安装MySQL开发库

在开始前,需要确保系统中安装了MySQL客户端开发库:

  • Ubuntu/Debian:运行 sudo apt-get install libmysqlclient-dev
  • CentOS/RHEL:运行 sudo yum install mysql-develdnf install mysql-devel
  • Windows:下载并安装 MySQL Connector/C,配置头文件和lib路径

2. 包含头文件并链接库

在C++代码中使用MySQL C API时,需包含 头文件,并在编译时链接 libmysqlclient 库。

示例代码结构:

#include 
#include 

int main() { MYSQL conn; MYSQL_RES res; MYSQL_ROW row;

conn = mysql_init(NULL);

// 连接数据库
if (!mysql_real_connect(conn, "localhost", "user", "password", "testdb", 3306, NULL, 0)) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "连接失败:" zuojiankuohaophpcnzuojiankuohaophpcn mysql_error(conn) zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    return 1;
}

// 执行查询
if (mysql_query(conn, "SELECT id, name FROM users")) {
    std::cerr zuojiankuohaophpcnzuojiankuohaophpcn "查询失败:" zuojiankuohaophpcnzuojiankuohaophpcn mysql_error(conn) zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
    mysql_close(conn);
    return 1;
}

res = mysql_store_result(conn);
while ((row = mysql_fetch_row(res))) {
    std::cout zuojiankuohaophpcnzuojiankuohaophpcn "ID: " zuojiankuohaophpcnzuojiankuohaophpcn row[0] zuojiankuohaophpcnzuojiankuohaophpcn ", Name: " zuojiankuohaophpcnzuojiankuohaophpcn row[1] zuojiankuohaophpcnzuojiankuohaophpcn std::endl;
}

mysql_free_result(res);
mysql_close(conn);
return 0;

}

3. 编译命令(Linux)

编译时需链接MySQL客户端库:

g++ -o db_example db_example.cpp -lmysqlclient

若头文件不在默认路径,可添加 -I/usr/include/mysql;库路径不同时使用 -L 指定。

4. 常用API函数说明

  • mysql_init():初始化MySQL连接句柄
  • mysql_real_connect():建立与MySQL服务器的连接
  • mysql_query():执行SQL语句(如SELECT、INSERT等)
  • mysql_store_result():获取查询结果集
  • mysql_use_result():逐行读取结果(适用于大数据量)
  • mysql_fetch_row():从结果集中取出一行数据
  • mysql_free_result():释放结果集内存
  • mysql_close():关闭数据库连接

5. 使用预处理语句(防止SQL注入)

对于用户输入的数据,建议使用预处理语句(prepared statements)来提升安全性和性能。

MYSQL_STMT *stmt = mysql_stmt_init(conn);
std::string sql = "INSERT INTO users(name, age) VALUES(?, ?)";
mysql_stmt_prepare(stmt, sql.c_str(), sql.length());

// 绑定参数并执行... // (此处涉及MYSQL_BIND结构体绑定变量)

6. 使用MySQL Connector/C++(可选)

MySQL官方也提供C++风格的连接器——MySQL Connector/C++,支持JDBC-like接口。

特点:

  • 面向对象设计,使用 sql::Statementsql::ResultSet 等类
  • 语法更接近Java JDBC
  • 需额外安装Connector/C++库

示例片段:

#include 
#include 

sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance(); std::unique_ptr con(driver->connect("tcp://127.0.0.1:3306", "user", "pass")); con->setSchema("testdb");

std::unique_ptr stmt(con->createStatement()); std::unique_ptr res(stmt->executeQuery("SELECT * FROM users")); while (res->next()) { std::cout << "Name: " << res->getString("name") << std::endl; }

基本上就这些。选择C API还是C++ Connector取决于项目需求:C API更轻量稳定,C++接口更现代但依赖较多。只要掌握连接、查询、结果处理和资源释放的基本流程,就能高效完成数据库操作。