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

如何在C语言中查询SQL数据库？

admin
行业动态
2025-01-27
2432

SQL 是用于管理关系数据库的标准语言，可进行数据查询、更新和管理数据库结构等操作。

在C语言中查询SQL数据库通常涉及以下几个步骤：连接到数据库、执行查询语句、处理结果以及关闭连接，以下是一个详细的示例，展示如何在C语言中使用MySQL C API来查询SQL数据库。

如何在C语言中查询SQL数据库？第1张

安装MySQL开发库

你需要确保你的系统上安装了MySQL开发库，你可以通过包管理器（如apt-get或yum）进行安装，在Debian/Ubuntu系统上，你可以运行以下命令：

sudo apt-get install libmysqlclient-dev

包含必要的头文件

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

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

初始化和连接到数据库

使用mysql_init()函数初始化一个MYSQL对象，然后使用mysql_real_connect()函数连接到数据库服务器。

MYSQL *conn;
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);
}

在上面的代码中，将"localhost"替换为你的数据库服务器地址，将"user"替换为你的数据库用户名，将"password"替换为你的数据库密码，将"database"替换为你要连接的数据库名称。

执行查询

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

if (mysql_query(conn, "SELECT id, name 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("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 *result;
    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);
    }
    result = mysql_store_result(conn);
    if (result == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 处理结果集
    while ((row = mysql_fetch_row(result))) {
        printf("ID: %s, Name: %s
", row[0], row[1]);
    }
    // 释放资源和关闭连接
    mysql_free_result(result);
    mysql_close(conn);
    return 0;
}