C++连接MySQL数据库主要依赖MySQL官方提供的C语言API接口,也就是MySQL C API,该接口可以直接在C++项目中调用,实现数据库的连接、查询、修改等各类操作。在使用前需要先完成对应的环境配置,确保开发环境可以正常加载MySQL的相关库文件。

环境准备
首先需要安装MySQL数据库服务,同时获取MySQL的开发库文件。如果是Windows系统,可以下载MySQL Installer,安装时勾选开发组件,获取include目录下的头文件和lib目录下的库文件。如果是Linux系统,可以通过包管理器安装libmysqlclient-dev包,安装完成后头文件会存放在/usr/include/mysql目录,库文件存放在/usr/lib目录。
在项目中需要引入对应的头文件,同时链接MySQL的库文件。如果是使用GCC编译,需要添加-lmysqlclient参数,如果是使用Visual Studio,需要在项目属性中添加头文件目录和库文件目录,同时在链接器输入中添加libmysql.lib。
核心API介绍
连接和操作MySQL数据库需要用到以下几个核心函数:
- mysql_init:初始化一个MYSQL对象,用于后续的连接和操作
- mysql_real_connect:使用指定的参数连接MySQL数据库
- mysql_query:执行SQL语句,支持查询、插入、修改、删除等操作
- mysql_store_result:获取查询语句返回的结果集
- mysql_fetch_row:从结果集中逐行获取数据
- mysql_free_result:释放结果集占用的内存
- mysql_close:关闭数据库连接,释放相关资源
完整连接与操作示例
以下是一个完整的C++连接MySQL数据库并执行各类操作的示例代码,代码中包含详细的注释说明每一步的作用:
#include <mysql/mysql.h>
#include <iostream>
#include <string>
using namespace std;
int main() {
// 初始化MYSQL对象
MYSQL* mysql = mysql_init(nullptr);
if (mysql == nullptr) {
cout << "MySQL初始化失败" << endl;
return -1;
}
// 设置数据库连接参数
const char* host = "127.0.0.1"; // 数据库地址
const char* user = "root"; // 数据库用户名
const char* password = "123456"; // 数据库密码
const char* db = "test_db"; // 要连接的数据库名
unsigned int port = 3306; // 数据库端口
const char* unix_socket = nullptr;
unsigned long client_flag = 0;
// 连接数据库
MYSQL* connect_ret = mysql_real_connect(mysql, host, user, password, db, port, unix_socket, client_flag);
if (connect_ret == nullptr) {
cout << "数据库连接失败,错误信息:" << mysql_error(mysql) << endl;
mysql_close(mysql);
return -1;
}
cout << "数据库连接成功" << endl;
// 执行查询操作,查询user表的所有数据
string query_sql = "SELECT id, name, age FROM user";
if (mysql_query(mysql, query_sql.c_str()) != 0) {
cout << "查询语句执行失败,错误信息:" << mysql_error(mysql) << endl;
} else {
// 获取查询结果集
MYSQL_RES* result = mysql_store_result(mysql);
if (result == nullptr) {
cout << "获取结果集失败,错误信息:" << mysql_error(mysql) << endl;
} else {
// 获取结果集的列数
unsigned int field_count = mysql_num_fields(result);
// 获取列名
MYSQL_FIELD* fields = mysql_fetch_fields(result);
cout << "查询结果:" << endl;
for (unsigned int i = 0; i < field_count; i++) {
cout << fields[i].name << "t";
}
cout << endl;
// 逐行获取结果数据
MYSQL_ROW row;
while ((row = mysql_fetch_row(result)) != nullptr) {
for (unsigned int i = 0; i < field_count; i++) {
cout << (row[i] ? row[i] : "NULL") << "t";
}
cout << endl;
}
// 释放结果集
mysql_free_result(result);
}
}
// 执行插入操作
string insert_sql = "INSERT INTO user (name, age) VALUES ('张三', 25)";
if (mysql_query(mysql, insert_sql.c_str()) != 0) {
cout << "插入语句执行失败,错误信息:" << mysql_error(mysql) << endl;
} else {
cout << "数据插入成功,影响行数:" << mysql_affected_rows(mysql) << endl;
}
// 执行修改操作
string update_sql = "UPDATE user SET age = 26 WHERE name = '张三'";
if (mysql_query(mysql, update_sql.c_str()) != 0) {
cout << "修改语句执行失败,错误信息:" << mysql_error(mysql) << endl;
} else {
cout << "数据修改成功,影响行数:" << mysql_affected_rows(mysql) << endl;
}
// 执行删除操作
string delete_sql = "DELETE FROM user WHERE name = '张三'";
if (mysql_query(mysql, delete_sql.c_str()) != 0) {
cout << "删除语句执行失败,错误信息:" << mysql_error(mysql) << endl;
} else {
cout << "数据删除成功,影响行数:" << mysql_affected_rows(mysql) << endl;
}
// 关闭数据库连接
mysql_close(mysql);
cout << "数据库连接已关闭" << endl;
return 0;
}
注意事项
在实际使用中需要注意以下几点:
- 每次执行
mysql_query之后,如果是查询语句,需要及时获取结果集并释放,避免内存泄漏 - SQL语句拼接时需要注意防范SQL注入问题,如果是用户输入的参数,建议使用预处理语句接口
mysql_stmt_init等函数处理 - 数据库连接参数不要硬编码在代码中,建议通过配置文件或者环境变量获取,提高代码的安全性和可维护性
- 操作完成后一定要调用
mysql_close关闭连接,释放相关资源
常见问题排查
如果连接数据库失败,可以先检查以下几点:
- MySQL服务是否正常运行,端口是否正确
- 数据库用户名和密码是否正确,对应的用户是否有访问目标数据库的权限
- 开发环境的头文件和库文件路径是否配置正确,编译时是否成功链接了MySQL的库文件
- 如果是远程连接,需要检查MySQL是否开启了远程访问权限,防火墙是否放行了对应端口
C++MySQLMySQL_C_API数据库连接数据库操作修改时间:2026-07-10 16:42:34