• MySQL数据库————数据库与vs的连接

    系列文章目录

    在这里插入图片描述

    文章目录

    前言

    MySQL数据库虽然有他自己的编译器，但是我们在调用数据库的时候，如果每次使用数据库都需要打开数据库编译器，则会增加程序员的工作量，于是我们就可以将我们使用的数据库与编译器连接，这里博主使用的是VS编译器（visual studio 2019），故下面的教程是关于VS与数据库的连接的。

    一.数据库连接前的环境配置

    这里博主用的是微软公司的visual studio2019编译器，以下的连接方式均是在此基础上操作，其他的版本也类似。

    1.创建新项目

    在这里插入图片描述
    创建一个c++空项目（自己命名）,这里的代码是博主自己写的，不需要去敲，后面会提供代码，只需要建立一个空的c++源文件即可;

    2.添加类向导

    ①.在vs右侧的解决方案资源管理器中鼠标右击你创建的项目，找到类向导
    在这里插入图片描述
    ②.点击创建类向导，类向导的名字自己写，不要和你刚刚创建的源文件同名就好。
    在这里插入图片描述
    点击确定，到这里就完成了类向导的创建。

    3.配置资源环境

    在博主的主页中有博主上传的资源，点击打开，可能需要解压，解压过后，打开文件。会出现下面的情况：
    在这里插入图片描述
    找到第一个文件include，复制，右击项目，点击资源管理，然后将include文件放进目录;
    在这里插入图片描述
    在这里插入图片描述
    然后点击项目，找到属性，打开。
    在这里插入图片描述
    然后在目录中找到vc++目录，然后找到在右边的包含目录，在旁边有一个小三角，点击，来到编辑。
    在这里插入图片描述
    然后将include文件包含进去即可。
    然后将资源包中的libmysql.lib文件也放置在同目录下，然后生成解决方案，然后将libmysql.dll文件也放在此目录下。
    然后就完成了配置。配置过后的文件：
    在这里插入图片描述
    到这里环境配置就完成了。

    二、数据库与vs连接的步骤

    1、调用mysql_library_init() 初始化MySQL C API库
    2、调用mysql_init() 获取或初始化MYSQL结构
    3、调用mysql_options() 连接前设置选项
    4、调用mysql_real_connect() 连接到MySQL服务器
    5、调用mysql_real_query() 执行指定长度的SQL语句（嵌入式SQL）
    6、调用mysql_close() 关闭与服务器的连接
    7、调用mysql_library_end() 终止MySQL C API库

    三、代码实现

    1.初始化MySQL C API数据库

    MySQLCAPI::MySQLCAPI()
{
	//1、调用mysql_library_init()	初始化MySQL C API库
	if (mysql_library_init(0, nullptr, nullptr))
	{ //如果初始化MySQL C API库失败则返回非0值，否则成功返回0
		cout << "初始化MySQL C API库失败！" << endl;
		getchar();
		exit(1); //退出程序
	}
	//2、调用mysql_init()	获取或初始化MYSQL结构
	if (mysql_init(&mysql) == nullptr)
	{ //如果获取或初始化MYSQL结构失败则返回null
		cout << "获取或初始化MYSQL结构失败！" << endl;
		getchar();
		exit(1); //退出程序
	}
	//3、调用mysql_options()	连接前设置选项
	if (mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "gbk"))
	{ //连接前设置选项，并设置字符集为"gbk"
		cout << "连接前设置选项失败！" << endl;
		getchar();
		exit(1); //退出程序
	}
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24

    2.数据库连接函数

    bool MySQLCAPI::OpenConnect(const char* host, const char* username, const char* pwd, const char* db_name, unsigned port)
{
	//4、调用mysql_real_connect()	连接到MySQL服务器
	if (mysql_real_connect(&mysql, host, username, pwd, db_name, port, nullptr, 0) == nullptr)
	{
		cout << "连接到MySQL服务器失败！" << endl;
		//getchar();
		//exit(1); //退出程序
		GetErrorinfo(); //获取错误信息函数
		return false;
	}
	return true;
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13

    3.执行SQl操作

    bool MySQLCAPI::ExecuteSQL(const char* sql)
{
	//5、调用mysql_real_query()	执行指定长度的SQL语句（嵌入式SQL）
	if (mysql_real_query(&mysql, sql, strlen(sql)))
	{
		GetErrorinfo();
		return false;
	}
	return true;
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    4.执行SQL查询

    //执行SQL查询（有结果集返回）
bool MySQLCAPI::QuerySQL(const char* sql, vector<vector<string>>& resultSet)
{
	//① 执行SQL语句
	//5、调用mysql_real_query()	执行指定长度的SQL语句（嵌入式SQL）
	if (mysql_real_query(&mysql, sql, strlen(sql)))
	{
		GetErrorinfo();
		return false;
	}

	//② 接收查询结果集
	MYSQL_RES* result = mysql_store_result(&mysql);
	//定义一个数据库结果集对象来获取查询结果集

//③ 把结果集对象result中的数据放入vector中
	unsigned rows = (unsigned)mysql_num_rows(result);
	//获取结果集对象的行数，也就是记录（元组）的条数
	unsigned fields = (unsigned)mysql_num_fields(result);
	//获取结果集对象的列数，也就是属性（字段）的个数

	MYSQL_ROW row; //定义一个数据库行对象

	while (row = mysql_fetch_row(result))
	{ //循环变量结果集中的每一行
		vector<string> linedata; //定义一个行数组
		for (unsigned i = 0; i < fields; i++)
		{
			if (row[i])
			{
				linedata.push_back(row[i]);
				//数据不为空时，把数据放入临时数组中
			}
			else
			{
				linedata.push_back("");
				//数据为空时，把空字符串放入临时数组中
			}
		}
		resultSet.push_back(linedata);
		//把结果集中的每一行数据放入resultSet中
	}
	mysql_free_result(result); //释放临时结果集
	return true;
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45

    5.关闭数据库连接

    
MySQLCAPI::~MySQLCAPI()
{
	//6、调用mysql_close()	关闭与服务器的连接
	mysql_close(&mysql);
	//7、调用mysql_library_end()	终止MySQL C API库
	mysql_library_end();
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

    四.源代码呈现

    1.类（头文件）

    #pragma once
#include "mysql.h" //包含MySQL数据库功能函数头文件
#pragma comment(lib,"libmysql.lib") //包含MySQL连接静态库
#include 
using std::string;
#include 
using std::vector;

//1、调用mysql_library_init()	初始化MySQL C API库
//2、调用mysql_init()	获取或初始化MYSQL结构
//3、调用mysql_options()	连接前设置选项
//4、调用mysql_real_connect()	连接到MySQL服务器
//5、调用mysql_real_query()	执行指定长度的SQL语句（嵌入式SQL）
//6、调用mysql_close()	关闭与服务器的连接
//7、调用mysql_library_end()	终止MySQL C API库

class MySQLCAPI
{
	MYSQL mysql; //mysql连接变量：用于连接mysql数据库

public:
	MySQLCAPI();
	~MySQLCAPI();

	int errornum; //错误码
	string errorinfo; //错误提示信息

	//数据库连接函数
	bool OpenConnect(const char* host, const char* username, const char* pwd, const char* db_name, unsigned port = 0);

	//获取错误信息函数
	void GetErrorinfo();

	//执行SQL操作（没有结果集返回）
	bool ExecuteSQL(const char* sql);

	//执行SQL查询（有结果集返回）
	bool QuerySQL(const char* sql, vector<vector<string>>& resultSet);
};


    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40

    2.类（cpp文件实现头文件功能）

    #define _CRT_SECURE_NO_WARNINGS 1
#include "MySQLCAPI.h"
#include 
#include 
using namespace std;

MySQLCAPI::MySQLCAPI()
{
	//1、调用mysql_library_init()	初始化MySQL C API库
	if (mysql_library_init(0, nullptr, nullptr))
	{ //如果初始化MySQL C API库失败则返回非0值，否则成功返回0
		cout << "初始化MySQL C API库失败！" << endl;
		getchar();
		exit(1); //退出程序
	}
	//2、调用mysql_init()	获取或初始化MYSQL结构
	if (mysql_init(&mysql) == nullptr)
	{ //如果获取或初始化MYSQL结构失败则返回null
		cout << "获取或初始化MYSQL结构失败！" << endl;
		getchar();
		exit(1); //退出程序
	}
	//3、调用mysql_options()	连接前设置选项
	if (mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "gbk"))
	{ //连接前设置选项，并设置字符集为"gbk"
		cout << "连接前设置选项失败！" << endl;
		getchar();
		exit(1); //退出程序
	}
}


MySQLCAPI::~MySQLCAPI()
{
	//6、调用mysql_close()	关闭与服务器的连接
	mysql_close(&mysql);
	//7、调用mysql_library_end()	终止MySQL C API库
	mysql_library_end();
}

//数据库连接函数
bool MySQLCAPI::OpenConnect(const char* host, const char* username, const char* pwd, const char* db_name, unsigned port)
{
	//4、调用mysql_real_connect()	连接到MySQL服务器
	if (mysql_real_connect(&mysql, host, username, pwd, db_name, port, nullptr, 0) == nullptr)
	{
		cout << "连接到MySQL服务器失败！" << endl;
		//getchar();
		//exit(1); //退出程序
		GetErrorinfo(); //获取错误信息函数
		return false;
	}
	return true;
}

//获取错误信息函数
void MySQLCAPI::GetErrorinfo()
{
	errornum = mysql_errno(&mysql); //获取错误码
	errorinfo = mysql_error(&mysql); //获取错误提示信息

	cout << "\nerror num:" << errornum << "\nerror info:" << errorinfo << endl;
	getchar();
}

//执行SQL操作（没有结果集返回）
bool MySQLCAPI::ExecuteSQL(const char* sql)
{
	//5、调用mysql_real_query()	执行指定长度的SQL语句（嵌入式SQL）
	if (mysql_real_query(&mysql, sql, strlen(sql)))
	{
		GetErrorinfo();
		return false;
	}
	return true;
}

//执行SQL查询（有结果集返回）
bool MySQLCAPI::QuerySQL(const char* sql, vector<vector<string>>& resultSet)
{
	//① 执行SQL语句
	//5、调用mysql_real_query()	执行指定长度的SQL语句（嵌入式SQL）
	if (mysql_real_query(&mysql, sql, strlen(sql)))
	{
		GetErrorinfo();
		return false;
	}

	//② 接收查询结果集
	MYSQL_RES* result = mysql_store_result(&mysql);
	//定义一个数据库结果集对象来获取查询结果集

//③ 把结果集对象result中的数据放入vector中
	unsigned rows = (unsigned)mysql_num_rows(result);
	//获取结果集对象的行数，也就是记录（元组）的条数
	unsigned fields = (unsigned)mysql_num_fields(result);
	//获取结果集对象的列数，也就是属性（字段）的个数

	MYSQL_ROW row; //定义一个数据库行对象

	while (row = mysql_fetch_row(result))
	{ //循环变量结果集中的每一行
		vector<string> linedata; //定义一个行数组
		for (unsigned i = 0; i < fields; i++)
		{
			if (row[i])
			{
				linedata.push_back(row[i]);
				//数据不为空时，把数据放入临时数组中
			}
			else
			{
				linedata.push_back("");
				//数据为空时，把空字符串放入临时数组中
			}
		}
		resultSet.push_back(linedata);
		//把结果集中的每一行数据放入resultSet中
	}
	mysql_free_result(result); //释放临时结果集
	return true;
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 84
    • 85
    • 86
    • 87
    • 88
    • 89
    • 90
    • 91
    • 92
    • 93
    • 94
    • 95
    • 96
    • 97
    • 98
    • 99
    • 100
    • 101
    • 102
    • 103
    • 104
    • 105
    • 106
    • 107
    • 108
    • 109
    • 110
    • 111
    • 112
    • 113
    • 114
    • 115
    • 116
    • 117
    • 118
    • 119
    • 120
    • 121
    • 122

    3.源程序文件

    #include 
#include 
using namespace std;

#include "MySQLCAPI.h" 


void MySQLConnectTest();

int main()
{
	MySQLConnectTest();

	system("pause");
	return 0;
}

void MySQLConnectTest()
{
	MySQLCAPI MySQL_Connect;


	MySQL_Connect.OpenConnect("localhost", "root", "123456", "db_2");


	string sql = "use db_2;";
	vector<vector<string>> data;

	MySQL_Connect.ExecuteSQL(sql.c_str());

	//sql = "insert into db_2.student values(null,\"����\",103,'��',24);";
	//MySQL_Connect.ExecuteSQL(sql.c_str()); 

	sql = "select * from db_2.student;";
	MySQL_Connect.QuerySQL(sql.c_str(), data);

	for (unsigned i = 0; i < data.size(); i++)
	{
		for (unsigned j = 0; j < data[i].size(); j++)
		{
			cout << data[i][j] << '\t';
		}
		cout << endl;
	}
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45

    总结

    数据库与VS的连接类容就到此结束了，我们的数据库知识点也讲解的差不多了，后面就是MySQL数据库的题目讲解了。也会持续更新win32和mfc。如果有需要，可以关注博主一下哦。

  • 相关阅读:
    低学历并不是阻碍职业发展的绊脚石
    Java 1.8引入StringJoiner，用与字符串拼接
    强制删除文件？正确操作方法分享！
    【Linux】关于普通用户无法使用sudo指令的解决方案
    SLAM从入门到精通（3d 点云数据访问）
    【C++】平衡二叉搜索树的模拟实现
    Selenium定位元素
    Java计算机毕业设计 基于SpringBoot+Vue的毕业生信息招聘平台的设计与实现 Java实战项目 附源码+文档+视频讲解
    C语言：单精度(float)和双精度(double)浮点数 与 十六进制(HEX) 之间转换
    交互题入门
  • 原文地址：https://blog.csdn.net/qq_59931372/article/details/126110687