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

c怎么写入mysql数据库

admin
行业动态
2025-02-01
6

用C语言写入MySQL数据库：先安装配置MySQL及C API库，编写代码初始化连接、构建执行SQL语句并处理结果，最后关闭连接。

在C语言中写入MySQL数据库，主要通过使用MySQL Connector/C API来实现，以下是详细的步骤和示例代码：

一、安装MySQL开发库

1、Windows系统：从MySQL官方网站下载MySQL Connector/C的安装包，运行安装程序并按照提示完成安装，安装完成后，将安装目录下的include和lib目录添加到项目中。

2、Linux系统：对于Debian或Ubuntu系统，可以使用命令sudo apt-get install libmysqlclient-dev来安装MySQL开发库；对于Red Hat或CentOS系统，可以使用命令sudo yum install mysql-devel。

3、macOS系统：可以通过Homebrew安装，使用命令brew install mysql-connector-c。

二、包含必要的头文件

在C程序中，需要包含MySQL C API提供的头文件mysql/mysql.h，并在编译时链接MySQL客户端库，使用gcc编译时，可以添加-lmysqlclient选项。

三、连接数据库

1、初始化MySQL连接：使用mysql_init()函数初始化一个MYSQL结构体，用于存储MySQL连接的相关信息，如果初始化失败，会返回NULL。

c怎么写入mysql数据库

2、建立数据库连接：使用mysql_real_connect()函数与数据库建立连接，该函数需要提供数据库的主机地址、用户名、密码、数据库名称等信息，如果连接失败，会返回NULL。

示例代码如下：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    // 初始化MySQL库
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    // 连接到MySQL数据库
    if (mysql_real_connect(conn, "localhost", "username", "password", "test_db", 0, NULL, 0) == NULL) {
        fprintf(stderr, "mysql_real_connect() failed
");
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    // 后续操作...
    // 关闭连接
    mysql_close(conn);
    return 0;
}

四、执行SQL语句

1、构建SQL语句：根据需求构建相应的SQL插入语句，向名为users的表中插入一条记录，可以使用以下代码：

const char *query = "INSERT INTO users (name, age) VALUES ('Alice', 30)";

2、执行SQL语句：使用mysql_query()函数执行构建好的SQL语句，如果执行失败，可以通过mysql_error()函数获取错误信息。

c怎么写入mysql数据库

if (mysql_query(conn, query)) {
    fprintf(stderr, "INSERT failed. Error: %s
", mysql_error(conn));
    mysql_close(conn);
    exit(EXIT_FAILURE);
}

五、处理结果（可选）

对于插入操作，通常不需要处理结果，但如果需要获取插入操作的自动生成的ID，可以使用mysql_insert_id()函数。

六、关闭数据库连接

操作完成后，使用mysql_close()函数关闭数据库连接，释放相关资源。

七、完整示例代码

以下是一个完整的示例代码，演示了如何在C语言中连接MySQL数据库并插入数据：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    // 初始化MySQL库
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    // 连接到MySQL数据库
    if (mysql_real_connect(conn, "localhost", "root", "password", "test_db", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    // 构建插入数据的SQL语句
    const char *query = "INSERT INTO users (name, age) VALUES ('John Doe', 25)";
    // 执行SQL语句
    if (mysql_query(conn, query)) {
        fprintf(stderr, "INSERT failed. Error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(EXIT_FAILURE);
    }
    // 获取插入后的结果（可选）
    res = mysql_store_result(conn);
    if (res) {
        mysql_free_result(res); // 释放结果集
    }
    // 关闭连接
    mysql_close(conn);
    printf("Record inserted successfully!
");
    return 0;
}