01-连接池项目背景：C++的数据库操作

从0开始学习C++与数据库的联动

1.原始方式-使用MySQL Connector/C 提供的API查询

1.1 数据库预操作

我的本地电脑上有mysql数据库，里面预先创建了一个database名叫chat，用户名root，密码password。

1.2 Visual Studio预操作

在Windows上使用VS需要加一些路径之类的，这样才可以使用MySQL C API。否则，无法找到mysql.h，无法正常链接dll、lib，无法编译。
1.下载MySQL Connector/C；
2.配置包含目录和库目录：
“C/C++” -> “常规” -> “附加包含目录”，添加MySQL Connector/C的include目录。
“链接器” -> “常规” -> “附加库目录”，添加MySQL Connector/C的lib目录。
3.配置链接库：
在“链接器” -> “输入” -> “附加依赖项”，添加以下库文件：
libmysql.lib：MySQL C API的静态库。
mysqlclient.lib：MySQL C API的动态链接库。
4.拷贝运行时依赖项： 将MySQL Connector/C的bin目录添加到系统的PATH环境变量中，并将libmysql.dll文件复制到vcxproj文件所在的目录。

1.3 简单查询程序

1.下面是一个单线程的程序，所有的数据库连接和查询都是在主线程中执行的。（里面可能有一些不安全的操作，方便理解没有管，比如close函数里传nullptr是不安全的，NULL最好改成nullptr便于与0值区分等。）
2.mysql.h声明了MYSQL、MYSQL_ROW、MYSQL_RES等结构体和一些mysql_init这样的函数，必须包含这个头文件，编译才不会出错。
从https://dev.mysql.com/doc/c-api/8.0/en/c-api-basic-function-reference.html摘了一些出来，可跳转链接看具体的接口参数
结构体：
在这里插入图片描述
函数接口：
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

#include <iostream>
#include <mysql.h> // 假设使用MySQL数据库

int main() {
    // 步骤1：建立数据库连接
    MYSQL* conn = mysql_init(NULL);
    if (conn == NULL) {
        std::cerr << "Failed to initialize MySQL connection." << std::endl;
        return -1;
    }

    if (mysql_real_connect(conn, "localhost", "root", "password", "chat", 0, NULL, 0) == NULL) {
        std::cerr << "Failed to connect to MySQL database." << std::endl;
        mysql_close(conn);
        return -1;
    }

    // 步骤2：执行SQL查询
    const char* query = "SELECT * FROM user";
    if (mysql_query(conn, query) != 0) {
        std::cerr << "Failed to execute SQL query." << std::endl;
        mysql_close(conn);
        return -1;
    }

    MYSQL_RES* result = mysql_store_result(conn);
    if (result == NULL) {
        std::cerr << "Failed to store MySQL result." << std::endl;
        mysql_close(conn);
        return -1;
    }

    // 处理查询结果
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(result)) != NULL) {
        // 处理每一行的数据
        std::cout << "Column 1: " << row[0] << ", Column 2: " << row[1] << std::endl;
    }

    // 释放查询结果
    mysql_free_result(result);

    // 步骤3：断开数据库连接
    mysql_close(conn);

    return 0;
}

2.将上述API查询封装到类里，调用自己的函数查询

上面的代码主要是用到了mysql_init,mysql_real_connect,mysql_query,mysql_store_result,mysql_free_result,mysql_close这些mysql.h里声明的一些函数。如果我们想用这些函数进行对MYSQL数据库内数据的操作，用的是MYSQL*类型的指针conn进行操作。

  1. 首先，MYSQL* conn = mysql_init(NULL);也即真正malloc了一个空间，分配和初始化了一个 MYSQL 结构体实例，并返回指向该实例的指针conn。这个实例用于存储数据库连接所需的所有信息。
  2. mysql_real_connect 函数建立实际的数据库连接，并使用 MYSQL 结构体来保存连接的详细信息。
  3. 之后，无论是查询（mysql_query）、获取结果（mysql_store_result）还是关闭连接（mysql_close），都需要使用这个 MYSQL* 类型的指针。这是因为所有这些操作都是在特定的数据库连接会话上执行的，而 conn 指针正是指向这个会话的。

那么，在此基础之上，我们可以将这些函数进一步的封装，用一个类中的成员函数去分别调用它们。具体而言，我们自己定义一个Connection类，里面放一个私有成员对象MYSQL* _conn指针，以及构造、析构、连接、更新、查询函数，而这些函数又分别调用了初始的mysql_init,mysql_real_connect,mysql_query,mysql_store_result,mysql_free_result,mysql_close这些mysql.h里声明的一些函数，调用的参数是初始函数所需的参数加上conn指针。在我们自己实现的函数里，还可以额外加一些LOG语句。当我们对这个类进行实例化的时候，用类实例.成员函数()就可以真正对数据库进行增删改查。

代码分为4个文件，Connection.h、Connection.cpp、main.cpp，以及最简单的日志打印（仅仅使用了一个宏，而未用到任何日志库。）里面把之前的store换成了use，这样可以减轻内存的使用，直接按行输出而不用保存。

Connection.cpp:

// 实现对数据库的增删改查
#pragma once
#include <iostream>
#include "Connection.h"
#include "public.h"


//构造函数    mysql_init 函数用于初始化一个新的 MYSQL 结构体实例。这是建立数据库连接之前的准备步骤。
//分配并初始化一个新的 MYSQL 结构体，返回一个指向这个新结构体的指针；如果分配失败，返回 NULL。
Connection::Connection() {
	_conn = mysql_init(nullptr);
}

//真正的连接
bool Connection::connect(string ip, string user, string password, string dbname, unsigned short port) {
	MYSQL* p = mysql_real_connect(_conn,ip.c_str(), user.c_str(), password.c_str(), dbname.c_str(), port, nullptr, 0);//.c_str() :将string转换为 const char* 类型
	return p != nullptr;
}

//增删改，只要返回bool的一些操作
bool Connection::update(string sql) {
	if (mysql_query(_conn, sql.c_str())) {//当 mysql_query() 返回 0 时，表示查询语句成功执行
		LOG("更新失败：" + sql);
		return false;
	}
	return true;
}

//查并返回结果，实际上就是存
MYSQL_RES* Connection::query(string sql) {
	if (mysql_query(_conn, sql.c_str())) {
		LOG("查询失败：" + sql);
		return nullptr;
	}
	return mysql_use_result(_conn);
}

//析构函数（关闭连接）
Connection::~Connection() {
	if (_conn != nullptr)
		mysql_close(_conn);
}

Connection.h:

// 实现对数据库的增删改查
#pragma once
#include <mysql.h>
#include <string>
using namespace std;

class Connection {
public:
	Connection();
	~Connection();	//析构函数（关闭连接）
	bool connect(string ip, string user, string password, string dbname, unsigned short port);	//真正的连接
	bool update(string sql);	//增删改，只要返回bool的一些操作
	MYSQL_RES* query(string sql);	//查并返回结果，实际上就是存

private:
	MYSQL* _conn;
};

public.h:

#pragma once
#define LOG(str)\
	cout<<__FILE__<<":"<<__LINE__<<" "<<__TIMESTAMP__<<":"<<str<<endl;

main:

#include "Connection.h"

int main() {
	Connection conn;
	conn.connect("localhost", "root", "password", "chat", 3306);

	string sql = "insert into user (name, age, sex) values ('zhang san' ,18, 'male');";
	conn.update(sql);
//这里没有测试query
	return 0;
}

在这里插入图片描述
可以发现原本chat database里面user表里没有数据的，执行了该程序之后成功插入了一行数据。并且，id一开始设置成了自增字段，就没有手动指定，只插入了(name, age, sex)，它会自动从1开始填。

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

iOS 接入firebase消息推送

iOS 接入firebase消息推送

前言 APP推送消息和很正常&#xff0c;这就像你谈女朋友一样&#xff0c;如果你经常沉默等着她来找你&#xff0c;那肯定不行&#xff0c;你需要主动一下。APP也是一样&#xff0c;你下载了APP但是你不经常用它&#xff0c;那么他想要让你关注她&#xff0c;自然就要主动推送消…
阅读更多...
1.4~1.5链表复习，代码操作（反转链表（用栈解决，双指针），删除链表指定元素），链表选择题，广义表

1.4~1.5链表复习，代码操作（反转链表（用栈解决，双指针），删除链表指定元素），链表选择题，广义表

删除链表内指定范围的数 思路是双指针&#xff0c;定义两个指针&#xff0c;一个去找当前这个数满不满足要求&#xff0c;然后另一个定义为删除区间的起点 &#xff0c; 当不满足时&#xff0c;两个指针同时向后移动&#xff1b;当满足时&#xff0c;前驱指针就不动了&#xf…
阅读更多...
强烈推荐！这8款在线画图工具好用极了

强烈推荐！这8款在线画图工具好用极了

即时设计 即时设计作为一种简单的绘图工具&#xff0c;为创作者提供了一个方便而强大的创作平台&#xff0c;具有丰富的绘图工具、实时合作、矢量绘图和组件设计系统等功能。即时设计可以满足不同的创作需求&#xff0c;使创意自由流动。 强大的矢量编辑工具 即时设计提供了…
阅读更多...
Windows 环境多个JDK安装与切换

Windows 环境多个JDK安装与切换

一、下载jdk 去Oracle官网上下载想要安装的jdk版本&#xff0c;https://www.oracle.com/java/technologies/downloads/。 二、安装jdk 双击.exe文件&#xff0c;选择好安装目录进行安装。多个版本的jdk重复这两步操作就好。 三、多版本的jdk都下载安装完成之后&#xff0…
阅读更多...
leetcode贪心(单调递增的数字、监控二叉树)

leetcode贪心(单调递增的数字、监控二叉树)

738.单调递增的数字 给定一个非负整数 N&#xff0c;找出小于或等于 N 的最大的整数&#xff0c;同时这个整数需要满足其各个位数上的数字是单调递增。 &#xff08;当且仅当每个相邻位数上的数字 x 和 y 满足 x < y 时&#xff0c;我们称这个整数是单调递增的。&#xff…
阅读更多...
Kafka与RabbitMQ的区别

Kafka与RabbitMQ的区别

消息队列介绍 消息队列&#xff08;Message Queue&#xff09;是一种在分布式系统中进行异步通信的机制。它允许一个或多个生产者在发送消息时暂时将消息存储在队列中&#xff0c;然后由一个或多个消费者按顺序读取并处理这些消息。 消息队列具有以下特点&#xff1a; 异步通…
阅读更多...
红日靶场之stack远程桌面控制 个人学习）

红日靶场之stack远程桌面控制 个人学习）

我们首先打开webshell工具 然后切换到C盘的www的文件夹下面 然后我们打开MSF工具进行监听 模板 msfconsole 启动MSF工具 然后是 use exploit/multi/handler 使用漏洞辅助模块 set payload windows/meterpreter/reverse_tcp 这是利用漏洞tcp回弹模块 set lhost 192.168.52.…
阅读更多...
Domain Adaptation 相关介绍

Domain Adaptation 相关介绍

1. Transfer Learning Transfer learning 是机器学习的一个分支, 而 Domain adpatation 是 transfer learning 的一个分支. 在 transfer learning 中有两个概念: source domain (源域) 和 target domain (目标域). 源域中往往有丰富的信息, 比如有大量的数据点和其真实的标签;…
阅读更多...
Git命令+github仓库克隆

Git命令+github仓库克隆

Git github Git常用命令 开始 git init #创建仓库 git status #查看仓库的状态 git status -s #简单的查看仓库的状态 git ls-files #查看暂存区的内容 git reflog #查看操作的历史记录 暂存区 git add git add <file&g…
阅读更多...
如何克隆驱动器，不同的操作系统有不同的推荐软件

如何克隆驱动器，不同的操作系统有不同的推荐软件

你需要将Windows或macOS安装迁移到新驱动器吗？你可以使用服务备份文件，也可以创建数据的完整一对一副本。通过克隆你的驱动器，你可以创建一个精确的副本。 一些业务级别的备份服务，如IDrive和Acronis，具有内置的磁盘克隆功能，是对正常文件备份的补充。但对于一次性克隆（…
阅读更多...
Python 开源扫雷游戏 PyMine 发布介绍视频

Python 开源扫雷游戏 PyMine 发布介绍视频

Python 开源扫雷游戏 PyMine 发布介绍视频 Python 开源扫雷游戏 PyMine 是笔者开发的基于 wxPython 的 Python 扫雷游戏&#xff0c;现已发布介绍视频。视频请见&#xff1a;https://www.bilibili.com/video/BV1aW4y1N7Dd/ PyMine 比较忠实的还原了微软的扫雷游戏。在算法设计…
阅读更多...
【UE Niagara学习笔记】03 - 火焰喷射效果

【UE Niagara学习笔记】03 - 火焰喷射效果

目录 效果 步骤 一、创建粒子系统 二、制作火焰动画 三、改为GPU粒子 四、循环播放粒子动画 五、火焰喷射效果雏形 六、火焰颜色 效果 步骤 一、创建粒子系统 1. 新建一个Niagara系统&#xff0c;选择模板 命名为“NS_Flame_Thrower”&#xff08;火焰喷射&#…
阅读更多...
Windows 双网卡链路聚合解决方案

Windows 双网卡链路聚合解决方案

Windows 双网卡链路聚合解决方案 链路聚合方案1&#xff1a;Metric介绍操作 方案2&#xff1a;NetSwitchTeam介绍操作 方案3&#xff1a;NIC介绍操作 方案4&#xff1a;Intel PROSet 链路聚合 指将多个物理端口汇聚在一起&#xff0c;形成一个逻辑端口&#xff0c;以实现出/入…
阅读更多...
多级缓存、OpenResty缓存、Redis分布式缓存、进程缓存

多级缓存、OpenResty缓存、Redis分布式缓存、进程缓存

目录标题 一、预期表现二、环境配置1、nginx环境2、OpenResty环境3、redis环境3.1 安装redis3.2 配置启动命令3.3 配置主从3.4 哨兵 4、进程缓存环境 三 、主要编码工作3.1、缓存主要问题解决3.1.1 缓存穿透3.1.2 缓存雪崩3.1.3 缓存击穿 3.2、OpenResty编码3.2.1 openresty/ng…
阅读更多...
JavaWeb——后端AOP面向特定方法编程

JavaWeb——后端AOP面向特定方法编程

七、AOP 1. 概述 AOP&#xff08;Aspect Oriented Programming&#xff09;&#xff1a;面向切面编程、面向方法编程&#xff0c;其实就是面向特定方法编程 场景&#xff1a; 案例部分功能运行较慢&#xff0c;定位执行耗时较长的业务方法&#xff0c;此时需要统计每个业务…
阅读更多...
了解ASP.NET Core 中的文件提供程序

了解ASP.NET Core 中的文件提供程序

写在前面 ASP.NET Core 通过文件提供程序来抽象化文件系统访问。分为物理文件提供程序(PhysicalFileProvider)和清单嵌入的文件提供程序(ManifestEmbeddedFileProvider)还有复合文件提供程序(CompositeFileProvider )&#xff1b;其中PhysicalFileProvider 提供对物理文件系统…
阅读更多...
echarts - xAxis.type设置time时该如何使用formatter的分级模板

echarts - xAxis.type设置time时该如何使用formatter的分级模板

echarts 文档中描述了x轴的多种类型 一、type: ‘value’ ‘value’ 数值轴&#xff0c;适用于连续数据。 此时x轴数据是从零开始&#xff0c;有数据大小的区分。 【注意】 因为xAxis.data是为category服务的&#xff0c;所以xAxis.data里面设置的数据无效。 二、type: ‘ca…
阅读更多...
计算机配件杂谈-鼠标

计算机配件杂谈-鼠标

目录 基础知识鼠标的发展鼠标的左右手鼠标的显示样式鼠标的移动和可见性移动可见性 现在的我们的生活工作都基本上离不开电脑了&#xff0c;不管是你平时玩玩游戏&#xff0c;上班工作等等&#xff1b; 今天将关于鼠标的一些小的技巧分享出来&#xff0c;共勉&#xff01; 基础…
阅读更多...
【SPDK】【NoF】使用SPDK实现NVMe over Fabrics Target

【SPDK】【NoF】使用SPDK实现NVMe over Fabrics Target

本文使用两台PC&#xff0c;一台做NVMe over Fabrics Target&#xff08;服务端&#xff09;&#xff0c;一台做NVMe over Fabrics initiator&#xff08;客户端&#xff09;。首先使用SoftRoCE来实现底层的rdma传输&#xff0c;然后使用SPDK来实现NVMe over Fabrics Target。 …
阅读更多...
同一局域网如何共享文件

同一局域网如何共享文件

一、Windows文件共享设置步骤 1.在需要共享文件的电脑上&#xff0c;右击要共享的文件夹&#xff0c;选择“属性” 2.在“共享”选项卡中&#xff0c;点击“高级共享” 3.勾选“共享此文件夹”并设定共享名称&#xff0c;点击“权限”设置具体访问权限。 4.在其他电脑上&#x…
阅读更多...
最新文章

Copyright @ 2022~2023