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

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

admin
数据库
2025-06-17
7

在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等）与数据库交互,流程分为：

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

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

常用数据库连接方案

方案1：MySQL（最常用）

步骤：

安装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（轻量级嵌入式数据库）

步骤：

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

安装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);