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

c实现数据库输入输出

admin
行业动态
2025-02-16
6

“

c，#include，#include，#includeint main() {， MYSQL *conn;， MYSQL_RES *res;， MYSQL_ROW row;， const char *server = "localhost";， const char *user = "root";， const char *password = "your_password"; /* set me first */， const char *database = "testdb"; conn = mysql_init(NULL);， if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {， fprintf(stderr, "%s，", mysql_error(conn));， exit(1);， } if (mysql_query(conn, "SELECT * FROM your_table")) {， fprintf(stderr, "%s，", mysql_error(conn));， exit(1);， } res = mysql_use_result(conn);， while ((row = mysql_fetch_row(res)) != NULL)， printf("%s ，", row[0]); mysql_free_result(res);， mysql_close(conn); return 0;，}，

“

C语言实现数据库输入输出

在C语言中，实现数据库的输入输出操作通常涉及以下几个步骤：连接到数据库、执行SQL查询、处理结果集以及断开连接，下面将详细介绍如何使用C语言与MySQL数据库进行交互。

准备工作

确保你的开发环境中已经安装了MySQL数据库，并且有一个可以访问的数据库和表，还需要安装MySQL的开发库，以便在C程序中使用MySQL的API。

包含头文件

在C源文件中，需要包含MySQL的头文件以及其他标准库头文件：

#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()函数连接到MySQL服务器，需要提供服务器地址、用户名、密码、数据库名等参数：

c实现数据库输入输出

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

执行SQL查询

使用mysql_query()函数执行SQL查询，要插入一条记录到表中：

char *query = "INSERT INTO users(name, age) VALUES('Alice', 30)";
if (mysql_query(conn, query)) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

6. 处理查询结果（针对SELECT查询）

如果执行的是SELECT查询，需要使用mysql_store_result()来获取结果集，并遍历结果集：

MYSQL_RES *res;
MYSQL_ROW row;
if ((res = mysql_store_result(conn)) == 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()函数断开与数据库的连接：

c实现数据库输入输出

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;
    char *server = "localhost";
    char *user = "root";
    char *password = "password"; /* set me first */
    char *database = "testdb";
    conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 插入数据
    if (mysql_query(conn, "INSERT INTO users(name, age) VALUES('Bob', 25)")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 查询数据
    if (mysql_query(conn, "SELECT name, age FROM users")) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    res = mysql_use_result(conn);
    if (res == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    // 输出结果集
    printf("NametAge
");
    while ((row = mysql_fetch_row(res)) != NULL) {
        printf("%st%s
", row[0], row[1]);
    }
    // 清理工作
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}