当前位置：首页 > 行业动态 > 正文

如何在C语言中实现数据库连接与查询操作？

admin
行业动态
2025-01-27
3322

连接数据库查询是指通过特定的连接方式，将应用程序与数据库建立联系，并执行相应的查询操作以获取所需数据的过程。

在C语言中连接数据库并进行查询是一个常见的需求，尤其是在开发服务器端应用程序时，下面将详细介绍如何在C语言中实现这一功能。

如何在C语言中实现数据库连接与查询操作？第1张

准备工作

需要确保你的系统上已经安装了所需的数据库管理系统（如MySQL、PostgreSQL等）以及相应的C语言开发库，以MySQL为例，你需要安装MySQL服务器和MySQL C API开发库。

包含必要的头文件

在C程序中，需要包含与数据库连接相关的头文件，对于MySQL，通常是mysql/mysql.h。

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

初始化数据库连接

使用mysql_init()函数初始化一个MYSQL类型的变量，该变量将用于后续的数据库操作。

MYSQL *conn;
conn = mysql_init(NULL);
if (conn == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}

连接到数据库

使用mysql_real_connect()函数连接到数据库，需要提供数据库的主机名、用户名、密码、数据库名以及端口号等信息。

if (mysql_real_connect(conn, "localhost", "user", "password", "database", 0, NULL, 0) == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

执行查询

使用mysql_query()函数执行SQL查询，如果查询成功，可以通过mysql_store_result()获取结果集。

if (mysql_query(conn, "SELECT * FROM users")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

处理查询结果

遍历结果集并处理每一行数据，使用mysql_fetch_row()函数获取当前行的数据。

MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
    printf("User ID: %s, Name: %s
", row[0], row[1]);
}

释放资源

查询完成后，需要释放结果集和关闭数据库连接。

mysql_free_result(result);
mysql_close(conn);

完整示例代码

以下是一个完整的示例代码，展示了如何在C语言中连接MySQL数据库并执行查询。

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_real_connect(conn, "localhost", "user", "password", "database", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    if (mysql_query(conn, "SELECT id, name FROM users")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    res = mysql_use_result(conn);
    if (res == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    while ((row = mysql_fetch_row(res))) {
        printf("User ID: %s, Name: %s
", row[0], row[1]);
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}