c 读写mysql数据库

在C语言中读写MySQL数据库是一个常见的需求，尤其在需要高性能和底层操作的场景下，下面将详细介绍如何使用C语言连接MySQL数据库，并执行读写操作。

一、安装MySQL开发库

要在C语言中操作MySQL数据库，首先需要安装MySQL开发库，这个库提供了一组C语言的API，可以用来连接和操作MySQL数据库。

在大多数Linux发行版中，可以使用包管理工具来安装这些库，例如在Ubuntu系统中，可以使用以下命令：

sudo apt-get install libmysqlclient-dev

在Windows系统中，可以从MySQL官方网站下载并安装MySQL Connector/C。

二、初始化MySQL连接

在C语言中读取MySQL数据库时，首先需要初始化一个MySQL连接，以下是一些必要的步骤：

1、包含头文件：在代码中包含MySQL开发库的头文件。

   #include <mysql/mysql.h>

2、初始化MYSQL对象：使用mysql_init函数初始化一个MYSQL对象。

   MYSQL *conn;
   conn = mysql_init(NULL);

3、建立连接：使用mysql_real_connect函数建立一个到MySQL服务器的连接。

   const char *server = "localhost";
   const char *user = "root";
   const char *password = "password"; // MySQL root password
   const char *database = "testdb";
   if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
       fprintf(stderr, "%s
", mysql_error(conn));
       exit(1);
   }

三、执行SQL查询

在成功建立连接后，可以使用mysql_query函数执行SQL查询，以下代码执行一个简单的SELECT查询：

if (mysql_query(conn, "SELECT * FROM test_table")) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}

四、处理查询结果

执行SQL查询后，可以使用mysql_store_result函数获取查询结果，并通过mysql_fetch_row函数逐行读取数据，以下是处理查询结果的示例代码：

MYSQL_RES *res;
MYSQL_ROW row;
res = mysql_store_result(conn);
if (res == NULL) {
    fprintf(stderr, "%s
", mysql_error(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("%s ", row[i] ? row[i] : "NULL");
    }
    printf("
");
}
mysql_free_result(res);

五、关闭连接

在完成所有操作后，记得关闭MySQL连接，以释放资源：

mysql_close(conn);

六、写入数据到MySQL数据库

写入数据到MySQL数据库与读取数据类似，只是使用的SQL语句不同，以下是插入数据的示例代码：

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

七、修改和删除数据

修改和删除数据的操作也类似，只需更改SQL语句即可，更新数据的SQL语句为：

const char *update_query = "UPDATE test_table SET column1 = 'new_value' WHERE column2 = 'value2'";
if (mysql_query(conn, update_query)) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}

删除数据的SQL语句为：

const char *delete_query = "DELETE FROM test_table WHERE column2 = 'value2'";
if (mysql_query(conn, delete_query)) {
    fprintf(stderr, "%s
", mysql_error(conn));
    exit(1);
}

八、错误处理和调试

在实际开发过程中，错误处理和调试是非常重要的，MySQL C API提供了一些函数来帮助你处理和调试错误，

mysql_error：返回一个描述上一个MySQL函数调用错误的字符串。

mysql_errno：返回上一个MySQL函数调用错误的错误代码。

mysql_sqlstate：返回上一个MySQL函数调用错误的SQLSTATE字符串。

九、优化性能

在处理大量数据时，性能优化是非常重要的，以下是一些优化性能的建议：

使用批量操作：尽量使用批量操作来减少数据库连接和查询的次数。

使用索引：确保在查询的字段上创建适当的索引，以提高查询性能。

使用连接池：在高并发场景下，使用连接池可以减少连接的创建和销毁开销。

十、实际应用示例

以下是一个实际应用示例，展示了如何在C语言中读取MySQL数据库，并将查询结果保存到一个文件中：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
void finish_with_error(MYSQL *con) {
    fprintf(stderr, "%s
", mysql_error(con));
    mysql_close(con);
    exit(1);
}
int main() {
    MYSQL *con = mysql_init(NULL);
    if (con == NULL) {
        fprintf(stderr, "mysql_init() failed
");
        exit(EXIT_FAILURE);
    }
    if (mysql_real_connect(con, "localhost", "root", "password", "testdb", 0, NULL, 0) == NULL) {
        finish_with_error(con);
    }
    if (mysql_query(con, "SELECT * FROM test_table")) {
        finish_with_error(con);
    }
    MYSQL_RES *result = mysql_store_result(con);
    if (result == NULL) {
        finish_with_error(con);
    }
    FILE *file = fopen("output.txt", "w");
    if (file == NULL) {
        fprintf(stderr, "Could not open file for writing.
");
        exit(EXIT_FAILURE);
    }
    int num_fields = mysql_num_fields(result);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(result))) {
        for (int i = 0; i < num_fields; i++) {
            fprintf(file, "%st", row[i] ? row[i] : "NULL");
        }
        fprintf(file, "
");
    }
    fclose(file);
    mysql_free_result(result);
    mysql_close(con);
    return 0;
}