本文结合了Linux C/C++ 实现MySQL的图片插入以及图片的读取，特别是数据库读写的具体流程

一、文件读取相关函数

• fseek() 可以将文件指针移动到文件中的任意位置。其基本形式如下：

int fseek(FILE *stream, long offset, int whence);

其中，stream 是一个指向已经打开的文件流的指针；offset 是相对于 whence 参数所表示位置的偏移量，可以为正数、负数或者零；而 whence 则是指定了 offset 所表示偏移量相对位置的标志。具体来说，它可以取以下三个值之一：
– SEEK_SET: 表示从文件起始处开始计算偏移量；
– SEEK_CUR: 表示从当前位置开始计算偏移量；
– SEEK_END: 表示从文件结尾处开始计算偏移量。
当调用成功时，返回值为 0；否则返回非零值。
需要注意的是，在使用完 fseek() 函数后，我们需要通过调用 ftell() 函数获取当前文件指针所在位置，并且确保该位置与我们想要设置的位置一致。

• ftell() 用于获取文件指针当前位置的函数，其原型如下：

long ftell(FILE *stream);

其中，stream 表示要获取当前位置的文件流指针。调用成功后，返回值为 long 类型，表示当前文件指针相对于文件开头的偏移量（以字节为单位）。

• fread() 用于从文件中读取二进制数据并存储到内存缓冲区中，其原型如下：

size_t fread(void *ptr, size_t size, size_t count, FILE *stream);

其中，ptr: 读取后存放数据的缓冲区地址。size: 每次读取元素的字节数。count: 读取元素的个数。stream: 文件指针。调用成功时，返回值为实际读取到的元素数量，通常与 count 参数相等。如果在读取操作过程中遇到了文件结束符或者发生了错误，则返回值会小于 count。

• fwrite()用于将内存中的二进制数据按照指定数量和大小写入到文件中。其原型如下：

size_t fwrite(void *ptr, size_t size, size_t count, FILE *stream);

其中，ptr：指向要写入的数据的指针。size：每个数据块的大小（以字节为单位）。count：要写入的数据块数量。stream：指向目标文件的FILE结构体指针。

二、stmt相关函数

使用stmt（或者叫做statement）能够将SQL语句预编译，这可以提高代码的执行效率和安全性。当我们使用stmt时，可以将 SQL 查询中需要传递的参数占位符（例如 “?”）和实际的参数值进行绑定，随后数据库会先对SQL语句进行预编译，并生成一个执行计划。之后，每次执行该SQL语句时，只需将实际参数值填充到占位符位置上即可执行该计划，而不需要重新编译整个SQL语句。这样可以大大减少数据库系统的开销，并提高应用程序的响应速度。

1、将本地(图片)数据写入到数据库的具体流程如下

1、创建一个MYSQL_STMT *stmt用于表示预处理语句
2、使用mysql_stmt_init()函数初始化MYSQL_STMT结构体对象stmt
3、使用mysql_stmt_prepare()函数将要执行的SQL语句绑定到对象stmt上
4、创建一个结构体MYSQL_BIND *param用于绑定SQL语句中参数的变量
5、使用mysql_stmt_bind_param()函数设置SQL语句中所需要的参数
6、使用mysql_stmt_send_long_data()函数绑定二进制数据到预处理的SQL语句的占位符中
7、使用mysql_stmt_execute()函数执行SQL语句
8、使用mysql_stmt_fetch()函数获取结果集中的数据
9、在使用完毕后，使用mysql_stmt_close()函数释放MYSQL_STMT对象

2、将从数据库读取(图片)数据的具体流程如下

1、创建一个MYSQL_STMT *stmt用于表示预处理语句
2、使用mysql_stmt_init()函数初始化MYSQL_STMT结构体对象stmt
3、使用mysql_stmt_prepare()函数将要执行的SQL语句绑定到对象stmt上
4、创建一个结构体MYSQL_BIND *result用于绑定SQL语句中参数的结果集
5、使用mysql_stmt_bind_result(stmt,&result)函数将查询结果绑定到 result 结构体
6、使用mysql_stmt_execute()函数执行SQL语句
7、使用mysql_stmt_store_result()函数将所有结果行保存在本地缓冲区中
8、使用mysql_stmt_fetch()函数获取结果集中行数据并存储到 result.buffer 中
9、使用mysql_stmt_fetch_column() 函数获取结果集列数据，并将其存储到缓冲区的相应位置上
9、在使用完毕后，使用mysql_stmt_close()函数释放MYSQL_STMT对象

#include<stdio.h>
#include<string.h>
#include<mysql.h>#define MING_DB_IP           "192.168.42.128"
#define MING_DB_PORT         3306
#define MING_DB_USENAME      "admin"
#define MING_DB_PASSWORD     "123456"
#define MING_DB_DEFAULTDB    "MING_DB"
#define FILE_IMAGE_LENGTH    (64*1024)#define SQL_INSERT_IMG_USER     "insert TBL_USER(U_NAME,U_GENDER,U_IMG) values('zxm','women',?);"
#define SQL_SELECT_IMG_USER     "select U_IMG from TBL_USER where U_NAME='zxm';"//从客户端读取图片存入节点服务器的buffer//filename:图片路径； buffer：存储图片
int read_image(char *filename,char *buffer){if (filename == NULL || buffer ==NULL ) return -1;FILE *fp=fopen(filename,"rb"); //以二进制模式读取该文件if (fp == NULL){printf("fopen failed\n");return -2;}//检测文件大小filefseek(fp,0,SEEK_END);int length=ftell(fp);fseek(fp,0,SEEK_SET);int size=fread(buffer,1,length,fp);if (size != length){printf("fread failed:%d\n",size);return -3;}fclose(fp);return size;
}//从节点服务器的buffer写入图片到客户端
int write_image(char *filename,char *buffer,int length){if (filename == NULL || buffer ==NULL || length <=1) return -1;FILE *fp=fopen(filename,"wb+"); if (fp == NULL){printf("fopen failed\n");return -2;}    int size=fwrite(buffer,1,length,fp);if (size != length){printf("fwrite failed:%d\n",size);return -3;}fclose(fp);return size;
}//从节点服务器的buffer读取数据到数据库
int mysql_write(MYSQL *handle,char *buffer,int length){if (handle ==NULL || buffer == NULL || length <=0) return -1;MYSQL_STMT *stmt=mysql_stmt_init(handle);int ret=mysql_stmt_prepare(stmt,SQL_INSERT_IMG_USER,strlen(SQL_INSERT_IMG_USER));if (ret){printf("mysql_stmt_prepare:%s\n",mysql_error(handle));return -2;}MYSQL_BIND param={0};param.buffer_type=MYSQL_TYPE_LONG_BLOB;param.buffer=NULL;param.is_null=0;param.length=NULL;ret=mysql_stmt_bind_param(stmt,&param);if (ret){printf("mysql_stmt_bind_param:%s\n",mysql_error(handle));return -3;       }ret=mysql_stmt_send_long_data(stmt,0,buffer,length);if (ret){printf("mysql_stmt_send_long_data:%s\n",mysql_error(handle));return -4;       }   ret=mysql_stmt_execute(stmt);if (ret){printf("mysql_stmt_execute:%s\n",mysql_error(handle));return -5;       }ret=mysql_stmt_close(stmt) ;  if (ret){printf("mysql_stmt_close:%s\n",mysql_error(handle));return -6;       }     return ret;
}//从数据库写入数据到节点服务器的buffer
int mysql_read(MYSQL *handle,char *buffer,int length){if (handle ==NULL || buffer == NULL || length <=0) return -1;MYSQL_STMT *stmt=mysql_stmt_init(handle);int ret=mysql_stmt_prepare(stmt,SQL_SELECT_IMG_USER,strlen(SQL_SELECT_IMG_USER));if (ret){printf("mysql_stat_prepare:%s\n",mysql_error(handle));return -2;}   MYSQL_BIND result={0};result.buffer_type=MYSQL_TYPE_LONG_BLOB;unsigned long total_length=0;result.length=&total_length;ret=mysql_stmt_bind_result(stmt,&result);if (ret){printf("mysql_stmt_bind_result:%s\n",mysql_error(handle));return -3;}     ret=mysql_stmt_execute(stmt);if (ret){printf("mysql_stmt_execute:%s\n",mysql_error(handle));return -4;}         ret=mysql_stmt_store_result(stmt);if (ret){printf("mysql_stmt_store_result:%s\n",mysql_error(handle));return -5;}    while (1){//获取下一行数据并存储到 result.buffer 中ret=mysql_stmt_fetch(stmt);if (ret !=0 && ret != MYSQL_DATA_TRUNCATED ) break;int start=0;while(start <(int)total_length ){/*buffer 是一个指向缓冲区起始地址的指针，而 start 是一个表示偏移量的整数。因此，buffer+start 的结果就是一个指向缓冲区中某个特定位置的指针。result.buffer指向的是buffer+start*/result.buffer=buffer+start; //存储实际读取到的数据长度，单位为字节 result.buffer_length=1;/*在使用 mysql_stmt_fetch_column() 函数从结果集中读取数据时，每次只会读取一部分数据并存储到由result.buffer所指向的缓冲区中。如果要将多个数据段合并成完整的数据块，则需要利用偏移量来调整存储位置。具体地说，可以通过不断修改 start 的值来控制写入数据时所处的位置。*/mysql_stmt_fetch_column(stmt,&result,0,start);start+=result.buffer_length;}}mysql_stmt_close(stmt);return total_length;}int main(){//定义一个MYSQL类型的结构体变量，并通过调用mysql_init()函数对其进行初始化//调用mysql_error()函数来获取有关错误信息MYSQL mysql;if (mysql_init(&mysql)==NULL){printf("mysql_init:%s\n",mysql_error(&mysql));return -1;}//mysql_real_connect()用于连接到MySQL服务器.它需要以下参数：/*1、MYSQL类型的结构体指针，该结构体已由mysql_init()初始化。2、MySQL服务器所在主机名或IP地址。3、登录MySQL服务器时使用的用户名。4、登录MySQL服务器时使用的密码。5、要连接的数据库名称。6、端口号（默认为3306）。7、规定 socket    8、规定不同的连接选项*/if(!mysql_real_connect(&mysql,MING_DB_IP,MING_DB_USENAME,MING_DB_PASSWORD,MING_DB_DEFAULTDB,MING_DB_PORT,NULL,0)){    //等于0，不成功printf("mysql_real_connect:%s\n",mysql_error(&mysql));return -2;}printf("case:mysql read image and write image \n");char buffer[FILE_IMAGE_LENGTH]={0};int length=read_image("/home/zxm/share/06mysqlPicture/0voice.jpg",buffer);if (length < 0) goto Exit;mysql_write(&mysql,buffer,length);printf("case:mysql read mysql and write image \n");memset(buffer,0,FILE_IMAGE_LENGTH);length=mysql_read(&mysql,buffer,FILE_IMAGE_LENGTH);write_image("a.jpg",buffer,length);Exit:mysql_close(&mysql);return 0;}