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/296658.html

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

相关文章

vue3中使用echarts：tooltip的trigger为axis tooltip不显示问题

vue3中使用echarts：tooltip的trigger为axis tooltip不显示问题

vue3中使用echarts时&#xff0c;tooltip的trigger设置为axis时formatter不触发 tooltip: {trigger: "axis",formatter: function (params) {console.log("params", params);},axisPointer: {type: "shadow", // 阴影指示器}, },解决办法&#…
阅读更多...
10分钟设置免费海外远程桌面使用Amazon Lightsail服务的免费套餐轻松搭建远程桌面

10分钟设置免费海外远程桌面使用Amazon Lightsail服务的免费套餐轻松搭建远程桌面

本篇文章授权活动官方亚马逊云科技文章转发、改写权&#xff0c;包括不限于在 亚马逊云科技开发者社区, 知乎&#xff0c;自媒体平台&#xff0c;第三方开发者媒体等亚马逊云科技官方渠道。 目录 前言 使用教程 启动 Amazon Lightsail 实例 配置远程桌面 启动远程桌面 使…
阅读更多...
圆通速递单号查询入口，筛选出指定某天签收的单号

圆通速递单号查询入口，筛选出指定某天签收的单号

随着电商和物流行业的飞速发展&#xff0c;快递单号的管理也成了一个让人头疼的问题。如何快速筛选、整理这些快递单号&#xff0c;成为了提高生活和工作效率的关键。而【快递批量查询高手】的出现&#xff0c;正好可以巧妙的解决上面的问题&#xff0c;下面就来具体看看这款软…
阅读更多...
Docker一键极速安装Nacos，并配置数据库！

Docker一键极速安装Nacos，并配置数据库！

1 部署方式 1.1 DockerHub javaedgeJavaEdgedeMac-mini ~ % docker run --name nacos \ -e MODEstandalone \ -e JVM_XMS128m \ -e JVM_XMX128m \ -e JVM_XMN64m \ -e JVM_MS64m \ -e JVM_MMS64m \ -p 8848:8848 \ -d nacos/nacos-server:v2.2.3 a624c64a1a25ad2d15908a67316d…
阅读更多...
【洛谷千题详解】P5706 【深基2.例8】再分肥宅水

【洛谷千题详解】P5706 【深基2.例8】再分肥宅水

只需要用t/n即可。 AC代码&#xff1a; #include<bits/stdc.h> using namespace std; int main() {float a;int b;cin>>a>>b;double ca/b;printf("%.3f\n",c);cout<<b*2<<endl;return 0; }
阅读更多...
VuePress部署到GitHub Pages

VuePress部署到GitHub Pages

一、git push自动部署 1、创建用于工作流的文件 在项目根目录下创建一个用于 GitHub Actions 的工作流 .yml 文件 name: docson:# 每当 push 到 main 分支时触发部署push:branches: [main]# 手动触发部署workflow_dispatch:jobs:docs:runs-on: ubuntu-lateststeps:- uses: a…
阅读更多...
问题 E: 便利店

问题 E: 便利店

题目描述 天宝来到便利店想买些饮料。便利店有各种型号的瓶装饮料售卖&#xff0c;不同型号的饮料卖不同的价格。1瓶0.25升的卖A元&#xff0c;1瓶0.5升的饮料卖B元&#xff0c;1瓶1升的卖C元&#xff0c;1瓶2升的卖D元。便利店里每种饮料都是无限供应。 天宝要买N升的饮料&a…
阅读更多...
逻辑斯蒂回归

逻辑斯蒂回归

逻辑斯蒂回归简介 逻辑斯蒂回归&#xff08;Logistic Regression&#xff09;是一个非常经典的算法&#xff0c;虽然被称为回归&#xff0c;但其实际上是分类模型&#xff0c;并常用于二分类。因为通过逻辑回归模型&#xff0c;我们得到的计算结果是0-1之间的连续数字&#xff…
阅读更多...
FreeRTOS 实时操作系统第九讲 - 链表 (数据结构)

FreeRTOS 实时操作系统第九讲 - 链表 (数据结构)

一、链表简述 链表是一种物理存储单元上非连续、非顺序的存储结构&#xff0c;数据元素的逻辑顺序是通过链表中的指针链接次序实现的。链表由一系列节点&#xff08;链表中每一个元素称为节点&#xff09;组成&#xff0c;节点可以在运行时动态生成。每个节点包括两个部分&…
阅读更多...
虾皮、Lazada店铺流量怎么提升？自养号优势及测评系统如何搭建？

虾皮、Lazada店铺流量怎么提升？自养号优势及测评系统如何搭建？

虾皮、Lazada是东南亚地区最大的购物平台之一&#xff0c;吸引了大量的买家和卖家。在竞争激烈的虾皮市场上&#xff0c;如何提升店铺的流量成为许多卖家关注的问题。以下是关于如何提升虾皮、Lazada店铺流量的一些建议。 一、店铺流量怎么提升? 首先&#xff0c;进行优质的…
阅读更多...
C#编程-使用集合

C#编程-使用集合

使用集合 您学习了如何使用数组来有效地存储和操作相似类型额数据。但是，以下限制于数组的使用相关联： 您必须在声明时定义数组的大小。您必须编写代码以对数组执行标准操作，如排序。让我们思考一个示例。假设您想要存储在组织工作的五个雇员的姓名。您可以使用以下语句来声…
阅读更多...
java基于ssm的线上选课系统的设计与实现论文

java基于ssm的线上选课系统的设计与实现论文

摘 要 在如今社会上&#xff0c;关于信息上面的处理&#xff0c;没有任何一个企业或者个人会忽视&#xff0c;如何让信息急速传递&#xff0c;并且归档储存查询&#xff0c;采用之前的纸张记录模式已经不符合当前使用要求了。所以&#xff0c;对学生选课信息管理的提升&#x…
阅读更多...
无人直播源码/技术源头开发/直播贴片技术源头

无人直播源码/技术源头开发/直播贴片技术源头

无人直播源码/技术源头开发/直播贴片&#xff0c;无人直播&#xff0c;无人实景直播。动态切片功能&#xff0c;自动回复功能&#xff0c;压低打断主播音&#xff0c;支持短视频各大主流平台开播。 搭建无人直播源码需要以下步骤&#xff1a; 1. 确定直播平台和工具&#xff1…
阅读更多...
基于孔雀优化算法的航线规划

基于孔雀优化算法的航线规划

MATLAB2020a下正常运行 上传明细-CSDN创作中心
阅读更多...
XSKY SDS 产品率先获得 OceanBase V4 新版本认证

XSKY SDS 产品率先获得 OceanBase V4 新版本认证

近日&#xff0c;北京奥星贝斯科技有限公司&#xff08;简称&#xff1a;OceanBase&#xff09;与北京星辰天合科技股份有限公司&#xff08;简称&#xff1a;XSKY 星辰天合&#xff09;顺利完成产品兼容性认证。 XSKY 的高性能全闪存储以及混闪存储&#xff0c;与 OceanBase V…
阅读更多...
大数据平台Bug Bash大扫除最佳实践

大数据平台Bug Bash大扫除最佳实践

一、背景 随着越来越多的"新人"在日常工作以及大促备战中担当大任&#xff0c;我们发现仅了解自身系统业务已不能满足日常系统开发运维需求。为此&#xff0c;大数据平台部门组织了一次Bug Bash活动&#xff0c;既能提升自己对兄弟产品的理解和使用&#xff0c;又能…
阅读更多...
【IPC通信--信号】

【IPC通信--信号】

信号处理函数 • 信号发送函数 – kill(), sigqueue(), raise(), alarm(), setitimer(), pause() &#xff0c; abort() • 信号安装函数 – signal(), sigaction() • 信号集操作函数 – sigemptyset(), sigfillset(), sigaddset(), sigdelset(), sigismember() 信号发送函数—…
阅读更多...
xgboost对密西西比数据集csv文件进行预测

xgboost对密西西比数据集csv文件进行预测

代码&#xff1a; # 导入需要的库 from sklearn.preprocessing import LabelEncoder import matplotlib.pyplot as plt import pandas as pd import xgboost as xgb from sklearn.model_selection import train_test_split from sklearn.metrics import confusion_matrix, cla…
阅读更多...
自定义事件总线

自定义事件总线

文章目录 什么是自定义事件总线具体实现思路分析定义结构实现 on实现 emit实现 off 源码 什么是自定义事件总线 自定义事件总线属于一种观察着模式&#xff0c;其中包括三个角色发布者&#xff08;Publisher&#xff09;&#xff1a;发出事件&#xff08;Event&#xff09;订阅…
阅读更多...
[SwiftUI]工程最低适配iOS13

[SwiftUI]工程最低适配iOS13

问题&#xff1a; 新建工程&#xff0c;选择最低支持iOS13报错&#xff1a; main() is only available in iOS 14.0 or newer Scene is only available in iOS 14.0 or newer WindowGroup is only available in iOS 14.0 or newer 解决&#xff1a; 注释掉上面代码&#x…
阅读更多...
最新文章

Copyright @ 2022~2023