前言用 C 或 C 连 MySQL只有一条官方路线MySQL C API也叫 Connector/C库名libmysqlclient。所有语言的绑定底层都是它。围绕它最常见的误解有三个mysql.h是给 C 用的C 另有库。 实际上mysql.h既能在 C 里用也能在 C 里直接用只是要注意链接规范linkage与资源释放。mysql_query会把结果一次性返回。 它只负责发送 SQL 并检查语法结果要么靠mysql_store_result拉到客户端要么用mysql_use_result一行行流式读。把用户输入拼进 SQL 之前转义一下就是安全的。 能防住经典注入但更稳的是预编译语句prepared statement。本文按装库 → 连接 → 查询 → 参数绑定的顺序走一遍每个环节都给出可直接编译的 C 与 C 代码。示例面向MySQL 8.0.x 的 C API在 GCC 13 / Clang 17 / MSVC 19.3x 上均可编译版本差异会单独注明。一、准备头文件在哪、库怎么链不同平台上头文件和库的位置不一样这是连不上的第一大来源平台 / 安装方式头文件库链接参数Debian/Ubuntulibmysqlclient-dev/usr/include/mysql/mysql.hlibmysqlclient.so-lmysqlclientRHEL/CentOSmysql-devel/usr/include/mysql/mysql.hlibmysqlclient.so-lmysqlclientWindows 官方 ZIP/MSIinclude/mysql.hlib/libmysql.lib链接器加libmysql.lib最省事的做法是用官方脚本问出编译参数mysql_config --cflags # 例如 -I/usr/include/mysqlmysql_config --libs # 例如 -L/usr/lib/x86_64-linux-gnu -lmysqlclient -lz -lssl -lcryptoC 与 C 的编译命令分别是gcc -stdc11 -Wall -Wextra mysql_config --cflags conn_c.c -o conn_c mysql_config --libsg -stdc17 -Wall -Wextra mysql_config --cflags conn_cpp.cpp -o conn_cpp mysql_config --libs用 CMake 的话思路完全一样find_path找mysql.h、find_library找mysqlclient或libmysql再挂到target_include_directories与target_link_libraries上。二、连接与错误处理2.1 C 版本的完整流程/* conn_c.c —— gcc -stdc11 conn_c.c -o conn_c mysql_config --cflags --libs */#include mysql/mysql.h#include stdio.hint main(void){MYSQL *conn mysql_init(NULL);if (conn NULL) {fprintf(stderr, mysql_init failed: out of memory\n);return 1;}/* 必须在 mysql_real_connect 之前调用 */unsigned int timeout 5;mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, timeout);mysql_options(conn, MYSQL_SET_CHARSET_NAME, utf8mb4);if (mysql_real_connect(conn, 127.0.0.1, appuser, secret,testdb, 3306, NULL, 0) NULL) {fprintf(stderr, connect failed (%u): %s\n,mysql_errno(conn), mysql_error(conn));mysql_close(conn); /* 即使连接失败也要释放句柄 */return 1;}printf(connected, client %s\n, mysql_get_client_info());mysql_close(conn);return 0;}关键点mysql_init(NULL)分配并返回一个MYSQL*失败返回NULL。mysql_real_connect的完整参数表是(MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *db, unsigned int port, const char *unix_socket, unsigned long clientflag)返回MYSQL*失败返回NULL。连接失败时也要mysql_closemysql_init已经把句柄分配出来了直接return会泄漏。mysql_options的签名是int mysql_options(MYSQL *mysql, enum mysql_option option, const void *arg)必须在mysql_real_connect之前调用。mysql_set_character_set(MYSQL *mysql, const char *csname)是连接后设置字符集的另一个入口返回int0 成功。2.2 C 版本用 RAII 包一层C API 全是裸指针加手动释放C 里最好的做法是立刻用 RAIIResource Acquisition Is Initialization包一层// conn_cpp.cpp —— g -stdc17 ... mysql_config --cflags --libs#include mysql/mysql.h#include iostream#include stdexcept#include stringclass MySqlConnection {public:MySqlConnection(const std::string host, const std::string user,const std::string passwd, const std::string db,unsigned int port): raw_(mysql_init(nullptr)) {if (raw_ nullptr) throw std::runtime_error(mysql_init failed);unsigned int timeout 5;mysql_options(raw_, MYSQL_OPT_CONNECT_TIMEOUT, timeout);mysql_options(raw_, MYSQL_SET_CHARSET_NAME, utf8mb4);if (mysql_real_connect(raw_, host.c_str(), user.c_str(),passwd.c_str(), db.c_str(), port,nullptr, 0) nullptr) {std::string msg mysql_error(raw_); // 必须在 mysql_close 之前取mysql_close(raw_);raw_ nullptr;throw std::runtime_error(connect failed: msg);}}~MySqlConnection() { if (raw_ ! nullptr) mysql_close(raw_); }MySqlConnection(const MySqlConnection) delete;MySqlConnection operator(const MySqlConnection) delete;MYSQL* get() const noexcept { return raw_; }private:MYSQL* raw_;};逐行核对一点连接失败的分支里要先把mysql_error(raw_)的结果拷进std::string再mysql_close最后才抛异常——顺序反了的话mysql_error返回的指针会随mysql_close一起失效。另外手工拼 SQL 时用到的转义函数签名是unsigned long mysql_real_escape_string(MYSQL *mysql, char *to, const char *from, unsigned long length)返回写入的字节数不含结尾的\0目标缓冲区至少要length * 2 1字节。三、执行 SQL 与取结果mysql_query只负责把 SQL 发出去并检查语法/权限它不接收结果集。结果集要么用mysql_store_result一次拉到本地要么用mysql_use_result逐行流式读对比项mysql_store_resultmysql_use_result数据存放位置全部读到客户端内存留在服务端逐行取内存占用与结果集大小成正比只占一行mysql_num_rows立即有效✅❌ 未读完之前不可靠客户端能否立刻发新查询✅ 可以❌ 必须先把结果读干净适用场景结果集不大、要随机访问超大结果集、一遍流式处理/* query.c —— 连接部分同 2.1这里只看取结果 */MYSQL_RES *res mysql_store_result(conn);if (res NULL) {/* 关键区分这条语句本来就不产生结果集和真的出错了 */if (mysql_field_count(conn) 0) {printf(affected rows %llu\n,(unsigned long long)mysql_affected_rows(conn));} else {fprintf(stderr, store_result failed: %s\n, mysql_error(conn));}mysql_close(conn);return 0;}unsigned int nfields mysql_num_fields(res);MYSQL_ROW row;while ((row mysql_fetch_row(res)) ! NULL) {unsigned long *lengths mysql_fetch_lengths(res);for (unsigned int i 0; i nfields; i) {if (row[i] NULL) {printf(%-16s, NULL); /* NULL 与空串不同 */} else {printf(%-16.*s, (int)lengths[i], row[i]);}}printf(\n);}printf(total %llu\n, (unsigned long long)mysql_num_rows(res));mysql_free_result(res);必须记住的几件事MYSQL_ROW就是char**row[i]是以\0结尾的字符串但字段内容本身可能含\0比如BLOB所以长度必须用mysql_fetch_lengths拿别用strlen。row[i] NULL表示该字段是 SQL NULLrow[i]指向空串才表示字段值是空字符串。这两者必须分开处理。mysql_fetch_row返回NULL既可能是没有更多行了也可能是出错了稳妥的写法是取完之后再查一次mysql_errno(conn)。每个MYSQL_RES*都必须mysql_free_result否则一直泄漏到连接关闭。C 里可以给MYSQL_RES*写个删除器交给std::unique_ptr管struct ResultDeleter { void operator()(MYSQL_RES* r) const noexcept { if (r) mysql_free_result(r); } };再using ResultPtr std::unique_ptrMYSQL_RES, ResultDeleter;。四、预编译语句MYSQL_STMT把用户输入拼进 SQL 是注入SQL injection的根源。预编译语句的做法是SQL 里用?占位参数走二进制协议单独传服务端不会把参数当 SQL 解析。// stmt_demo.cpp —— 编译方式同上#include mysql/mysql.h#include cstring#include iostreamint main() {MYSQL* conn mysql_init(nullptr);if (conn nullptr) return 1;if (mysql_real_connect(conn, 127.0.0.1, appuser, secret,testdb, 3306, nullptr, 0) nullptr) {std::cerr connect failed: mysql_error(conn) \n;mysql_close(conn);return 1;}MYSQL_STMT* stmt mysql_stmt_init(conn);if (stmt nullptr) {std::cerr stmt_init failed\n;mysql_close(conn);return 1;}const char* sql INSERT INTO users(name, age) VALUES(?, ?);if (mysql_stmt_prepare(stmt, sql,static_castunsigned long(std::strlen(sql))) ! 0) {std::cerr prepare failed: mysql_stmt_error(stmt) \n;mysql_stmt_close(stmt);mysql_close(conn);return 1;}// ---- 绑定输入参数数组必须整体清零 ----char name[64] Alice;unsigned long name_len static_castunsigned long(std::strlen(name));int age 30;MYSQL_BIND param[2];std::memset(param, 0, sizeof(param));param[0].buffer_type MYSQL_TYPE_STRING;param[0].buffer name;param[0].buffer_length sizeof(name);param[0].length name_len; // 字符串参数必须给 lengthparam[1].buffer_type MYSQL_TYPE_LONG;param[1].buffer age; // 数值参数不需要 lengthif (mysql_stmt_bind_param(stmt, param) ! 0 ||mysql_stmt_execute(stmt) ! 0) {std::cerr stmt failed: mysql_stmt_error(stmt) \n;mysql_stmt_close(stmt);mysql_close(conn);return 1;}std::cout inserted id static_castunsigned long long(mysql_stmt_insert_id(stmt)) , affected static_castunsigned long long(mysql_stmt_affected_rows(stmt)) \n;mysql_stmt_close(stmt);mysql_close(conn);return 0;}查询场景下绑定输出结果MYSQL_BIND result[2];std::memset(result, 0, sizeof(result));long long out_id 0; bool id_is_null false;unsigned long id_len 0;char out_name[128] {0}; bool name_is_null false;unsigned long name_len_out 0;result[0].buffer_type MYSQL_TYPE_LONGLONG;result[0].buffer out_id;result[0].is_null id_is_null;result[0].length id_len;result[1].buffer_type MYSQL_TYPE_STRING;result[1].buffer out_name;result[1].buffer_length sizeof(out_name) - 1; // 留出 \0 的位置result[1].is_null name_is_null;result[1].length name_len_out;if (mysql_stmt_bind_result(stmt, result) ! 0) { /* 处理错误 */ }int rc;while ((rc mysql_stmt_fetch(stmt)) 0) {out_name[name_len_out] \0; // 返回的字符串可能不带结尾 \0std::cout out_id out_name \n;}if (rc MYSQL_DATA_TRUNCATED) {std::cerr 警告某个字段被截断缓冲区太小\n;}关于MYSQL_BIND和版本的注意点字段有buffer_type、buffer、buffer_length、length、is_null、error、is_unsigned。is_null在 MySQL 8.0 里是bool*5.7 里my_bool是char的别名要用char。这是 8.0.1 与 5.7 的 API 差异。mysql_stmt_bind_param与mysql_stmt_bind_result的返回类型都是bool8.0 中my_bool已被bool取代。mysql_stmt_fetch返回 0 表示成功MYSQL_NO_DATA值 100表示取完MYSQL_DATA_TRUNCATED值 101表示缓冲区不够。常见坑点#❌ 错误写法✅ 正确写法1mysql_store_result返回NULL就直接当成出错先用mysql_field_count(conn) 0判断该语句是否本来就无结果集INSERT/UPDATE就是2连接失败后直接return不调mysql_closemysql_init已经分配了句柄失败路径也要mysql_close(conn)3在mysql_real_connect之后才mysql_options(...)设超时/字符集mysql_options只在连接前有效必须放在mysql_real_connect之前4用strlen(row[i])量字段长度字段可能含\0用mysql_fetch_lengths(res)返回的长度数组5把row[i] NULLSQL NULL当成空字符串NULL 要单独分支处理空串是row[i] ! NULL lengths[i] 06把用户输入直接拼 SQLsprintf(buf, SELECT * FROM t WHERE name%s, input);用预编译语句INSERT ... VALUES(?, ?)实在要拼就用mysql_real_escape_string7用mysql_use_result之后不读干净就去发下一条查询必须先mysql_fetch_row到NULL否则连接处于结果未取完状态8忘记mysql_free_result/mysql_stmt_close每个MYSQL_RES*都要释放每个MYSQL_STMT*都要关闭C 里用std::unique_ptr配删除器还有两个新手容易卡住的工程问题。一是Access denied不一定是密码错MySQL 8.0 默认认证插件是caching_sha2_password旧客户端库不支持表现为连接阶段报认证错误升级客户端库即可。二是想一次执行多条语句必须在clientflag里传CLIENT_MULTI_STATEMENTS并用mysql_next_result依次消费结果集忘了传标志位分号后面的语句会被静默忽略。总结阶段关键 API最容易踩的点初始化mysql_init返回NULL要判空连接配置mysql_options只能在mysql_real_connect之前调用建立连接mysql_real_connect失败也要mysql_close8 个参数一个都不能错位执行语句mysql_query/mysql_real_query含二进制或含\0的 SQL 必须用mysql_real_query显式传长度取结果集mysql_store_result/mysql_use_resultNULL返回值的两种含义要分开MYSQL_RES必须释放遍历行mysql_fetch_rowmysql_fetch_lengths不能用strlenNULL 要单独分支参数化查询mysql_stmt_*系列MYSQL_BIND必须清零字符串参数要填length释放mysql_free_result/mysql_stmt_close/mysql_close漏一个就是一次泄漏C API 的调用顺序是一条固定流水线init → options → connect → query → store_result → fetch_row → free_result → close。把每一级的返回值都当成可能失败处理用 RAII 包住需要手动释放的句柄再坚持用预编译语句传参数这段代码就不会有太多意外。跨版本时要额外留意的只有my_bool8.0.1 起改为 C 的bool和默认认证插件这两处。