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

如何用C语言访问数据库？

admin
数据库
2025-06-17
3171

在C语言中访问数据库通常通过数据库提供的API或通用接口实现，主要方法包括：，1. 使用数据库原生C API（如MySQL Connector/C、SQLite C接口），2. 通过ODBC（开放式数据库连接）标准接口，3. 采用第三方库（如libpqxx for PostgreSQL），基本流程：建立连接→执行SQL语句→处理结果集→释放资源，需包含对应头文件并链接数据库客户端库。

在C语言中访问数据库通常需要借助特定的数据库连接库，这些库提供了与数据库服务器通信的API,以下是详细的操作指南和关键步骤：

核心原理

C语言通过数据库客户端库（如MySQL Connector/C、SQLite API等）与数据库交互,流程分为：

建立数据库连接
执行SQL语句
处理返回结果
关闭连接

常用数据库连接方案

方案1：MySQL（最常用）

步骤：

如何用C语言访问数据库？第1张

安装MySQL C Connector
- Ubuntu: sudo apt-get install libmysqlclient-dev
- Windows: 从MySQL官网下载库文件

基础代码示例

#include <mysql/mysql.h>
#include <stdio.h>

int main() {
MYSQL conn;
MYSQL_RES res;
MYSQL_ROW row;

// 1. 初始化连接
conn = mysql_init(NULL);
// 2. 建立连接（替换your_xxx为实际参数）
if (!mysql_real_connect(conn, "localhost", "your_user", "your_pass", "your_db", 0, NULL, 0)) {
    fprintf(stderr, "连接失败: %sn", mysql_error(conn));
    return 1;
}
// 3. 执行SQL查询
if (mysql_query(conn, "SELECT id, name FROM users")) {
    fprintf(stderr, "查询失败: %sn", mysql_error(conn));
    return 1;
}
// 4. 获取结果集
res = mysql_store_result(conn);
// 5. 遍历结果
while ((row = mysql_fetch_row(res)) != NULL) {
    printf("ID: %s, Name: %sn", row[0], row[1]);
}
// 6. 释放资源
mysql_free_result(res);
mysql_close(conn);
return 0;


3. **编译命令**
   ```bash
   gcc program.c -o output `mysql_config --cflags --libs`

方案2：SQLite（轻量级嵌入式数据库）

步骤：

安装SQLite3开发库
- Ubuntu: sudo apt-get install libsqlite3-dev
代码示例：
```
#include <sqlite3.h>
#include <stdio.h>
```

int main() {
sqlite3 db;
char err_msg = 0;

// 1. 打开数据库（不存在则创建）
int rc = sqlite3_open("test.db", &db);
if (rc != SQLITE_OK) {
    fprintf(stderr, "无法打开数据库: %sn", sqlite3_errmsg(db));
    return 1;
}
// 2. 执行SQL语句
const char *sql = "CREATE TABLE IF NOT EXISTS users(id INT, name TEXT);";
rc = sqlite3_exec(db, sql, 0, 0, &err_msg);
if (rc != SQLITE_OK) {
    fprintf(stderr, "SQL错误: %sn", err_msg);
    sqlite3_free(err_msg);
}
// 3. 关闭连接
sqlite3_close(db);
return 0;


---
### 三、关键注意事项
1. **错误处理**
   - 每次数据库操作后检查返回状态
   - 使用`mysql_error()`或`sqlite3_errmsg()`获取详细错误信息
2. **防SQL注入**
   - **永远不要拼接SQL字符串**！
   - 使用预处理语句：
     ```c
     // MySQL预处理示例
     MYSQL_STMT *stmt = mysql_stmt_init(conn);
     const char *sql = "INSERT INTO users (name) VALUES (?)";
     mysql_stmt_prepare(stmt, sql, strlen(sql));
     // 绑定参数
     char name[50] = "safe_value";
     MYSQL_BIND bind = {0};
     bind.buffer_type = MYSQL_TYPE_STRING;
     bind.buffer = name;
     bind.buffer_length = strlen(name);
     mysql_stmt_bind_param(stmt, &bind);
     mysql_stmt_execute(stmt);