^-^
TrinityCore框架_数据库模块单独构建及应用
最近更新：2024-09-23   |   字数总计：1k   |   阅读估时：5分钟   |   阅读量：次
  1. TrinityCore数据库模块单独构建
  2. 同步连接池使用
  3. 异步连接池使用

TrinityCore数据库模块单独构建

  1. 依赖fmt
  2. cmake目录查找MySQL头文件及库文件
  3. 数据库模块的迁移
  4. Errors断言处理
  5. Log日志模块适配
  6. StringFormat格式化字符串（性能优越，线程安全）

同步连接池使用

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
#include "Log.h"
#include "DatabaseEnv.h"
#include "DatabaseLoader.h"
#include "Implementation/SakilaDatabase.h"
#include "MySQLThreading.h"
#include <typeinfo>

int main()
{   
    MySQL::Library_Init();
    DatabaseLoader loader;
    loader.AddDatabase(SakilaDatabase, "localhost;3306;root;;sakila", 8, 2);

    if(!loader.Load()){
        TC_LOG_ERROR("", "SakilaDatabase connect error");
        return 1;
    }
    TC_LOG_INFO("", "SakilaDatabase connect success");

    {
        // 不需要结果的sql
        SakilaDatabase.DirectExecute("insert into actor(first_name, last_name) values ('lin', 'vacation')");
    }

    {
        // 需要结果的sql
        auto result = SakilaDatabase.Query("select actor_id, first_name, last_name, last_update from actor where actor_id = 1");
        if(!result){
            TC_LOG_ERROR("", "select empty");
            return 1;
        }
        TC_LOG_INFO("", "actor_id=%u, first_name=%s, last_name=%s, last_update=%s", 
            (*result)[0].GetUInt8(), (*result)[1].GetString(), (*result)[2].GetString(),(*result)[3].GetString()
        );
    }
    {
        // 使用预处理的sql
        auto *stmt = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO);
        stmt->setInt8(0, 1);
        auto result = SakilaDatabase.Query(stmt);
        TC_LOG_INFO("", "actor_id=%u, first_name=%s, last_name=%s", 
            (*result)[0].GetUInt8(), (*result)[1].GetString(), (*result)[2].GetString()
        );
    }

    {
        // 处理多行结果的sql
        auto result = SakilaDatabase.Query("select actor_id, first_name, last_name, last_update from actor where actor_id >= 0 and actor_id <= 10;");
        if(result){
            do{
                Field *field = result->Fetch();
                TC_LOG_INFO("", "actor_id=%s, first_name=%s, last_name=%s", 
                    field[0].GetString(), field[1].GetString(), field[2].GetString()
                );
            }while(result->NextRow());
        }
    }


    SakilaDatabase.Close();
    MySQL::Library_End();
    return 0;
}

异步连接池使用

  1. 单语句连接池的使用
    1. 简单sql语句
    2. 预处理语句
      1. 创建索引
      2. 初始化预处理语句
      3. 指定同步连接池还是异步连接池的使用
  2. 多语句连接池的使用
    1. chain
      1. 责任链模式
      2. 可打断
    2. delay
      1. 一个包含多个sql语句的容器
      2. 整体执行
      3. 异步获取整体执行的结果
    3. transaction
      1. 构成逻辑整体，失败回滚
      2. 针对写操作，拿不到事务中间语句的处理结果
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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
#include "AsyncCallbackProcessor.h"
#include "DatabaseEnvFwd.h"
#include "Define.h"
#include "Log.h"
#include "DatabaseEnv.h"
#include "DatabaseLoader.h"
#include "Implementation/SakilaDatabase.h"
#include "MySQLThreading.h"
#include "QueryCallback.h"
#include "QueryHolder.h"
#include "Transaction.h"
#include <chrono>
#include <memory>
#include <thread>
#include <typeinfo>

int main()
{
    MySQL::Library_Init();
    DatabaseLoader loader;
    loader.AddDatabase(SakilaDatabase, "localhost;3306;root;;sakila", 8, 2);

    if(!loader.Load()){
        TC_LOG_ERROR("", "SakilaDatabase connect error");
        return 1;
    }
    TC_LOG_INFO("", "SakilaDatabase connect success");

    {
        // 单语句获取结果
        AsyncCallbackProcessor<QueryCallback> processor;

        auto *stmt = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO_ASYNC);
        stmt->setUInt8(0, 1);
        
        processor.AddCallback(SakilaDatabase.AsyncQuery(stmt).WithPreparedCallback([](PreparedQueryResult result){
           TC_LOG_INFO("","actor_id=%u, first_name=%s, last_name=%s",(*result)[0].GetUInt16(),(*result)[1].GetString(),(*result)[2].GetString() );
        }));

        while(true){
            processor.ProcessReadyCallbacks();
            std::this_thread::sleep_for(std::chrono::milliseconds(50));
        }
    }
    {
        // chain
        // AsyncCallbackProcessor<QueryCallback> processor;

        auto *stmt = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO_ASYNC);
        stmt->setUInt8(0, 1);
        processor.AddCallback(SakilaDatabase.AsyncQuery(stmt).WithChainingPreparedCallback([](QueryCallback &callback, PreparedQueryResult result){
            TC_LOG_INFO("","actor_id=%u, first_name=%s, last_name=%s",(*result)[0].GetUInt16(),(*result)[1].GetString(),(*result)[2].GetString() );
            // 再进行下一次query
            auto *stmt2 = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO_ASYNC);
            stmt2->setUInt8(0, 2);
            callback.SetNextQuery(SakilaDatabase.AsyncQuery(stmt2));
        })
            .WithChainingPreparedCallback([](QueryCallback &callback, PreparedQueryResult result){
                // 注意chain的点的位置
                TC_LOG_INFO("","next query :: actor_id=%u, first_name=%s, last_name=%s",(*result)[0].GetUInt16(),(*result)[1].GetString(),(*result)[2].GetString() );
                // 不设置setNextQuery，责任链在这里就终止了
            })
        );
        while(true){
            processor.ProcessReadyCallbacks();
            std::this_thread::sleep_for(std::chrono::milliseconds(50));
        }
    }
    {
        // delay异步获取多个sql的结果 delayholder , 这种方法不保证sql的顺序
        class ActorInfoHolder : public SQLQueryHolder<SakilaDatabaseConnection>
        {
        public:
            enum ACTOR_INFO_IDX : uint8{
                AI_1,
                AI_3,
                AI_5,
                AI_MAX,
            };
            ActorInfoHolder(){
                SetSize(AI_MAX); // 一共有几条sql语句
                auto stmt1 = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO_ASYNC);
                stmt1->setUInt8(0, 1);
                SetPreparedQuery(AI_1, stmt1);

                auto stmt3 = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO_ASYNC);
                stmt3->setUInt8(0, 3);
                SetPreparedQuery(AI_3, stmt3);

                auto stmt5 = SakilaDatabase.GetPreparedStatement(SAKILA_SEL_ACTOR_INFO_ASYNC);
                stmt5->setUInt8(0, 5);
                SetPreparedQuery(AI_5, stmt5);
            }
        };
        AsyncCallbackProcessor<SQLQueryHolderCallback> processor; // 注意和单语句的processor是不一样的
        auto holder = std::make_shared<ActorInfoHolder>();
        processor.AddCallback(SakilaDatabase.DelayQueryHolder(holder)).AfterComplete([](const SQLQueryHolderBase &hdr){
            auto holder = static_cast<const ActorInfoHolder&>(hdr);
            auto result1 = holder.GetPreparedResult(ActorInfoHolder::AI_1);
            auto result3 = holder.GetPreparedResult(ActorInfoHolder::AI_3);
            auto result5 = holder.GetPreparedResult(ActorInfoHolder::AI_5);

            TC_LOG_INFO("","result1 actor_id=%u, first_name=%s, last_name=%s",(*result1)[0].GetUInt16(),(*result1)[1].GetString(),(*result1)[2].GetString() );
            TC_LOG_INFO("","result3 actor_id=%u, first_name=%s, last_name=%s",(*result3)[0].GetUInt16(),(*result3)[1].GetString(),(*result3)[2].GetString() );
            TC_LOG_INFO("","result5 actor_id=%u, first_name=%s, last_name=%s",(*result5)[0].GetUInt16(),(*result5)[1].GetString(),(*result5)[2].GetString() );
        });

        while(true){
            processor.ProcessReadyCallbacks();
            std::this_thread::sleep_for(std::chrono::milliseconds(50));
        }
    }
    {
        // 异步事务
        auto trans = SakilaDatabase.BeginTransaction();
        trans->Append("insert into actor(first_name, last_name) values ('lin','vacation2');");
        trans->Append("insert into actor(first_name, last_name) values ('lin','vacation3');");
        trans->Append("insert into actor(first_name, last_name) values ('lin','vacation4');");
        trans->Append("insert into country(country_id, country) values (1001, 'Thailand');");
        trans->Append("insert into city(city, country_id) values ('Bankok',1001);");
        AsyncCallbackProcessor<TransactionCallback> processor;
        // 注意这里我们只能知道bool值的结果，说明TrinityCore对数据库事务处理的封装是只针对写操作的，是无法取到返回的结果的，这是封装的问题，可能是没有这样的需求？
        processor.AddCallback(SakilaDatabase.AsyncCommitTransaction(trans)).AfterComplete([](bool success){
            if(success){
                TC_LOG_INFO("", "transaction commit success");
            } else {
                TC_LOG_INFO("", "transaction commit fail");
            }
        });
        while(true){
            processor.ProcessReadyCallbacks();
            std::this_thread::sleep_for(std::chrono::milliseconds(50));
        }
    }

    SakilaDatabase.Close();
    MySQL::Library_End();
    return 0;
}
2024-06-10 该篇文章被 Cleofwine 归为分类: Game

上一篇：TrinityCore框架_日志模块功能实现 下一篇：TrinityCore框架_数据库模块实现分析
© 2023-2026 Cleofwine / Email / GitHub / 浙ICP备2024136127号
🌙赠我弯弯一枚月，也赠予我晚星⭐ 本站由Hexo驱动｜使用Hexo-theme-A4主题