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

c 数据库连接查询

admin
行业动态
2025-01-31
4

### 本文主要介绍了数据库连接查询的相关内容，包括连接查询的概念、类型（内连接、外连接、交叉连接等）以及在实际业务场景中的应用实例，还提及了数据库查询实验的操作步骤和要求，旨在帮助读者理解和运用数据库连接查询技术。

在C语言中，进行数据库连接和查询操作通常需要借助第三方库，如MySQL Connector/C、libpq（用于PostgreSQL）、ODBC等，这些库提供了与数据库交互的接口函数，使得开发者可以在C程序中执行SQL查询、更新数据等操作，下面以MySQL为例，详细介绍如何在C语言中实现数据库连接和查询功能。

环境配置

确保你的开发环境中已经安装了MySQL服务器，并且创建了相应的数据库和表结构，需要安装MySQL Connector/C库，这可以通过包管理器或从官方网站下载源码编译安装。

包含头文件

在C源文件中，需要包含MySQL Connector/C提供的头文件：

#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_name", 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 table_name")) {
    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);
}
int num_fields = mysql_num_fields(result);
MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
    for (int i = 0; i < num_fields; i++) {
        printf("%st", row[i] ? row[i] : "NULL");
    }
    printf("
");
}

清理资源

查询完成后，释放结果集内存并关闭数据库连接。

mysql_free_result(result);
mysql_close(conn);

示例代码整合

以下是上述步骤的完整示例代码：

#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_name", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 执行查询
    if (mysql_query(conn, "SELECT * FROM table_name")) {
        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);
    }
    int num_fields = mysql_num_fields(res);
    while ((row = mysql_fetch_row(res))) {
        for (int i = 0; i < num_fields; i++) {
            printf("%st", row[i] ? row[i] : "NULL");
        }
        printf("
");
    }
    // 清理资源
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}