8、Linux C/C++ 实现MySQL的图片插入以及图片的读取

news2024/11/20 20:24:07

本文结合了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,&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;

}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/562264.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

kafka 设置用户密码和通过SpringBoot测试

kafka 设置用户密码和通过SpringBoot测试

叙述 当前Kafka认证方式采用动态增加用户协议。 自0.9.0.0版本开始Kafka社区添加了许多功能用于提高Kafka群集的安全性&#xff0c;Kafka提供SSL或者SASL两种安全策略。SSL方式主要是通过CA令牌实现&#xff0c;此文主要介绍SASL方式。 1&#xff09;SASL验证: 验证方式Kaf…
阅读更多...
【JavaSE】Java基础语法(六)：方法详解

【JavaSE】Java基础语法(六)：方法详解

文章目录 1. 方法概述1.1 方法的概念 2. 方法的定义和调用2.1 方法的定义2.2 方法的调用过程 3. 带参数方法的定义和调用3.1 带参数方法定义和调用3.2 形参和实参 4. 带返回值方法的定义和调用4.1 带返回值方法定义和调用4.2 带返回值方法的练习-求两个数的最大值(应用) 5. 方法…
阅读更多...
【链接】深入理解PLT表和GOT表

【链接】深入理解PLT表和GOT表

系列综述&#xff1a; &#x1f49e;目的&#xff1a;本系列是个人整理为了秋招面试的&#xff0c;整理期间苛求每个知识点&#xff0c;平衡理解简易度与深入程度。 &#x1f970;来源&#xff1a;材料主要源于多处理器编程的艺术进行的&#xff0c;每个知识点的修正和深入主要…
阅读更多...
nest日志包pino、winston配置-懒人的折腾

nest日志包pino、winston配置-懒人的折腾

nest日志 三种node服务端日志选型 winstonpinolog4js 2023年5月23日 看star数&#xff1a;winston > pino > log4js 使用体验&#xff1a; pino 格式简洁&#xff0c;速度快&#xff0c;支持输入日志到任意数据库&#xff0c;日志暂无自动清理&#xff08;可能是我…
阅读更多...
AI是怎么帮我写代码，写SQL的？（本文不卖课）

AI是怎么帮我写代码，写SQL的？（本文不卖课）

近期&#xff0c;ChatGPT风起云涌&#xff0c;“再不入局&#xff0c;就要被时代淘汰”的言论甚嚣尘上&#xff0c;借着这一波创业的朋友都不止3-4个&#xff0c;如果没记错&#xff0c;前几次抛出该言论的风口似乎是区块链&#xff0c;元宇宙&#xff0c;WEB3.0。 画外音&…
阅读更多...
动态规划问题实验：数塔问题

动态规划问题实验：数塔问题

目录 前言实验内容实验流程实验过程实验分析伪代码代码实现分析算法复杂度用例测试 总结 前言 动态规划是一种解决复杂问题的方法&#xff0c;它将一个问题分解为若干个子问题&#xff0c;然后从最简单的子问题开始求解&#xff0c;逐步推导出更复杂的子问题的解&#xff0c;最…
阅读更多...
绝世内功秘籍《调试技巧》

绝世内功秘籍《调试技巧》

本文作者&#xff1a;大家好&#xff0c;我是paper jie&#xff0c;感谢你阅读本文&#xff0c;欢迎一建三连哦。 内容专栏&#xff1a;这里是《C知识系统分享》专栏&#xff0c;笔者用重金(时间和精力)打造&#xff0c;基础知识一网打尽&#xff0c;希望可以帮到读者们哦。 内…
阅读更多...
CloudQuery v2.0.0 发布 新增数据保护、数据变更、连接管理等功能

CloudQuery v2.0.0 发布 新增数据保护、数据变更、连接管理等功能

哈喽社区的小伙伴们&#xff0c;经过一个月的努力&#xff0c;CloudQuery 社区版发布了全新 v2.0.0系列&#xff01; 对比 v1.5.0&#xff0c;v2.0.0 在整体 UI 界面上就做了很大调整&#xff0c;功能排布我们做了重新梳理&#xff0c;可以说&#xff0c;社区版 v2.0.0 带领 C…
阅读更多...
Linux——makefile自动化构建工具

Linux——makefile自动化构建工具

一. 前言 一个工程中的源文件不计数&#xff0c;其按类型、功能、模块分别放在若干个目录中&#xff0c;makefile定义了一系列的 规则来指定&#xff0c;哪些文件需要先编译&#xff0c;哪些文件需要后编译&#xff0c;哪些文件需要重新编译&#xff0c;甚至于进行更复杂 的功能…
阅读更多...
数据结构的定义

数据结构的定义

主要的定义 数据 描述客观事物的数和字符的集合&#xff0c;比如文字&#xff0c;数字和特殊符号 基本单元&#xff1a;数据元素 一个数据单元由若干个数据项构成 数据项&#xff1a;具有独立含义的数据最小单元&#xff0c;也称字段或域 数据元素&…
阅读更多...
Spring Boot 中的 Starter 是什么？如何创建自定义 Starter？

Spring Boot 中的 Starter 是什么？如何创建自定义 Starter？

Spring Boot 中的 Starter 是什么&#xff1f;如何创建自定义 Starter&#xff1f; Spring Boot 是一个快速构建应用程序的框架&#xff0c;它提供了一种简单的方式来快速启动和配置 Spring 应用程序。Spring Boot Starter 是 Spring Boot 的一个重要概念&#xff0c;它可以帮…
阅读更多...
计算机网络详细笔记（四）网际控制报文协议ICMP

计算机网络详细笔记（四）网际控制报文协议ICMP

文章目录 4.网际控制报文协议ICMP4.1.ICMP报文的种类4.2.ICMP应用举例 4.网际控制报文协议ICMP 网际控制报文协议概述&#xff1a;&#xff1a; 作用&#xff1a;更有效地转发IP数据报和提高交付成功的机会。原理&#xff1a;允许主机或路由器报告差错情况和提供有关异常情况…
阅读更多...
maven_SSM项目如何实现验证码功能

maven_SSM项目如何实现验证码功能

验证码的作用 防止恶意注册&#xff0c;自动化程序批量注册。防止暴力破解。 1、这里我们使用goole的验证码生成器 由于直接在maven中引入依赖&#xff0c;没有找到。所以只能直接去下载jar包了。 链接&#xff1a;https://pan.baidu.com/s/1KANhJKI4sQCfkiroTVr0WA?pwd29iv …
阅读更多...
Oracle数据库环境变量配置修改数据库密码

Oracle数据库环境变量配置修改数据库密码

1.设置环境变量&#xff1a; 必须设置环境变量才可以用CMD命令访问Oracle数据库 1.1.首先找到你Oracle安装位置路径 C:\app\Administrator\product\11.2.0\dbhome_1 1.2.设置环境变量 1.2.1 设置Adimistrator变量 变量名&#xff1a; ORACLE_HOME 变量值&#xff1a;C:\app…
阅读更多...
嵌入式学习之Linux驱动（第九期_设备模型_教程更新了）_基于RK3568

嵌入式学习之Linux驱动（第九期_设备模型_教程更新了）_基于RK3568

驱动视频全新升级&#xff0c;并持续更新~更全&#xff0c;思路更科学&#xff0c;入门更简单。 迅为基于iTOP-RK3568开发板进行讲解&#xff0c;本次更新内容为第九期&#xff0c;主要讲解设备模型&#xff0c;共计29讲。视频选集 0.课程规划 06:35 1.抛砖引玉-设备模型…
阅读更多...
K8s in Action 阅读笔记——【3】Pods: running containers in Kubernetes

K8s in Action 阅读笔记——【3】Pods: running containers in Kubernetes

K8s in Action 阅读笔记——【3】Pods: running containers in Kubernetes 3.1 Introducing pods 在Kubernetes中&#xff0c;Pod是基本构建块之一&#xff0c;由容器集合组成。与独立部署容器不同&#xff0c;你总是要部署和操作一个Pod。Pod并不总是包含多个容器&#xff0…
阅读更多...
Python数据分析案例28——西雅图交通事故预测（不平衡样本处理）

Python数据分析案例28——西雅图交通事故预测（不平衡样本处理）

本次案例适合机器学习数据科学方向的同学。 引言(废话集) 交通事故是一个严重的公共安全问题&#xff0c;在全球范围内每年都有成千上万的人死于交通事故。随着交通运输的发展和城市化进程的加速&#xff0c;交通事故已成为制约城市发展和人民幸福的主要因素之一。因此&#x…
阅读更多...
【蓝桥杯选拔赛真题57】Scratch计数游戏 少儿编程scratch图形化编程 蓝桥杯选拔赛真题讲解

【蓝桥杯选拔赛真题57】Scratch计数游戏 少儿编程scratch图形化编程 蓝桥杯选拔赛真题讲解

目录 scratch计数游戏 一、题目要求 编程实现 二、案例分析 1、角色分析
阅读更多...
Java版本企业电子招标采购系统源码:营造全面规范安全的电子招投标环境，促进招投标市场健康可持续发展

Java版本企业电子招标采购系统源码:营造全面规范安全的电子招投标环境，促进招投标市场健康可持续发展

营造全面规范安全的电子招投标环境&#xff0c;促进招投标市场健康可持续发展 传统采购模式面临的挑战 一、立项管理 1、招标立项申请 功能点&#xff1a;招标类项目立项申请入口&#xff0c;用户可以保存为草稿&#xff0c;提交。 2、非招标立项申请 功能点&#xff1a;非招标…
阅读更多...
设计模式之【解释器模式】，用语言定义一门语言

设计模式之【解释器模式】，用语言定义一门语言

文章目录 一、什么是解释器模式1、常见文法&#xff08;语法&#xff09;规则2、抽象语法树3、解释器模式的使用场景4、解释器模式的四大角色5、解释器模式优缺点 二、实例1、解释器模式的一般写法2、数学表达式案例 三、源码中的解释器模式1、Pattern正则2、Spring的Expressio…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023