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

c 读取数据库内容

admin
行业动态
2025-03-21
3

步骤，1. 包含数据库头文件，如 #include。，2. 初始化数据库连接，如 MYSQL conn; conn = mysql_init(NULL);。，3. 连接到数据库，如 mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0);。，4. 执行查询语句，如 mysql_query(conn, "SELECT FROM table_name");。，5. 处理结果集，如 MYSQL_RES res; res = mysql_store_result(conn);。，6. 逐行读取结果，如 MYSQL_ROW row; while ((row = mysql_fetch_row(res)) != NULL) { / 处理每行数据 / }。，7. 释放资源，如 mysql_free_result(res); mysql_close(conn);。

在C语言中，读取数据库内容通常需要借助数据库提供的API或库，以下以MySQL数据库为例，介绍如何在C语言中读取数据库内容。

安装MySQL开发库

确保系统上已安装MySQL服务器和开发库，在Linux系统中，可以使用以下命令安装：

sudo apt-get update
sudo apt-get install libmysqlclient-dev

包含头文件

在C程序中，需要包含MySQL的头文件：

#include <mysql/mysql.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", "root", "password", "database_name", 0, NULL, 0) == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

执行查询

使用mysql_query()函数执行SQL查询，要读取名为users的表中的所有数据，可以这样做：

if (mysql_query(conn, "SELECT  FROM users")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

处理结果集

使用mysql_store_result()函数获取查询结果，并遍历结果集：

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()函数关闭与数据库的连接：

mysql_close(conn);

以下是一个完整的示例代码，展示了如何在C语言中读取MySQL数据库的内容：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL conn;
    MYSQL_RES result;
    MYSQL_ROW row;
    int num_fields;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_real_connect(conn, "localhost", "root", "password", "database_name", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    if (mysql_query(conn, "SELECT  FROM users")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    result = mysql_store_result(conn);
    if (result == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    num_fields = mysql_num_fields(result);
    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);
    return 0;
}