本文结合了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; } //检测文件大小file fseek(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,¶m); 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; }