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

如何在C语言中将数据库数据传递到结构体中？

admin
行业动态
2025-01-25
2104

### ，，在C语言中，向结构体中传送数据库可以通过多种方式实现，包括使用指针、嵌入其他结构体、利用联合体等。这些方法各有优缺点，如动态内存分配的灵活性与复杂性、嵌入结构体的代码可读性与固定大小限制、联合体的内存节省与数据覆盖风险等。还可以结合使用这些方法以达到最佳效果。

在C语言中，向结构体中传送数据库数据通常涉及以下几个步骤：

如何在C语言中将数据库数据传递到结构体中？第1张

定义结构体

首先需要定义一个与数据库表对应的结构体，假设我们有一个名为users的表，包含以下字段：id（整数），name（字符串），age（整数），我们可以定义一个相应的结构体来表示这个表中的一行数据：

typedef struct {
    int id;
    char name[50];
    int age;
} User;

连接数据库

需要使用适当的数据库API来连接到数据库，以MySQL为例，可以使用MySQL C API进行连接：

#include <mysql/mysql.h>
MYSQL *conn;
conn = mysql_init(NULL);
if (conn == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}
if (mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0) == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

查询数据库并获取结果集

执行SQL查询语句，并将结果存储在一个结果集中：

MYSQL_RES *res;
MYSQL_ROW row;
if (mysql_query(conn, "SELECT id, name, age FROM users")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
res = mysql_store_result(conn);
if (res == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

遍历结果集并填充结构体数组

遍历结果集，将每一行的数据读取到结构体实例中：

User users[100]; // 假设最多有100个用户
int i = 0;
while ((row = mysql_fetch_row(res)) != NULL) {
    users[i].id = atoi(row[0]);
    strncpy(users[i].name, row[1], sizeof(users[i].name) 1);
    users[i].age = atoi(row[2]);
    i++;
}

关闭连接和释放资源

不要忘记关闭数据库连接并释放所有分配的资源：

mysql_free_result(res);
mysql_close(conn);

示例代码整合

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

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
typedef struct {
    int id;
    char name[50];
    int age;
} User;
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    User users[100];
    int i = 0;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_real_connect(conn, "host", "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, age FROM users")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    res = mysql_store_result(conn);
    if (res == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    while ((row = mysql_fetch_row(res)) != NULL) {
        users[i].id = atoi(row[0]);
        strncpy(users[i].name, row[1], sizeof(users[i].name) 1);
        users[i].age = atoi(row[2]);
        i++;
    }
    // 输出结果验证
    for (int j = 0; j < i; j++) {
        printf("ID: %d, Name: %s, Age: %d
", users[j].id, users[j].name, users[j].age);
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}