答案是使用MySQL C API连接数据库需先安装开发库,包含mysql.h头文件,调用mysql_init初始化,mysql_real_connect建立连接,执行查询或插入操作后释放资源。
在C++中连接和操作MySQL数据库,通常使用MySQL官方提供的C API(即 MySQL Connector/C)或其封装库如 MySQL++。本文以原生的 MySQL C API 为例,介绍如何连接、查询、插入数据,并给出完整实例。
确保系统已安装 MySQL 开发库:
sudo apt-get install libmysqlclient-dev
sudo yum install mysql-devel
编译时需链接库:-lmysqlclient
使用 提供的接口进行数据库操作。
#include#include int main() { MYSQL *conn; conn = mysql_init(NULL); if (!conn) { std::cerr << "初始化失败" << std::endl; return 1; } // 连接数据库 if (!mysql_real_connect(conn, "localhost", "root", "password", "testdb", 3306, NULL, 0)) { std::cerr << "连接失败: " << mysql_error(conn) << std::endl; mysql_close(conn); return 1; } std::cout << "数据库连接成功!" << std::endl;
说明:
mysql_init() 初始化连接句柄mysql_real_connect() 建立连接,参数依次为:主机、用户名、密码、数据库名、端口等使用 mysql_query() 执行非查询语句,用 mysql_use_result() 或 mysql_store_result() 处理查询结果。
// 插入数据
const char *insert_sql = "INSERT INTO users (name, age) VALUES ('张三', 25)";
if (mysql_query(conn, insert_sql)) {
std::cerr << "插入失败: " << mysql_error(conn) << std::endl;
} else {
std::cout << "插入成功,影响行数: " << mysql_affected_rows(conn) << std::endl;
}
// 查询数据
if (mysql_query(conn, "SELECT id, name, age FROM users")) {
std::cerr << "查询失败: " << mysql_error(conn) << std::endl;
} else {
MYSQL_RES *result = mysql_store_result(conn);
if (result) {
MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
std::cout << "ID: " << row[0]
<< ", 姓名: " << row[1]
<< ", 年龄: " << row[2] << std::endl;
}
mysql_free_result(result);
}
}
关键函数说明:
mysql_query():执行SQL字符串mysql_store_result():将结果集全部取回内存mysql_fetch_row():逐行获取数据,返回字符串数组mysql_free_result():释放结果集资源对于带参数的操作,推荐使用预处理语句。
MYSQL_STMT *stmt = mysql_stmt_init(conn);
const char *sql = "INSERT INTO users (name, age) VALUES (?, ?)";
if (mysql_stmt_prepare(stmt, sql, strlen(sql))) {
std::cerr << "预处理失败: " << mysql_stmt_error(stmt) << std::endl;
mysql_stmt_close(stmt);
return 1;
}
// 绑定参数
MYSQL_BIND bind[2];
std::string name = "李四";
int age = 30;
memset(bind, 0, sizeof(bind));
bind[0].buffer_type = MYSQL_TYPE_STRING;
bind[0].buffer = (char*)name.c_str();
bind[0].buffer_length = name.length();
bind[1].buffer_type = MYSQL_TYPE_LONG;
bind[1].buffer = &age;
if (mysql_stmt_bind_param(stmt, bind)) {
std::cerr << "绑定参数失败: " << mysql_stmt_error(stmt) << std::endl;
}
if (mysql_stmt_execute(stmt)) {
std::cerr << "执行失败: " << mysql_stmt_error(stmt) << std::endl;
} else {
std::cout << "预处理插入成功" << std::endl;
}
mysql_stmt_close(stmt);
程序结束前务必释放资源。
mysql_close(conn);
return 0;
}
完整编译命令(Linux):
g++ -o db_example db_example.cpp -lmysqlclient
注
意事项: