C++ 二进制图片的读取和blob插入mysql_stmt_init—新年第一课

关于二进制图片的读取和BLOB插入一共包含五步

第一步:初始化

MYSQL_STMT* stmt = mysql_stmt_init(&mysql);

第二步:预处理sql语句

mysql_stmt_prepare(stmt,sql,sqllen);

第三步:绑定字段

mysql_stmt_bind_param(stmt,bind);

第四步:执行

mysql_stmt_excute(stmt);

第五步:关闭

mysql_stmt_close(stmt);

详细步骤如下:

1、连接数据库;这个就不详细讲解了

const char* host = "127.0.0.1";const char* user = "root";const char* password = "************";const char* database = "database_test";int port = 3306;MYSQL mysql;mysql_init(&mysql);mysql_library_init(0, NULL, NULL);//防止乱码mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "GBK");//支持多条sql语句 CLIENT_MULTI_STATEMENTS   clientflag  默认是不支持的//if (!mysql_real_connect(&mysql, host, user, password, database, port, 0, 0))if (!mysql_real_connect(&mysql, host, user, password, database, port, NULL, 0)){cout << "failed to connect" << host << mysql_error(&mysql) << endl;}else{cout << "successfully connected " << host <<endl;}

2、创建数据表t_data; 创建好存放二进制数据的表 t_data

注意***:这里的数据类型,必须是blob其他和以前一样

//创建号存放二进制数据的表 t_datastring sql = "";sql="CREATE TABLe IF NOT EXISTS `t_data`(\`id` int AUTO_INCREMENT,\`name` varchar(1024),\`data` blob,\`size` int,\PRIMARY KEY(id)\)";int re = mysql_query(&mysql, sql.c_str());if (re != 0){cout << "failed mysql_error" << mysql_error(&mysql) << endl;}

3、初始化stmt

MYSQL_STMT*stmt=mysql_stmt_init(&mysql);

4、预处理sql语句

// 注意这里的插入必须是???
sql="insert into t_data (name,data,size) values (?,?,?)";

//错误输出是mysql_stmt_error(stmt);和之前不一样哦;

//sql语句,插入数据
// 注意这里的插入必须是???sql = "insert into `t_data` (name,data,size) values (?,?,?)";if (mysql_stmt_prepare(stmt, sql.c_str(), sql.size())){cerr << "mysql_stmt_prepare failed!" << mysql_stmt_error(stmt) << endl;}

5、绑定字段

MYSQL_BIND bind[3]={ 0 };//第一个数据name
bind[0].buffer_type = MYSQL_TYPE_STRING; //name文件名
bind[0].buffer = (char*)filename.c_str();//原图的文件名
bind[0].buffer_length = filename.size();
//(char*) buffer要求的是void*,而c_str()是只读的,所以要转换char*。
//而bind是可以输入可以输出,所以不可以只读。默认const是只读的,但是在这儿是插入数据,不会修改数据,可以用char*bind[1].buffer_type = MYSQL_TYPE_BLOB;// data 文件二进制内容
bind[1].buffer = data; //二进制文件
bind[1].buffer_length = filesize; //文件大小//把文件大小存下来
//从mysql取出来,可以知道文件大小,但是不一定将它取出来,
//经常做显示文件列表,有时候不需要显示二进制。希望有个字段将文件大小存下来bind[2].buffer_type = MYSQL_TYPE_LONG;//长整型,不用直到size,因为是固定大小
bind[2].buffer = &filesize;  //存放指针

5.1、如何filename 和data?

在上述代码的前面需要定义filename和data大小;

//4、打开并读取文件string filename = "mysql.jpg";//打开文件可以有多种方式,可以用c的file fopen,但是这个在vs2017里面说不安全,得设置不安全选项//fopen_s 是多线程安全版本的,到了linux又不行了//为了跨平台,用C++方式读取 fstream//需要知道文件大小和文件二进制  考虑到空间的分配和释放 动态空间//int filesize = 0;//ios::binary必须写,因为是二进制文件,如果是文本文件,无所谓不用加,但是还是加着fstream in(filename, ios::in | ios::binary);//文件是否存在if (!in.is_open()){cerr << "file" << filename << "open failed" << endl;}//fopen//句柄,文件指针移到结尾处//从结尾往前移动,移动0个位置,也就是结尾//判断位置in.seekg(0, ios::end);// 得到文件大小,//文件大小和文件二进制int filesize = in.tellg();//得到大小之后,将文件移到开头,要不然待会读文件就读不到了in.seekg(0, ios::beg);//分配空间大小char* data = new char[filesize];//查看是否读完,不保证一次读完,所以用循环读,可以直到读取了多少int readed = 0;//已经读了多少while (!in.eof()){//in.read(data, filesize); data读什么数据,filesize读多少//指针要进行移位in.read(data + readed, filesize - readed);//上次读了多少字节if (in.gcount()<=0){break;}readed += in.gcount();}in.close();

6、绑定 mysql_stmt_bind_param(stmt, bind)

//6、绑定if (mysql_stmt_bind_param(stmt, bind)!=0) //定义和文档不一致,=表示成功{//cerr错误输出,在重定向的时候,可以分割开来,也可以写到文件当中//cout 标准输出/*cout:写到标准输出的ostream对象;cerr:输出到标准错误的ostream对象,常用于程序错误信息;clog:也是输出标准错误流(这点儿和cerr是一样的),貌似平时很少用到这个啊;*/cerr << "mysql_stmt_bind_param failed" << mysql_stmt_error(stmt) << endl;}

7、执行stmt sql

//7、执行stmt sqlif (mysql_stmt_execute(stmt) != 0){//cerr错误输出cerr << "mysql_stmt_execute failed" << mysql_stmt_error(stmt) << endl;}

8、关闭stmt

mysql_stmt_close(stmt);

9、注意****

9.1、刚才申请了data空间是动态控件,必须要释放

delete []data;

9.2、在读取文件之后,一定要把文件关闭

in.close();

完整代码如下:

#define _CRT_SECURE_NO_WARNINGS
#include<iostream>
#include<stdio.h>
#include<mysql.h>
#include<thread>
#include<map>
#include<sstream>
#include<fstream>
//计时
#include<chrono>
using namespace std;
using namespace chrono;int main()
{const char* host = "127.0.0.1";const char* user = "root";const char* password = "*********"; //输入自己数据库的密码const char* database = "database_test";int port = 3306;MYSQL mysql;mysql_init(&mysql);mysql_library_init(0, NULL, NULL);//防止乱码mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "GBK");//支持多条sql语句 CLIENT_MULTI_STATEMENTS   clientflag  默认是不支持的//if (!mysql_real_connect(&mysql, host, user, password, database, port, 0, 0))if (!mysql_real_connect(&mysql, host, user, password, database, port, NULL, 0)){cout << "failed to connect" << host << mysql_error(&mysql) << endl;}else{cout << "successfully connected " << host <<endl;}//blob  blob存放二进制// int 最大值大概是2g//1、创建号存放二进制数据的表 t_datastring sql = "";sql="CREATE TABLe IF NOT EXISTS `t_data`(\`id` int AUTO_INCREMENT,\`name` varchar(1024),\`data` blob,\`size` int,\PRIMARY KEY(id)\)";int re = mysql_query(&mysql, sql.c_str());if (re != 0){cout << "failed mysql_error" << mysql_error(&mysql) << endl;}//2、初始化MYSQL_STMT* stmt = mysql_stmt_init(&mysql);//3、预处理sql语句sql = "insert into `t_data` (name,data,size) values (?,?,?)";if (mysql_stmt_prepare(stmt, sql.c_str(), sql.size())){cerr << "mysql_stmt_prepare failed!" << mysql_stmt_error(stmt) << endl;}//4、打开并读取文件string filename = "mysql.jpg";//打开文件可以有多种方式,可以用c的file fopen,但是这个在vs2017里面说不安全,得设置不安全选项//fopen_s 是多线程安全版本的,到了linux又不行了//为了跨平台,用C++方式读取 fstream//需要知道文件大小和文件二进制  考虑到空间的分配和释放 动态空间//int filesize = 0;//ios::binary必须写,因为是二进制文件,如果是文本文件,无所谓不用加,但是还是加着fstream in(filename, ios::in | ios::binary);//文件是否存在if (!in.is_open()){cerr << "file" << filename << "open failed" << endl;}//fopen//句柄,文件指针移到结尾处//从结尾往前移动,移动0个位置,也就是结尾//判断位置in.seekg(0, ios::end);// 得到文件大小,//文件大小和文件二进制int filesize = in.tellg();//得到大小之后,将文件移到开头,要不然待会读文件就读不到了in.seekg(0, ios::beg);//分配空间大小char* data = new char[filesize];//查看是否读完,不保证一次读完,所以用循环读,可以直到读取了多少int readed = 0;//已经读了多少while (!in.eof()){//in.read(data, filesize); data读什么数据,filesize读多少//指针要进行移位in.read(data + readed, filesize - readed);//上次读了多少字节if (in.gcount()<=0){break;}readed += in.gcount();}in.close();//5、绑定字段MYSQL_BIND bind[3] = { 0 };bind[0].buffer_type = MYSQL_TYPE_STRING; //name文件名//(char*) buffer要求的是void*,而c_str()是只读的,所以要转换char*。//而bind是可以输入可以输出,所以不可以只读。默认const是只读的,但是在这儿是插入数据,不会修改数据,可以用char*bind[0].buffer = (char*)filename.c_str();//原图的文件名bind[0].buffer_length = filename.size();bind[1].buffer_type = MYSQL_TYPE_BLOB;// data 文件二进制内容bind[1].buffer = data; //二进制文件bind[1].buffer_length = filesize; //文件大小//把文件大小存下来//从mysql取出来,可以知道文件大小,但是不一定将它取出来,//经常做显示文件列表,有时候不需要显示二进制。希望有个字段将文件大小存下来bind[2].buffer_type = MYSQL_TYPE_LONG;//长整型,不用直到size,因为是固定大小bind[2].buffer = &filesize;  //存放指针//6、绑定if (mysql_stmt_bind_param(stmt, bind)!=0) //定义和文档不一致,=表示成功{//cerr错误输出,在重定向的时候,可以分割开来,也可以写到文件当中//cout 标准输出/*cout:写到标准输出的ostream对象;cerr:输出到标准错误的ostream对象,常用于程序错误信息;clog:也是输出标准错误流(这点儿和cerr是一样的),貌似平时很少用到这个啊;*/cerr << "mysql_stmt_bind_param failed" << mysql_stmt_error(stmt) << endl;}//7、执行stmt sqlif (mysql_stmt_execute(stmt) != 0){//cerr错误输出cerr << "mysql_stmt_execute failed" << mysql_stmt_error(stmt) << endl;}delete [] data;mysql_stmt_close(stmt);mysql_close(&mysql);mysql_library_end();system("pause");return 0;
}

插入成功

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【华为机试】2023年真题B卷(python)-靠谱的车

一、题目 题目描述&#xff1a; 程序员小明打了一辆出租车去上班。出于职业敏感&#xff0c;他注意到这辆出租车的计费表有点问题&#xff0c;总是偏大。 出租车司机解释说他不喜欢数字4&#xff0c;所以改装了计费表&#xff0c;任何数字位置遇到数字4就直接跳过&#xff0c;其…

thinkphp6入门(14)-- 多关联模型查询

背景&#xff1a; 有3个数据表&#xff0c;一个User表&#xff0c;一个Cloth表&#xff0c;一个Shoe表。 Cloth表和Shoe表分别和User表通过user_id关联。 thinkphp 6中如何通过模型查询所有用户&#xff0c;其中包括每个用户的cloth和shoe。 多关联模型查询&#xff1a; 1.…

邮件群发称呼怎么写?写群发邮件开头技巧?

如何写外贸邮件群发称呼&#xff1f;外贸群发邮件开头怎么称呼&#xff1f; 邮件群发已成为企业、个人和组织之间沟通的重要手段。而一个恰当的称呼&#xff0c;不仅能够展现出礼貌和尊重&#xff0c;还能够拉近彼此的距离。那么&#xff0c;如何写好邮件群发的称呼呢&#xf…

【2024年必看】私域裂变的10大秘籍,让你轻松玩转市场!

在私域时代&#xff0c;企业需要不断地寻找新的用户来扩大自己的用户群体。然而&#xff0c;随着获客成本的逐渐升高&#xff0c;传统的广告宣传和推广方式已经不再是最优选择。因此&#xff0c;“老带新”的裂变策略成为了企业拉新的首选。 通过给予老用户奖励&#xff0c;刺…

ChatGPT持续火热,OpenAI年收入突破16亿美元

著名科技媒体The Information消息&#xff0c;由于OpenAI的ChatGPT等产品实现强劲增长&#xff0c;其年收入将突破16亿美元。 这主要得益于OpenAI在2023年发布了一系列重磅产品&#xff0c;包括GPT-4、ChatGPT企业版、GPT-4 Turbo、DALLE 3、苹果/安卓应用、自定义GPTs、Assis…

安全防御之授权和访问控制技术

授权和访问控制技术是安全防御中的重要组成部分&#xff0c;主要用于管理和限制对系统资源&#xff08;如数据、应用程序等&#xff09;的访问。授权控制用户可访问和操作的系统资源&#xff0c;而访问控制技术则负责在授权的基础上&#xff0c;确保只有经过授权的用户才能访问…

vis 动态添加数据

借鉴两篇文章作出了demo效果 vue用vis插件如何实现网络拓扑图_vue.js_脚本之家 src/App.vue yaofengqiao/vis-demo - Gitee.com mounted () {this.getList();},methods: {getList() {allRelation(this.queryParams).then(response > {var edgeList response;var edges n…

Go语言基础简单了解

文章目录 前言关于Go学习流程 基础语法注释变量常量数据类型运算符fmt库 流程控制if、switch、selectfor、break、continue遍历String 函数值传递和引用传递deferinit匿名、回调、闭包函数 数组和切片Map结构体自定义数据类型接口协程和channel线程锁异常处理泛型文件读取文件写…

进制的计算方法

目录 一、什么是进制 二、进制是干什么的 三、进制的计数规则 四、进制相互转换 五、用计算器计算进制 六、进制前缀 一、什么是进制 生活中进制无处不在&#xff0c;最常用的就是十进制。如果你没有接触过计算机或者是通信相关的知识&#xff0c;那么大概率你只知道十进…

09、docker 安装nacos并配置mysql存储配置信息

docker 安装nacos并配置mysql存储配置信息 1、docker启动nacos的各种方式2、Docker安装nacos3、MySQL中新建nacos的数据库4、挂载数据or配置目录5、运行 1、docker启动nacos的各种方式 内嵌derby数据源 docker run -d \ -e PREFER_HOST_MODEhostname \ -e SPRING_DATASOURCE_…

云原生容器编排问题盘点,总结分享年度使用Kubernetes的坑和陷阱

云原生容器编排问题盘点&#xff0c;总结分享年度使用Kubernetes的坑和陷阱 Kubernetes与云原生性能问题&#xff1a;忽略节点选择器导致调度效率低下问题排查和分析解决方案案例介绍 配置问题&#xff1a;应用服务端口与Service&#xff08;KubectlProxy&#xff09;控制的端口…

深度生成模型之GAN优化目标设计与改进 ->(个人学习记录笔记)

文章目录 深度生成模型之GAN优化目标设计与改进原始GAN优化目标的问题1. JS散度度量问题2. 梯度问题 优化目标的设计与改进1. 最小二乘损失GAN2. Energy-based GAN(EBGAN)3. Wasserstein GAN4. WGAN-GP5. Boundary Equilibrium GAN(BEGAN)6. Loss Sensitive GAN7. Relativeisti…