首先需安装 MySQL 客户端开发库,然后使用 MySQL C API 进行连接管理、SQL 执行和结果处理。通过 mysql_init() 和 mysql_real_connect()建立连接,mysql_query()执行 SQL 语句,结合 mysql_store_result()与 mysql_fetch_row()处理查询结果,并用 mysql_free_result()释放资源;建议 封装 db_execute()、db_query() 等函数提升复用性,支持预处理语句以防止 SQL 注入;编译时链接 -lmysqlclient 库。

在 Linux 环境下开发 数据库 操作模块,尤其是集成 MySQL 数据库,通常使用 MySQL 官方提供的 C API。这套 API 允许开发者用 C 或 C ++ 语言直接与 MySQL服务器 通信,实现连接管理、查询执行、结果处理等功能。下面介绍如何在 Linux 系统中基于 MySQL C API 开发一个简单的数据库操作模块。
环境准备与依赖安装
在开始 编码 前,确保系统中已安装 MySQL 客户端开发库:
- Ubuntu/Debian 系统:运行 sudo apt-get install libmysqlclient-dev
- CentOS/RHEL 系统:运行 sudo yum install mysql-devel 或 dnf install mysql-devel
安装完成后,编译时可通过 -lmysqlclient 链接选项引入 MySQL 客户端库。
连接与初始化数据库模块
使用 MySQL C API 的第一步是初始化连接句柄并建立与服务器的连接。以下是一个基础连接函数示例:
#include <mysql.h> #include <stdio.h> #include <stdlib.h> MYSQL *connect_db() { MYSQL *conn = mysql_init(NULL); if (!conn) {fprintf(stderr, "MySQL init failedn"); return NULL; } if (mysql_real_connect(conn, "localhost", "user", "password", "testdb", 0, NULL, 0) == NULL) {fprintf(stderr, "Connection failed: %sn", mysql_error(conn)); mysql_close(conn); return NULL; } return conn; }
关键函数说明:
- mysql_init():初始化 MYSQL 结构体
- mysql_real_connect():建立 TCP 连接,参数包括主机、用户名、密码、数据库名等
- mysql_error():获取最近一次错误信息
执行 SQL 与处理结果
连接成功后,可执行 INSERT、SELECT 等语句。以下展示如何执行查询并遍历结果:
void query_data(MYSQL *conn) {if (mysql_query(conn, "SELECT id, name FROM users")) {fprintf(stderr, "Query failed: %sn", mysql_error(conn)); return; } MYSQL_RES *result = mysql_store_result(conn); if (!result) {fprintf(stderr, "No result set: %sn", mysql_error(conn)); return; } MYSQL_ROW row; while ((row = mysql_fetch_row(result))) {printf("ID: %s, Name: %sn", row[0], row[1]); } mysql_free_result(result); }
常用结果处理函数:
- mysql_store_result():将查询结果全部拉取到本地内存
- mysql_use_result():逐行读取(适用于 大数据 集)
- mysql_fetch_row():获取下一行数据,返回字符串数组
- mysql_num_fields() 和 mysql_fetch_fields():获取字段元信息
封装通用操作接口
为提高模块复用性,建议将常用操作封装成独立函数,例如:
- int db_execute(MYSQL *conn, const char *sql):执行非查询语句(如 INSERT、UPDATE)
- MYSQL_RES *db_query(MYSQL *conn, const char *sql):执行查询并返回结果集
- void db_disconnect(MYSQL *conn):安全关闭连接
还可加入预处理语句(prepared statement)支持,防止 SQL 注入,提升性能:
// 使用 mysql_stmt_prepare / mysql_stmt_bind_param 实现参数化查询
基本上就这些。Linux 下通过 MySQL C API 开发数据库模块,核心在于掌握连接管理、SQL 执行和结果解析流程。配合良好的错误处理和资源释放机制,可构建稳定高效的数据访问层。编译时记得链接库:gcc your_module.c -o your_app -lmysqlclient。不复杂但容易忽略细节。