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

c linux连接mysql数据库

admin
行业动态
2025-02-27
3

在C语言中连接MySQL数据库，通常使用MySQL官方提供的C API库。首先需要安装MySQL开发库，然后在代码中包含相应的头文件，并使用 mysql_init()初始化连接句柄，接着通过 mysql_real_connect()建立与数据库的连接。

在Linux环境下使用C语言连接MySQL数据库，主要涉及到以下几个关键步骤：安装MySQL C语言开发包、引入必要的头文件、连接到MySQL数据库、执行SQL查询并获取结果以及关闭连接，以下是详细内容：

安装MySQL C语言开发包

要在Linux系统上使用C语言连接MySQL数据库，首先需要确保系统中安装了MySQL C语言开发包，这可以通过包管理工具如apt或yum来完成，在基于Debian的系统（如Ubuntu）上，可以使用以下命令安装：

sudo apt-get install libmysqlclient-dev

这条命令会安装MySQL C语言开发所需的库文件和头文件，使得后续的编译和链接操作能够顺利进行。

引入必要的头文件

在编写C语言程序以连接MySQL数据库之前，需要在代码中引入MySQL提供的头文件，这通常通过在代码顶部添加以下语句来实现：

#include <mysql/mysql.h>

这个头文件包含了与MySQL数据库进行交互所需的所有函数声明和数据结构定义。

连接到MySQL数据库

使用MySQL C语言API连接到MySQL数据库需要执行以下步骤：

c linux连接mysql数据库

1、创建MYSQL对象：需要创建一个MYSQL类型的对象，用于表示与数据库的连接，这可以通过调用mysql_init()函数来完成，该函数返回一个指向MYSQL对象的指针。

2、初始化MYSQL对象：需要使用mysql_real_connect()函数来初始化MYSQL对象，并建立到MySQL服务器的实际连接，这个函数需要提供数据库的主机名、用户名、密码、数据库名以及端口号等信息，如果连接成功，函数将返回一个非空指针；否则，将返回NULL，并可以通过mysql_error()函数获取错误信息。

示例代码如下：

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);
}

在上述代码中，我们首先创建了一个MYSQL对象conn，然后使用mysql_init()函数对其进行了初始化，我们使用mysql_real_connect()函数尝试连接到本地的MySQL服务器，并指定了用户名、密码和要连接的数据库，如果连接失败，我们将打印错误信息并退出程序。

执行SQL查询并获取结果

一旦成功连接到MySQL数据库，就可以执行SQL查询并获取结果了，这通常涉及到以下几个步骤：

c linux连接mysql数据库

1、执行SQL查询：使用mysql_query()函数来执行SQL查询，这个函数接受两个参数：一个是MYSQL对象指针，另一个是要执行的SQL查询字符串，如果查询执行成功，函数将返回0；否则，将返回非0值，并可以通过mysql_error()函数获取错误信息。

2、获取查询结果：如果SQL查询是SELECT语句，那么可以使用mysql_store_result()函数来获取查询结果集，这个函数将返回一个指向MYSQL_RES结构的指针，该结构包含了查询结果集的所有行，可以使用mysql_fetch_row()函数来逐行遍历结果集，并处理每一行的数据。

3、释放结果集内存：在处理完查询结果后，需要使用mysql_free_result()函数来释放结果集所占用的内存资源。

示例代码如下：

if (mysql_query(conn, "SELECT * FROM table")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
MYSQL_RES *res = mysql_store_result(conn);
if (res == NULL) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
int num_fields = mysql_num_fields(res);
MYSQL_ROW row;
while ((row = mysql_fetch_row(res))) {
    for(int i = 0; i < num_fields; i++) {
        if (row[i]) {
            printf("%st", row[i]);
        } else {
            printf("NULLt");
        }
    }
    printf("
");
}
mysql_free_result(res);

在上述代码中，我们首先执行了一个SELECT查询来获取表中的所有数据，我们使用mysql_store_result()函数来获取查询结果集，并通过mysql_num_fields()函数获取结果集中的字段数量，我们使用mysql_fetch_row()函数来逐行遍历结果集，并打印出每一行的数据，我们使用mysql_free_result()函数来释放结果集所占用的内存资源。

c linux连接mysql数据库

执行插入、更新和删除操作

除了查询数据外，还可以使用C语言通过MySQL C API执行插入、更新和删除等操作，这些操作与执行查询类似，也是通过mysql_query()函数来完成的，只需要将相应的SQL语句作为参数传递给该函数即可。

char *insert_sql = "INSERT INTO table (column1, column2) VALUES ('value1', 'value2')";
if (mysql_query(conn, insert_sql)) {
    fprintf(stderr, "%s
", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}