如何用C语言获取数据库连接与数据？

在C语言中获取数据库数据是一个常见的需求，通常需要借助数据库提供的API或第三方库来实现，以下是详细的步骤和示例，涵盖环境准备、连接数据库、执行查询、处理结果以及资源释放等关键环节。

环境准备与库选择

首先需要确定目标数据库类型（如MySQL、PostgreSQL、SQLite等），并安装对应的C语言库，以MySQL为例，需安装MySQL Connector/C（libmysqlclient），在Linux中可通过sudo apt-get install libmysqlclient-dev安装，Windows则需从MySQL官网下载对应版本的库文件并配置开发环境，对于SQLite，其嵌入式特性使其无需额外服务，直接下载sqlite3.h和sqlite3.lib即可使用。

连接数据库

连接数据库是第一步，需初始化连接句柄并配置连接参数，以MySQL为例，使用mysql_init()初始化MYSQL结构体，通过mysql_real_connect()建立连接，需指定主机名、用户名、密码、数据库名及端口号，连接成功后，可通过mysql_errno()和mysql_error()检查错误。

MYSQL *conn;
conn = mysql_init(NULL);
if (!mysql_real_connect(conn, "localhost", "user", "password", "testdb", 0, NULL, 0)) {
    fprintf(stderr, "Error connecting: %sn", mysql_error(conn));
    exit(1);
}

执行SQL查询

连接成功后，使用mysql_query()执行SQL语句，若语句是SELECT查询，需通过mysql_store_result()或mysql_use_result()获取结果集,以查询用户表为例：

if (mysql_query(conn, "SELECT id, name FROM users")) {
    fprintf(stderr, "Query failed: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL) {
    fprintf(stderr, "No data or error: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

处理查询结果

获取结果集后，需遍历行和列提取数据。mysql_num_fields()获取列数，mysql_fetch_row()逐行读取数据。

MYSQL_ROW row;
MYSQL_FIELD *field;
int num_fields = mysql_num_fields(result);
while ((row = mysql_fetch_row(result))) {
    for (int i = 0; i < num_fields; i++) {
        printf("%s: %sn", mysql_fetch_field_direct(result, i)->name, row[i] ? row[i] : "NULL");
    }
}

资源释放

操作完成后，必须释放资源，避免内存泄漏，顺序为：释放结果集（mysql_free_result()）、关闭连接（mysql_close()）。

mysql_free_result(result);
mysql_close(conn);

不同数据库的注意事项

1. PostgreSQL：使用libpq库，通过PQconnectdb()连接，PQexec()执行查询，PQgetResult()处理结果。
2. SQLite：使用sqlite3库，通过sqlite3_open()打开数据库文件，sqlite3_exec()执行回调函数处理结果。

错误处理与安全性

• 错误处理：每次数据库操作后都应检查返回值，避免程序因未处理的错误而崩溃。
• SQL注入防护：使用参数化查询（如MySQL的mysql_stmt_prepare()）或对输入数据进行严格过滤，避免直接拼接SQL字符串。

性能优化建议

• 对于频繁查询，使用连接池管理数据库连接。
• 大数据量查询时，考虑分页或流式处理（如mysql_use_result()减少内存占用）。

完整示例（MySQL）

#include <mysql/mysql.h>
#include <stdio.h>
int main() {
    MYSQL *conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, "localhost", "user", "password", "testdb", 0, NULL, 0)) {
        fprintf(stderr, "Connection failed: %sn", mysql_error(conn));
        return 1;
    }
    if (mysql_query(conn, "SELECT * FROM users")) {
        fprintf(stderr, "Query failed: %sn", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }
    MYSQL_RES *result = mysql_store_result(conn);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(result))) {
        printf("ID: %s, Name: %sn", row[0], row[1]);
    }
    mysql_free_result(result);
    mysql_close(conn);
    return 0;
}

相关问答FAQs

Q1: C语言连接数据库时出现“Can’t connect to MySQL server”错误如何解决？
A: 该错误通常由网络问题、服务未启动或认证失败导致，可检查：①MySQL服务是否运行（sudo systemctl status mysql）；②主机名、端口、用户名密码是否正确；③防火墙是否阻止3306端口，若为本地连接，尝试将主机名改为0.0.1。

Q2: 如何在C程序中防止SQL注入攻击？
A: 避免直接拼接用户输入到SQL语句中，推荐使用以下方法：①参数化查询（如MySQL的mysql_stmt_prepare()和mysql_bind_param()）；②对输入数据进行转义（mysql_real_escape_string()）；③使用ORM框架（如SQLite的sqlite3_prepare_v2()）。

char query[256];
sprintf(query, "SELECT * FROM users WHERE name='%s'", name);
mysql_real_escape_string(conn, escaped_name, name, strlen(name));
sprintf(query, "SELECT * FROM users WHERE name='%s'", escaped_name);