easydb

KO | EN

gitlite — search

#python #hacktoberfest #typescript #android #machine-learning #deep-learning #linux #macos #windows #kubernetes #pytorch #mcp #ios #open-source

(★ 8)

一个c++数据库连接池,将c++下的mysql查询变得易用的项目

easydb 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# easydb
一个c++数据库连接池,将c++下的mysql查询变得易用的项目(目前仅支持 windows x64)
如果需要在 win32环境下，请自行替换Mysql文件夹中的文件
开发环境(vs2019 unicode编码)
<br>
2020年4月24日 19:28:33
<br>
后续将继续更新，加入此项目或者有好的建议( qq: 654320149 )
<br>
## 已经有一个简单版本的MYSQL数据库连接池
只需要 db.start()，即可启动数据库连接池
<br>
## 线程自动分配MYSQL数据库连接
直接使用easy_db中的静态查询方法
```c++
/*返回 string*/
static std::string queryStr(const char* sql);

/*返回 boolean*/
static bool queryBoolean(const char* sql);

/*返回 int*/
static int					queryInt(const char* sql);

/*返回 unsigned int*/
static unsigned int			queryUInt(const char* sql);

/*返回 long*/
static long					queryLong(const char* sql);

/*返回 unsigned long*/
static unsigned long		queryULong(const char* sql);

/*返回 long long*/
static long long			queryLLong(const char* sql);

/*返回 unsigned long long*/
static unsigned long long	queryULLong(const char* sql);

/*返回 double*/
static double				queryDouble(const char* sql);

/*返回 long double*/
static long double			queryLDouble(const char* sql);

/*返回 float*/
static float				queryFloat(const char* sql);

/*返回 map*/
static r_map				queryMap(const char* sql);

/*返回 list*/
static r_vec_map			queryList(const char* sql);

static Record				queryMapR(const char* sql);

static std::vector<Record>	queryListR(const char* sql);

/*分页查询*/
static Page					queryPage(int pageNumber, int pageSize, std::string select, std::string sqlExcept);
```

## SQL参数自动构造，使用jdbc类似的问号填充方式
```
std::vector<lpkp::Record> resList = lpkp::easy_db::queryListR("select * from City where CityName = ?", "成都");
```

## 事务支持
直接使用 easy_db::tx( lambda 表达式 ),
在lamdba表达式中的所有sql代码自动嵌套支持事务
示例:

```
lpkp::easy_db::tx( [=]()->int {
			lpkp::easy_db::excute_batch(sqlList);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			return true;
			});
```
后续将支持更多的事务特性

## 数据库表自动映射到Struct代码正在测试中
...
## 将支持更多的主流数据库
...
## 测试demo代码

```c++
#include <iostream>

#include "pool.h"
#include "easy_db.h"

#define PASSWORD ""
using vec_map = std::vector<std::map<std::string, std::string>>;
void fuc(int i)
{
	//线程自动分配数据库连接，可直接使用静态方法查询
	//每个线程查询1000次
	for (size_t i = 0; i < 1000; i++)
	{
		vec_map resList = lpkp::easy_db::queryList("select * from City where CityName = ? and CityNo = ?", "成都", 8);
	}
	std::cout << std::this_thread::get_id() << "  查询1000次结束:" << i << std::endl;
}
//测试
int main()
{
	//创建100个数据库连接
	bool b = lpkp::pool::start("127.0.0.1", 3306, "root", PASSWORD, "test", 10);
	std::cout << (b ? "创建连接成功" : "创建连接失败") << std::endl;

std::vector<lpkp::Record> resList = lpkp::easy_db::queryListR("select * from City where CityName = ?", "成都");

std::cout << "查询条数:" << resList.size() << std::endl;
	std::cout << "开始:" << clock() << std::endl;

std::vector<std::string> sqlList;
	std::string sql = lpkp::easy_db::SQL("insert into City(CityName,CityNo,rd) values(?,?,now())", "上海", 42);
	sqlList.push_back(sql);
	sqlList.push_back(sql);
	sqlList.push_back(sql);
	sqlList.push_back(sql);

std::vector<lpkp::Record> recordList = lpkp::easy_db::queryListR("select * from City where CityName = ?", "上海");

for (auto& r : recordList)
	{
		std::cout << r.getInt("CityNo") << "       " << r.getBoolean("boo") << std::endl;
	}
	//lpkp::easy_db::excute_batch(sqlList);
	//事务处理 直接 使用tx 方法，里面的sql代码会自动执行事务,
	//一行执行失败，所有操作都会回退
	try
	{
		lpkp::easy_db::tx([=]()->int {
			lpkp::easy_db::excute_batch(sqlList);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			lpkp::easy_db::excute("insert into City(CityName,CityNo,rd) values(?,?,now())", "北京", 43);
			return true;
			});
	}
	catch (lpkp::mysql_exception& e)
	{
		std::cout << e.what() << std::endl;
	}

//并发测试
	/*for (size_t i = 0; i < 98; i++)
	{
		std::thread td(fuc, i);
		td.detach();
	}
	for (size_t i = 0; i < 50; i++)
	{
		std::this_thread::sleep_for(std::chrono::seconds(1));
		std::cout << clock() << "毫秒" << std::endl;
	}*/

std::this_thread::sleep_for(std::chrono::seconds(50));

}

```

easydb

easydb 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

easydb

easydb 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README