MySQL C API 连接实战：5步配置 VS 2022 与 6个核心函数详解

张

张建站

2026/7/8 13:25:59

10分钟阅读

MySQL C API 连接实战：5步配置 VS 2022 与 6个核心函数详解

MySQL C API 高效开发指南从 VS 2022 配置到核心函数深度解析1. 开发环境搭建与项目配置在 Windows 平台使用 MySQL C API 进行开发Visual Studio 2022 是最常用的 IDE 之一。正确的环境配置是项目成功的第一步下面将详细介绍如何搭建高效的开发环境。1.1 前置条件准备在开始配置前请确保已安装以下组件MySQL Server 8.0完整安装开发所需的头文件和库文件Visual Studio 2022安装时勾选C桌面开发工作负载Windows SDK建议使用最新稳定版本提示MySQL 安装时建议选择Developer Default模式这会自动包含开发所需的头文件和库文件。1.2 VS 2022 项目配置步骤1.2.1 解决方案平台设置新建空项目后在解决方案资源管理器中右键解决方案选择配置管理器在活动解决方案平台下拉菜单中选择x64# 验证平台设置的快速方法 # 在项目属性 - 配置属性 - 高级中查看目标平台应显示为x641.2.2 包含目录配置配置项路径示例说明包含目录C:\Program Files\MySQL\MySQL Server 8.0\include包含MySQL头文件配置方法右键项目 - 属性 - VC目录 - 包含目录添加MySQL的include目录路径1.2.3 库目录配置配置项路径示例说明库目录C:\Program Files\MySQL\MySQL Server 8.0\lib包含MySQL库文件配置方法右键项目 - 属性 - VC目录 - 库目录添加MySQL的lib目录路径1.2.4 附加依赖项设置在链接器 - 输入 - 附加依赖项中添加libmysql.lib注意只需填写库文件名不需要完整路径。系统会在之前配置的库目录中查找该文件。1.2.5 动态链接库处理将libmysql.dll从MySQL的lib目录复制到以下位置之一项目生成的可执行文件所在目录Windows系统目录如C:\Windows\System32// 验证配置是否成功的简单测试代码 #include mysql.h #include iostream int main() { std::cout MySQL client version: mysql_get_client_info() std::endl; return 0; }如果编译运行后能正确输出MySQL客户端版本号说明基础配置成功。2. MySQL C API 核心函数解析MySQL C API 提供了一组丰富的函数用于数据库操作下面将深入解析最常用的6个核心函数及其最佳实践。2.1 mysql_init连接初始化mysql_init()函数用于初始化一个MYSQL对象为后续连接做准备。函数原型MYSQL *mysql_init(MYSQL *mysql);参数说明mysql可以传入NULL或已有的MYSQL对象指针返回值初始化后的MYSQL对象指针典型用法MYSQL *conn mysql_init(NULL); if (conn NULL) { fprintf(stderr, mysql_init() failed\n); exit(1); }错误处理检查返回值是否为NULL失败原因通常与内存分配有关2.2 mysql_real_connect建立数据库连接mysql_real_connect()是建立实际数据库连接的核心函数。函数原型MYSQL *mysql_real_connect( MYSQL *mysql, // mysql_init返回的对象 const char *host, // 主机名或IP const char *user, // 用户名 const char *passwd, // 密码 const char *db, // 数据库名 unsigned int port, // 端口号 const char *unix_socket,// Unix socket路径 unsigned long clientflag // 客户端标志 );参数详解参数类型说明典型值hostconst char*服务器地址localhost, 127.0.0.1userconst char*用户名rootpasswdconst char*密码yourpassworddbconst char*默认数据库NULL或指定数据库名portunsigned intTCP/IP端口3306unix_socketconst char*Unix域套接字NULLclientflagunsigned long客户端标志0连接示例MYSQL *conn mysql_init(NULL); if (!mysql_real_connect(conn, 127.0.0.1, root, password, testdb, 3306, NULL, 0)) { fprintf(stderr, Connection failed: %s\n, mysql_error(conn)); mysql_close(conn); exit(1); }连接优化技巧设置连接超时选项unsigned int timeout 5; // 5秒超时 mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, timeout);启用自动重连my_bool reconnect 1; mysql_options(conn, MYSQL_OPT_RECONNECT, reconnect);2.3 mysql_query执行SQL语句mysql_query()用于执行SQL查询语句是数据库操作的核心函数。函数原型int mysql_query(MYSQL *mysql, const char *stmt_str);返回值0执行成功非0执行失败使用示例if (mysql_query(conn, SELECT * FROM users)) { fprintf(stderr, Query failed: %s\n, mysql_error(conn)); } else { // 处理查询结果 }安全注意事项防止SQL注入// 不安全的方式 std::string query SELECT * FROM users WHERE id user_input; // 安全的方式 - 使用预处理语句 std::string query SELECT * FROM users WHERE id ?;大查询处理对于可能返回大量数据的查询考虑使用mysql_use_result()而非mysql_store_result()以降低内存使用。2.4 mysql_use_result 与 mysql_store_result结果集处理这两个函数都用于获取查询结果但在内存使用和行为上有重要区别。对比分析特性mysql_use_resultmysql_store_result内存使用逐行获取内存占用低一次性获取全部结果内存占用高执行速度较慢逐行获取较快一次性获取并发性阻塞其他操作直到结果集完全读取不阻塞其他操作适用场景大数据量查询中小数据量查询典型用法MYSQL_RES *result mysql_use_result(conn); if (result NULL) { fprintf(stderr, Error: %s\n, mysql_error(conn)); return; } MYSQL_ROW row; while ((row mysql_fetch_row(result)) ! NULL) { // 处理每一行数据 printf(ID: %s, Name: %s\n, row[0], row[1]); } mysql_free_result(result);2.5 mysql_fetch_row获取结果行mysql_fetch_row()用于从结果集中逐行获取数据。函数原型MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);行数据处理示例MYSQL_ROW row; unsigned int num_fields mysql_num_fields(result); while ((row mysql_fetch_row(result))) { for (unsigned int i 0; i num_fields; i) { printf(%s , row[i] ? row[i] : NULL); } printf(\n); }NULL值处理当字段值为NULL时row[i]将为NULL指针需要特殊处理printf(%s , row[i] ? row[i] : (NULL));2.6 mysql_close释放连接资源mysql_close()用于关闭数据库连接并释放相关资源。函数原型void mysql_close(MYSQL *mysql);资源释放最佳实践确保释放所有结果集mysql_free_result(result);关闭连接mysql_close(conn);将指针设为NULL防止误用conn NULL;3. 实战完整数据库操作示例3.1 数据库连接封装创建一个可重用的数据库连接类class MySQLConnection { public: MySQLConnection(const std::string host, const std::string user, const std::string password, const std::string db, unsigned int port 3306) : m_host(host), m_user(user), m_password(password), m_db(db), m_port(port), m_conn(nullptr) {} bool connect() { m_conn mysql_init(NULL); if (!m_conn) return false; // 设置连接选项 unsigned int timeout 3; // 3秒超时 mysql_options(m_conn, MYSQL_OPT_CONNECT_TIMEOUT, timeout); my_bool reconnect 1; // 启用自动重连 mysql_options(m_conn, MYSQL_OPT_RECONNECT, reconnect); if (!mysql_real_connect(m_conn, m_host.c_str(), m_user.c_str(), m_password.c_str(), m_db.c_str(), m_port, NULL, 0)) { return false; } // 设置字符集为UTF-8 return mysql_set_character_set(m_conn, utf8mb4) 0; } ~MySQLConnection() { if (m_conn) { mysql_close(m_conn); m_conn nullptr; } } // 其他成员函数... private: MYSQL* m_conn; std::string m_host; std::string m_user; std::string m_password; std::string m_db; unsigned int m_port; };3.2 查询操作实现实现一个通用的查询方法class MySQLQuery { public: MySQLQuery(MYSQL* conn) : m_conn(conn), m_result(nullptr) {} bool execute(const std::string query) { if (mysql_query(m_conn, query.c_str()) ! 0) { return false; } m_result mysql_use_result(m_conn); return m_result ! nullptr; } std::vectorstd::vectorstd::string fetchAll() { std::vectorstd::vectorstd::string rows; if (!m_result) return rows; unsigned int num_fields mysql_num_fields(m_result); MYSQL_ROW row; while ((row mysql_fetch_row(m_result))) { std::vectorstd::string current_row; for (unsigned int i 0; i num_fields; i) { current_row.push_back(row[i] ? row[i] : ); } rows.push_back(std::move(current_row)); } return rows; } ~MySQLQuery() { if (m_result) { mysql_free_result(m_result); m_result nullptr; } } private: MYSQL* m_conn; MYSQL_RES* m_result; };3.3 完整CRUD示例#include iostream #include string #include vector #include mysql.h // 使用前面定义的MySQLConnection和MySQLQuery类 int main() { try { // 1. 建立连接 MySQLConnection conn(127.0.0.1, root, password, testdb); if (!conn.connect()) { throw std::runtime_error(Connection failed); } // 2. 创建表 { MySQLQuery query(conn.get()); if (!query.execute(CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(50) NOT NULL, email VARCHAR(100) UNIQUE))) { throw std::runtime_error(Create table failed); } } // 3. 插入数据 { MySQLQuery query(conn.get()); if (!query.execute(INSERT INTO users (name, email) VALUES (Alice, aliceexample.com), (Bob, bobexample.com))) { throw std::runtime_error(Insert failed); } std::cout Inserted mysql_affected_rows(conn.get()) rows\n; } // 4. 查询数据 { MySQLQuery query(conn.get()); if (!query.execute(SELECT id, name, email FROM users)) { throw std::runtime_error(Query failed); } auto rows query.fetchAll(); for (const auto row : rows) { std::cout ID: row[0] , Name: row[1] , Email: row[2] \n; } } // 5. 更新数据 { MySQLQuery query(conn.get()); if (!query.execute(UPDATE users SET emailalice.newexample.com WHERE nameAlice)) { throw std::runtime_error(Update failed); } std::cout Updated mysql_affected_rows(conn.get()) rows\n; } // 6. 删除数据 { MySQLQuery query(conn.get()); if (!query.execute(DELETE FROM users WHERE nameBob)) { throw std::runtime_error(Delete failed); } std::cout Deleted mysql_affected_rows(conn.get()) rows\n; } } catch (const std::exception e) { std::cerr Error: e.what() std::endl; return 1; } return 0; }4. 高级技巧与性能优化4.1 预处理语句的使用预处理语句能提高性能并防止SQL注入// 1. 准备预处理语句 MYSQL_STMT *stmt mysql_stmt_init(conn); const char *query INSERT INTO users (name, email) VALUES (?, ?); if (mysql_stmt_prepare(stmt, query, strlen(query))) { fprintf(stderr, Prepare failed: %s\n, mysql_stmt_error(stmt)); return; } // 2. 绑定参数 MYSQL_BIND bind[2]; memset(bind, 0, sizeof(bind)); char *name Charlie; char *email charlieexample.com; unsigned long name_len strlen(name); unsigned long email_len strlen(email); bind[0].buffer_type MYSQL_TYPE_STRING; bind[0].buffer name; bind[0].buffer_length 100; bind[0].length name_len; bind[1].buffer_type MYSQL_TYPE_STRING; bind[1].buffer email; bind[1].buffer_length 100; bind[1].length email_len; if (mysql_stmt_bind_param(stmt, bind)) { fprintf(stderr, Bind failed: %s\n, mysql_stmt_error(stmt)); mysql_stmt_close(stmt); return; } // 3. 执行语句 if (mysql_stmt_execute(stmt)) { fprintf(stderr, Execute failed: %s\n, mysql_stmt_error(stmt)); } // 4. 清理资源 mysql_stmt_close(stmt);4.2 事务处理确保数据一致性的关键// 开始事务 if (mysql_query(conn, START TRANSACTION)) { fprintf(stderr, Start transaction failed: %s\n, mysql_error(conn)); return; } try { // 执行多个操作 if (mysql_query(conn, UPDATE accounts SET balance balance - 100 WHERE id 1)) { throw std::runtime_error(First update failed); } if (mysql_query(conn, UPDATE accounts SET balance balance 100 WHERE id 2)) { throw std::runtime_error(Second update failed); } // 提交事务 if (mysql_query(conn, COMMIT)) { throw std::runtime_error(Commit failed); } } catch (...) { // 回滚事务 mysql_query(conn, ROLLBACK); throw; }4.3 连接池实现对于高并发应用连接池是必不可少的class MySQLConnectionPool { public: MySQLConnectionPool(const std::string host, const std::string user, const std::string password, const std::string db, unsigned int port, size_t pool_size) : m_host(host), m_user(user), m_password(password), m_db(db), m_port(port) { for (size_t i 0; i pool_size; i) { auto conn std::make_sharedMySQLConnection(host, user, password, db, port); if (conn-connect()) { m_pool.push(conn); } } } std::shared_ptrMySQLConnection get_connection() { std::unique_lockstd::mutex lock(m_mutex); if (m_pool.empty()) { // 可以在这里实现等待逻辑或创建新连接 return nullptr; } auto conn m_pool.front(); m_pool.pop(); return conn; } void release_connection(std::shared_ptrMySQLConnection conn) { std::unique_lockstd::mutex lock(m_mutex); m_pool.push(conn); } private: std::queuestd::shared_ptrMySQLConnection m_pool; std::mutex m_mutex; std::string m_host; std::string m_user; std::string m_password; std::string m_db; unsigned int m_port; };