使用C++和Mysql进行图像存取操作记录
配置：
1.Mysql == 5.5.19
2.Vs2019
3.C++
一、创建图像存储表格
选择数据库指令：
将databasename改成你想操作的数据库就行。我这边依旧在student_manager数据库下进行操作。
use databasename;
CREATE TABLE images(image_name VARCHAR(255) NOT NULL,image_data LONGBLOB NOT NULL,PRIMARY KEY (image_name));
备注：
1.mage_name列被设定为VARCHAR(255)，意味着它可以存储最多255个字符的图像名称。你可以根据需要调整这个长度。
2.image_data列被设定为LONGBLOB类型，用于存储图像数据的二进制形式。
3.主键约束（PRIMARY KEY），这意味着每个图像名称都必须是唯一的。
在Navicat中刷新可以看到
二、修改数据库表结构
使用第一步创建表格后，直接对表格插入图像时，如果下报错：
Failed to insert data:Error:Data too long for column 'image_data' at row 1
这个错误表明你试图插入的数据超过了 image_data 列的最大允许大小。为了处理这个问题，你需要确保 image_data 列的类型和大小足够大以存储你的图像数据。
需要进行以下步骤：
1.修改数据库表结构：
确保 image_data 列的类型为 LONGBLOB，它可以存储最大 4GB 的数据。
修改指令为：
ALTER TABLE images MODIFY COLUMN image_data LONGBLOB;
images表格替换成自己的表格名字。
在mysql终端依次输入：
use student_manager;//选择数据库
ALTER TABLE images MODIFY COLUMN image_data LONGBLOB;//修改images表格
- 更新代码：
在插入数据之前设置 max_allowed_packet，这个在后续代码中完善。
三、图像以BLOB格式插入表格
代码如下：
#include <Windows.h>
#include <mysql.h>
#include<iostream>
#include <opencv2/core.hpp>
#include <opencv2/imgcodecs.hpp>
#include <opencv2/highgui.hpp>
using namespace cv;
using namespace std;
// 定义一个结构体用于存储图像数据
struct ImageData
{
string image_name; // 图像名称
vector<uchar> image_data; // 图像数据
};
// 将图像插入数据库的函数
void insertImageToDatabase(const ImageData& imgData)
{
MYSQL mysql; // 定义MySQL对象
mysql_init(&mysql); // 初始化MySQL对象
mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "GBK"); // 设置字符集为GBK
// 连接到数据库
if (mysql_real_connect(&mysql, "localhost", "root", "123456", "student_manager", 3306, NULL, 0))
{
printf("Mysql connected \n"); // 连接成功
}
else
{
printf("Mysql connected fail :Error:%s\n", mysql_error(&mysql)); // 连接失败，输出错误信息
return; // 返回
}
// 设置 max_allowed_packet
if (mysql_query(&mysql, "SET GLOBAL max_allowed_packet=67108864")) // 设置为64M
{
printf("Failed to set max_allowed_packet: %s\n", mysql_error(&mysql)); // 设置失败，输出错误信息
mysql_close(&mysql); // 关闭数据库连接
return; // 返回
}
// 准备SQL查询
const char* query = "INSERT INTO images (image_name, image_data) VALUES (?, ?)";
MYSQL_STMT* stmt = mysql_stmt_init(&mysql); // 初始化预处理语句
if (!stmt)
{
printf("mysql_stmt_init() out of memory\n"); // 初始化失败，内存不足
mysql_close(&mysql); // 关闭数据库连接
return; // 返回
}
if (mysql_stmt_prepare(stmt, query, strlen(query)))//执行成功时返回值为0 !!!!!!!!!!!!
{
printf("mysql_stmt_prepare() failed: %s\n", mysql_stmt_error(stmt)); // 预处理语句准备失败，输出错误信息
mysql_stmt_close(stmt); // 关闭预处理语句
mysql_close(&mysql); // 关闭数据库连接
return; // 返回
}
// 绑定参数
MYSQL_BIND bind[2]; // 定义绑定参数数组
memset(bind, 0, sizeof(bind)); // 初始化绑定参数数组
// 绑定图像名称
bind[0].buffer_type = MYSQL_TYPE_STRING; // 设置参数类型为字符串
bind[0].buffer = (char*)imgData.image_name.c_str(); // 设置参数值为图像名称
bind[0].buffer_length = imgData.image_name.length(); // 设置参数长度为图像名称长度
// 绑定图像数据
bind[1].buffer_type = MYSQL_TYPE_BLOB; // 设置参数类型为BLOB
bind[1].buffer = (char*)imgData.image_data.data(); // 设置参数值为图像数据
bind[1].buffer_length = imgData.image_data.size(); // 设置参数长度为图像数据大小
if (mysql_stmt_bind_param(stmt, bind))
{
printf("mysql_stmt_bind_param() failed: %s\n", mysql_stmt_error(stmt)); // 绑定参数失败，输出错误信息
mysql_stmt_close(stmt); // 关闭预处理语句
mysql_close(&mysql); // 关闭数据库连接
return; // 返回
}
// 执行SQL查询
if (mysql_stmt_execute(stmt))
{
printf("Failed to insert data:Error:%s\n", mysql_stmt_error(stmt)); // 执行查询失败，输出错误信息
}
else
{
printf("Image inserted successfully\n"); // 执行查询成功，输出成功信息
}
// 关闭预处理语句和数据库连接
mysql_stmt_close(stmt); // 关闭预处理语句
mysql_close(&mysql); // 关闭数据库连接
}
int main()
{
// 使用OpenCV加载图像
Mat image = imread("D:/work/C++Code/SQL/2.png", IMREAD_COLOR); // 读取图像
if (image.empty())
{
cout << "Could not open or find the image" << endl; // 图像读取失败，输出错误信息
return -1; // 返回错误码
}
// 将图像转换为vector<uchar>
vector<uchar> image_data(image.data, image.data + image.total() * image.elemSize()); // 将图像数据存储到vector中
// 创建ImageData对象
ImageData imgData;
imgData.image_name = "example_image"; // 设置图像名称
imgData.image_data = image_data; // 设置图像数据
// 将图像插入数据库
insertImageToDatabase(imgData); // 调用插入函数
return 0; // 返回成功码
}
在Navicat中可以看到如下数据：
四、取图
代码如下：
#define HAVE_STRUCT_TIMESPEC // 避免与MySQL库中的定义冲突
#include <windows.h>
#include <mysql.h> // 包含MySQL库的头文件
#include <opencv2/opencv.hpp> // 包含OpenCV库的头文件
#include <iostream> // 包含标准输入输出流库
#include <vector> // 包含标准向量库
#include <fstream> // 包含文件流库
using namespace std; // 使用标准命名空间
using namespace cv; // 使用OpenCV命名空间
void saveImageFromDB(const std::string& dbName, const std::string& tableName, const std::string& imageName, const std::string& outputPath) {
MYSQL* conn;
MYSQL_RES* res;
MYSQL_ROW row;
unsigned long* lengths; // 用于存储每列的长度
// 初始化连接
conn = mysql_init(NULL);
// 连接到数据库
if (!mysql_real_connect(conn, "localhost", "root", "123456", dbName.c_str(), 0, NULL, 0)) {
std::cerr << "Connection failed: " << mysql_error(conn) << std::endl;
return;
}
// 准备 SQL 查询
std::string query = "SELECT image_data FROM " + tableName + " WHERE image_name = '" + imageName + "'";
// 执行查询
if (mysql_query(conn, query.c_str())) {
std::cerr << "Query failed: " << mysql_error(conn) << std::endl;
mysql_close(conn);
return;
}
// 获取结果
res = mysql_use_result(conn);
// 检查是否有数据
if (res) {
row = mysql_fetch_row(res);
if (row != NULL) {
lengths = mysql_fetch_lengths(res); // 获取每列的长度
// 假设第一列是 image_data（BLOB 类型）
std::size_t len = lengths[0]; // 使用第一列的长度
std::vector<char> imageData(row[0], row[0] + len);
// 写入文件（与之前相同）
std::ofstream file(outputPath, std::ios::binary);
if (file.is_open()) {
file.write(imageData.data(), imageData.size());
file.close();
std::cout << "Image saved to " << outputPath << std::endl;
}
else {
std::cerr << "Failed to open file for writing" << std::endl;
}
}
mysql_free_result(res);
}
// 关闭连接
mysql_close(conn);
}
int main() {
// 从数据库中提取图像并保存到文件
saveImageFromDB("student_manager", "images", "example_image.jpg", "D:/work/C++Code/SQL/output/example_image.jpg");
return 0;
}
