C代码实现Mysql导出表数据，sql语句保存

article/2025/8/22 7:15:04

概述

本人最近项目的要求，需要定时检查数据库变化，定时将变化的数据库数据导出来另外保存。
所以研究数据库数据导出功能，并记录下开发过程。因暂时没有需要，没有将数据库的结构保存。

软件环境

编译器：vs2022
数据库：mysql，版本community 8.0.29.0
操作系统：win7

开发搭建

1、找头文件和库
安装好mysql之后，在安装路径下就有相关文件，
比如我安装头文件在这里(整个目录都要)：C:\Program Files\MySQL\MySQL Server 8.0\include
库在这里：C:\Program Files\MySQL\MySQL Server 8.0\lib\mysqlclient.lib
我喜欢用静态库，因为静态库编译集成到exe文件，不用像动态运行时候带着dll一起麻烦。

2、新建项目和复制文件
我用vs2022新建c++控制台项目MysqlBackup，将上一步的文件复制到目录下，如下图
在这里插入图片描述

3、确定编译版本
用静态库，就要保持和静态库一样的编译器版本。顺便提一下，动态库没有这个麻烦，其他编译器(如python,java)其他版本都可以调用。
用ultraedit打开mysqlclient.lib查看二进制，搜索字符串_MSC_VER，如下图
在这里插入图片描述
可以看到，_MSC_VER=1900，在百科查一下，对应的编译版本是v140，是vs2015的，在vs2022上把v140模块加上也可以。
如图这样配置

所有C代码

// MysqlBackup.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。
//#define _CRT_SECURE_NO_WARNINGS //使用过时的函数不会报错#include <stdio.h>
#include "include/mysql.h"
#include "include/field_types.h"#pragma comment(lib, "mysqlclient.lib")void get_table_data(char* tableName, MYSQL* mysqlData, FILE* saveFile)
{MYSQL_RES* sqlRestore = NULL;char buf[512];char data[2048];int i = 0;int j = 0;int index = 0;const int cntPer = 10;MYSQL_ROW tableRowData = NULL;MYSQL_FIELD* tableField = NULL;index = 0;while (1) {sprintf(buf, "select * from %s limit %d offset %d;", tableName, cntPer, index);mysql_query(mysqlData, buf);sqlRestore = mysql_store_result(mysqlData);if (sqlRestore == NULL) {break;}if (mysql_num_rows(sqlRestore) <= 0) {mysql_free_result(sqlRestore);break;}for (i = 0; i < mysql_num_rows(sqlRestore); i++) {tableRowData = mysql_fetch_row(sqlRestore);if (tableRowData == NULL) {continue;}            memset(buf, 0x00, sizeof(buf));memset(data, 0x00, sizeof(data));sprintf(buf, "insert into `%s` (", tableName);for (j = 0; j < mysql_num_fields(sqlRestore); j++) {if (tableRowData[j] == NULL) {continue;}tableField = mysql_fetch_field_direct(sqlRestore, j);if (j != 0) {strcat(buf, ",");strcat(data, ",");}strcat(buf, "`");strcat(buf, tableField->name);strcat(buf, "`");//printf("name=%s type=%d ", tableField->name, tableField->type);//printf("data = %s\n", tableRowData[j]);if (tableField->type == MYSQL_TYPE_DECIMAL|| tableField->type == MYSQL_TYPE_TINY|| tableField->type == MYSQL_TYPE_SHORT|| tableField->type == MYSQL_TYPE_LONG|| tableField->type == MYSQL_TYPE_FLOAT|| tableField->type == MYSQL_TYPE_DOUBLE|| tableField->type == MYSQL_TYPE_TIMESTAMP|| tableField->type == MYSQL_TYPE_LONGLONG|| tableField->type == MYSQL_TYPE_INT24|| tableField->type == MYSQL_TYPE_BOOL) {strcat(data, tableRowData[j]);} else {strcat(data, "\'");strcat(data, tableRowData[j]);strcat(data, "\'");}}strcat(buf, ") values (");//printf("%s%s);\n", buf, data);fwrite(buf, 1, strlen(buf), saveFile);fwrite(data, 1, strlen(data), saveFile);fwrite(");\r\n", 1, strlen(");\r\n"), saveFile);}       mysql_free_result(sqlRestore);index += cntPer;}fwrite("\r\n", 1, 2, saveFile);
}int main()
{int re = 0;int i = 0;MYSQL mysqlData;MYSQL_RES* sqlRestore = NULL;MYSQL_ROW pTableName = NULL;const char* url = "127.0.0.1";const char* user = "shenweihong";const char* passwdStr = "shen_123456#abc";const char* dataBase = "pyweb";int port = 3306;FILE* pSaveFile = NULL;pSaveFile = fopen("123.txt", "wb");re = mysql_library_init(0, NULL, NULL);printf("mysql_library_init re = %d\n", re);if (re != 0) {printf("mysql_library_init fail re = %d\n", re);goto EXIT_FUN;}if (mysql_init(&mysqlData) == 0) {printf("mysql_init fail\n");goto EXIT_FUN;}printf("mysql_init success\n");if (mysql_real_connect(&mysqlData, url, user, passwdStr, NULL, port, NULL, 0) == NULL) {printf("mysql_real_connect fail\n");mysql_close(&mysqlData);goto EXIT_FUN;}printf("mysql_real_connect success\n");mysql_select_db(&mysqlData, dataBase);mysql_query(&mysqlData, "SHOW TABLES;");sqlRestore = mysql_store_result(&mysqlData);for (i = 0; i < mysql_num_rows(sqlRestore); i++) {pTableName = mysql_fetch_row(sqlRestore);printf("TableName=%s\n", pTableName[0]);get_table_data(pTableName[0], &mysqlData, pSaveFile);}mysql_free_result(sqlRestore);EXIT_FUN:fclose(pSaveFile);mysql_library_end();return 0;
}