MySQLPool/main.cpp at main · kyrie2to11/MySQLPool · GitHub

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
#include "./src/conn.h"
#include "./src/connpool.h"
#include <chrono>
using namespace std;

int main() {
    auto start = chrono::high_resolution_clock::now();
    /* single thread test */
    // for (int i = 0; i < 1000; ++i) {
    //     /* don't use sql connection pool */
    //     // Conn conn;
    //     // char sql[1024] = { 0 };
    //     // sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
    //     // conn.connect("127.0.0.1", 3306, "root", "qq105311", "testdb");
    //     // conn.update(sql);

    //     /* use sql connection pool */
    //     ConnPool* cp = ConnPool::getConnPool();
    //     shared_ptr<Conn> sp = cp->getConn();
    //     char sql[1024] = { 0 };
    //     sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
    //     sp->update(sql);
    // }


    /* multi thread test */
    thread t1([](){
        /* use sql connection pool */
        ConnPool* cp = ConnPool::getConnPool();
        for (int i = 0; i < 2500; ++i) {
            /* don't use sql connection pool */
            // Conn conn;
            // char sql[1024] = { 0 };
            // sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            // conn.connect("127.0.0.1", 3306, "root", "qq105311", "testdb");
            // conn.update(sql);

            /* use sql connection pool */
            shared_ptr<Conn> sp = cp->getConn();
            char sql[1024] = { 0 };
            sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            sp->update(sql);
        }
    });
    thread t2([](){
        /* use sql connection pool */
        ConnPool* cp = ConnPool::getConnPool();
        for (int i = 0; i < 2500; ++i) {
            /* don't use sql connection pool */
            // Conn conn;
            // char sql[1024] = { 0 };
            // sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            // conn.connect("127.0.0.1", 3306, "root", "qq105311", "testdb");
            // conn.update(sql);

            /* use sql connection pool */
            shared_ptr<Conn> sp = cp->getConn();
            char sql[1024] = { 0 };
            sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            sp->update(sql);
        }
    });
    thread t3([](){
        /* use sql connection pool */
        ConnPool* cp = ConnPool::getConnPool();
        for (int i = 0; i < 2500; ++i) {
            /* don't use sql connection pool */
            // Conn conn;
            // char sql[1024] = { 0 };
            // sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            // conn.connect("127.0.0.1", 3306, "root", "qq105311", "testdb");
            // conn.update(sql);

            /* use sql connection pool */
            shared_ptr<Conn> sp = cp->getConn();
            char sql[1024] = { 0 };
            sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            sp->update(sql);
        }
    });
    thread t4([](){
        /* use sql connection pool */
        ConnPool* cp = ConnPool::getConnPool();
        for (int i = 0; i < 2500; ++i) {
            /* don't use sql connection pool */
            // Conn conn;
            // char sql[1024] = { 0 };
            // sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            // conn.connect("127.0.0.1", 3306, "root", "qq105311", "testdb");
            // conn.update(sql);

            /* use sql connection pool */
            shared_ptr<Conn> sp = cp->getConn();
            char sql[1024] = { 0 };
            sprintf(sql, "insert into user(username, password) values('%s','%s')", "zephyrus", "qq105311");
            sp->update(sql);
        }
    });

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

    auto end = chrono::high_resolution_clock::now();
    chrono::duration<double, milli> elapsed = end - start;  // 计算时间间隔并转换为毫秒单位
    cout << elapsed.count() << "ms" << endl;

    return 0;
}