当前位置：首页 > 数据库 > 正文

c 怎么保存到数据库

admin
数据库
2025-08-11
6

在 C 语言中，可借助数据库专属 API（如 MySQL 的 libmysqlclient），建立连接后构建 SQL 插入

技术选型与前置条件

1 主流数据库适配方案

数据库类型	推荐C语言接口库	特点	适用场景
MySQL	`libmysqlclient`	开源、轻量级、社区活跃	Web应用、中小型项目
PostgreSQL	`libpq`	支持JSON/GIS等高级特性	企业级应用、复杂查询需求
SQLite	`sqlite3.h`	嵌入式零配置、单文件存储	移动端、桌面软件、原型开发
Oracle	`oci.h` (Oracle Call Interface)	商业级高并发、ACID强一致性	金融系统、大型ERP
Microsoft SQL Server	`odbc`/`tdsodbc.dll`	Windows生态集成度高	.NET混合架构、旧系统迁移

2 环境准备清单

编译器：GCC/Clang/MSVC（需包含对应平台的SDK）
数据库服务端：已安装并启动目标数据库服务
头文件路径：将数据库厂商提供的.h文件加入编译路径
动态链接库：确保.so(Linux)/.dll(Windows)可被程序加载
权限配置：创建具有读写权限的数据库用户（如GRANT ALL PRIVILEGES ON dbname TO user@host;）

通用开发流程详解

1 基础操作四步曲

// 伪代码逻辑框架
初始化连接参数 → 建立数据库连接 → 构造SQL语句 → 执行并提交 → 释放资源

2 关键步骤拆解（以MySQL为例）

阶段	核心函数/方法	作用说明	注意事项
连接建立	`mysql_real_connect()`	创建TCP/IP或Unix域套接字连接	超时时间通过`MYSQL options`设置
语句准备	`mysql_stmt_prepare()`	预编译SQL模板（防注入必备）	占位符使用或命名参数
参数绑定	`mysql_stmt_bind_param()`	类型安全的数据填充	根据字段类型选择绑定函数
执行操作	`mysql_stmt_execute()`	发送指令到数据库引擎	批量插入可用`mysql_stmt_send_long_data()`
结果获取	`mysql_stmt_store_result()`	缓冲区模式获取结果集	大结果集建议流式处理
事务控制	`mysql_autocommit(0)` + `COMMIT/ROLLBACK`	显式事务管理	默认自动提交模式需手动关闭
资源释放	`mysql_close()` / `mysql_stmt_free_result()`	防止内存泄漏	异常退出时仍需调用清理函数


# 2.3 数据类型映射对照表
| C语言类型       | MySQL类型       | PostgreSQL类型    | SQLite类型      | 备注                          |
|----------------|----------------|------------------|----------------|-------------------------------|
| `int`          | INT            | INTEGER          | INTEGER        | 4字节有符号整数               |
| `double`       | DOUBLE         | DOUBLE PRECISION | REAL           | 双精度浮点数                  |
| `char[]`       | VARCHAR(n)     | TEXT             | TEXT           | 需指定最大长度                |
| `struct {...}` | JSON           | JSONB            | JSON           | 结构化数据序列化为JSON字符串  |
| `time_t`       | DATETIME       | TIMESTAMP        | TIMESTAMP      | 时间戳转换需注意时区问题      |
| `unsigned char` | BINARY(n)      | BYTEA            | BLOB           | 二进制数据存储                |
---
 三、实战代码示例（MySQL版）
```c
#include <mysql/mysql.h>
#include <stdio.h>
#include <string.h>
// 定义用户结构体
typedef struct {
    int id;
    char name[50];
    double balance;
} UserAccount;
int main() {
    MYSQL conn;
    MYSQL_STMT stmt;
    UserAccount new_user = {0, "张三", 1000.50};
    const char insert_sql = "INSERT INTO users(id, name, balance) VALUES(?, ?, ?)";
    // 1. 初始化连接对象
    conn = mysql_init(NULL);
    if (!conn) {
        fprintf(stderr, "初始化失败: %sn", mysql_error(conn));
        return EXIT_FAILURE;
    }
    // 2. 建立数据库连接
    if (mysql_real_connect(conn, "localhost", "root", "password", "testdb", 3306, NULL, 0)) {
        printf("连接成功!n");
        // 3. 准备预处理语句
        stmt = mysql_stmt_init(conn);
        mysql_stmt_prepare(stmt, insert_sql, strlen(insert_sql));
        // 4. 绑定参数（注意参数顺序与SQL占位符一致）
        MYSQL_BIND bind[3];
        memset(bind, 0, sizeof(bind));
        bind[0].buffer_type = MYSQL_TYPE_LONG;
        bind[0].buffer = &new_user.id;
        bind[0].is_null = 0;
        bind[0].length = NULL; // LONG类型不需要长度
        bind[1].buffer_type = MYSQL_TYPE_STRING;
        bind[1].buffer = new_user.name;
        bind[1].buffer_length = strlen(new_user.name);
        bind[1].is_null = 0;
        bind[2].buffer_type = MYSQL_TYPE_DOUBLE;
        bind[2].buffer = &new_user.balance;
        bind[2].is_null = 0;
        mysql_stmt_bind_param(stmt, bind);
        // 5. 执行插入操作
        if (mysql_stmt_execute(stmt)) {
            fprintf(stderr, "执行失败: %sn", mysql_stmt_error(stmt));
        } else {
            printf("成功插入 %d 条记录n", mysql_stmt_affected_rows(stmt));
        }
        // 6. 清理资源
        mysql_stmt_close(stmt);
        mysql_close(conn);
    } else {
        fprintf(stderr, "连接失败: %sn", mysql_error(conn));
        mysql_close(conn);
        return EXIT_FAILURE;
    }
    return EXIT_SUCCESS;
}

编译命令示例：

gcc -o db_insert db_insert.c `mysql_config --cflags --libs`

高级技巧与优化策略

1 性能提升方案

连接池：复用已有连接而非频繁创建/销毁（推荐使用第三方库如drizzle）
批量操作：单次执行多条INSERT/UPDATE语句（减少网络往返次数）
索引优化：为WHERE/ORDER BY/JOIN字段创建合适索引
延迟关联：先获取主键再关联其他表数据，减少笛卡尔积计算量

c 怎么保存到数据库第1张

2 安全防护措施

️ SQL注入防御：强制使用预处理语句（Prepared Statement），禁止字符串拼接SQL
️ 敏感信息脱敏：对密码等字段进行哈希加盐处理后再存储
️ 权限最小化原则：应用程序仅使用只读/有限写入权限的数据库账号
️ 输入校验：对用户输入进行正则表达式过滤（如邮箱格式、手机号校验）

c 怎么保存到数据库第2张

3 异常处理机制

// 示例：完善的错误处理链
if (ret != OK) {
    switch(mysql_errno(conn)) {
        case ER_ACCESS_DENIED_ERROR:
            log_error("权限不足");
            break;
        case ER_NO_SUCH_TABLE:
            log_error("表不存在");
            break;
        default:
            log_error("未知错误: %d", mysql_errno(conn));
    }
}

不同数据库的特殊处理要点对比

特性	MySQL	PostgreSQL	SQLite
事务隔离级别	REPEATABLE READ(默认)	SERIALIZABLE(最高)	IMMEDIATE(自动提交)
自增ID实现	`AUTO_INCREMENT`	`SERIAL`	`AUTOINCREMENT`
数组类型支持	无原生支持	ARRAY/ENUM	无
窗口函数	0+版本支持	完整支持	部分支持
JSON函数丰富度	基础查询/修改	JSONB全功能操作	JSON路径表达式
真空回收空间	OPTIMIZE TABLE	VACUUM FULL	VACUUM