数据库连接池：压力测试

前言

验证数据的插入操作所花费的时间，第一次测试使用普通的数据库访问操作，第二次测试使用带连接池的数据库访问操作，对比两次操作同样数据量所花费的时间。

单线程测试

一、不带连接池

#define _CRT_SECURE_NO_WARNINGS
#include<iostream>
#include "Connection.h"
#include "CommonConnectionPool.h"

using namespace std;

int main(void) {
    

	clock_t begin = clock();
	for (int i = 1; i <= 1000; ++i)
	{
    
		Connection conn;
		char sql[1024] = {
     0 };
		sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
			i, "zhangsan", 20, "male");
		conn.connect("127.0.0.1", 3306, "root", "123456", "chat");
		conn.update(sql);
	}
	clock_t end = clock();

	cout << (end - begin) << "ms" << endl;

	return 0;
}

for循环依次测1000个数据、5000个数据、10000个数据

1.插入1000个数据测试

平均值：11866ms

2.插入5000个数据

平均值：59581ms

3.插入10000个数据

平均值：120634ms

二、带连接池

#define _CRT_SECURE_NO_WARNINGS
#include<iostream>
#include "Connection.h"
#include "CommonConnectionPool.h"

using namespace std;

int main(void) {
    

	clock_t begin = clock();
	ConnectionPool* cp = ConnectionPool::getConnectionPool();
	for (int i = 1; i <= 1000; ++i)
	{
    
		shared_ptr<Connection> sp = cp->getConnection();
		char sql[1024] = {
     0 };
		sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
			i, "zhangsan", 20, "male");

		sp->update(sql);
	}
	clock_t end = clock();

	cout << (end - begin) << "ms" << endl;

	return 0;
}

1.插入1000个数据

取平均值：3226ms

2.插入5000个数据

平均值：17498ms

3.插入10000个数据

平均值：34179ms

对比

四线程测试

一、不带连接池

#define _CRT_SECURE_NO_WARNINGS
#include<iostream>
#include "Connection.h"
#include "CommonConnectionPool.h"

using namespace std;

int main(void) {
    

	Connection conn;
	conn.connect("127.0.0.1", 3306, "root", "123456", "chat");

	clock_t begin = clock();

	thread t1([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 1; i <= 250; ++i)
		{
    
			Connection conn;
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			conn.connect("127.0.0.1", 3306, "root", "123456", "chat");
			conn.update(sql);
		}
		});
	thread t2([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 1; i <= 250; ++i)
		{
    
			Connection conn;
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			conn.connect("127.0.0.1", 3306, "root", "123456", "chat");
			conn.update(sql);
		}
		});
	thread t3([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 1; i <= 250; ++i)
		{
    
			Connection conn;
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			conn.connect("127.0.0.1", 3306, "root", "123456", "chat");
			conn.update(sql);
		}
		});
	thread t4([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 1; i <= 250; ++i)
		{
    
			Connection conn;
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			conn.connect("127.0.0.1", 3306, "root", "123456", "chat");
			conn.update(sql);
		}
		});

	t1.join();
	t2.join();
	t3.join();
	t4.join();

	clock_t end = clock();

	cout << (end - begin) << "ms" << endl;

	return 0;
}

1.插入1000数据

平均值：2882ms

2.插入5000数据

平均值：13465ms

3.插入10000数据

平均：26191ms

二、带连接池

#define _CRT_SECURE_NO_WARNINGS
#include<iostream>
#include "Connection.h"
#include "CommonConnectionPool.h"

using namespace std;

int main(void) {
    

	clock_t begin = clock();

	thread t1([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 1; i <= 250; ++i)
		{
    
			
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			shared_ptr<Connection> sp = cp->getConnection();
			sp->update(sql);
		}
	});
	thread t2([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 251; i <= 500; ++i)
		{
    
			
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			shared_ptr<Connection> sp = cp->getConnection();
			sp->update(sql);
		}
	});
	thread t3([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 501; i <= 750; ++i)
		{
    
			
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			shared_ptr<Connection> sp = cp->getConnection();
			sp->update(sql);
		}
		});
	thread t4([]() {
    
		ConnectionPool* cp = ConnectionPool::getConnectionPool();
		for (int i = 751; i <= 1000; ++i)
		{
    
			
			char sql[1024] = {
     0 };
			sprintf(sql, "insert into user(id, name, age, sex) values(%d, '%s', %d, '%s')",
				i, "zhangsan", 20, "male");
			shared_ptr<Connection> sp = cp->getConnection();
			sp->update(sql);
		}
	});

	t1.join();
	t2.join();
	t3.join();
	t4.join();

	clock_t end = clock();

	cout << (end - begin) << "ms" << endl;

	return 0;
}

1.插入1000数据

平均值：1269ms

2.插入5000数据

平均值：6185ms

3.插入10000数据

平均值：11717ms

对比