oceanbase

1
#--disable_query_log
2
#--disable_result_log
3
connect (obsys_ydm,$OBMYSQL_MS0,admin,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
4
connection obsys_ydm;
5
let $__i__= 600;
6
sleep 3;
7
while($__i__ > 0)
8
{
9
    sleep 1;
10
    dec $__i__;
11
    let $__frozen_scn__ = query_get_value(select /*+query_timeout(100000000)*/sum(frozen_scn/1000) as sum_value from oceanbase.CDB_OB_MAJOR_COMPACTION, sum_value, 1);
12
    let $__merged_version__ = query_get_value(select /*+query_timeout(100000000)*/sum(last_scn/1000) as sum_value from oceanbase.CDB_OB_MAJOR_COMPACTION, sum_value, 1);
13
    #--echo sum_frozen_scn=$__frozen_scn__
14
    #--echo sum_merged_version=$__merged_version__
15
    #--echo remain_time_s=$__i__
16
    #--echo =======================================
17
    # all tenant should major merge complete
18
    if($__frozen_scn__ == $__merged_version__)
19
    {
20
        let $__i__ = -5;
21
    }
22
}
23

24
###判断集群状态，先注释掉
25
#let $__j__= 180;
26
#while($__j__ > 0)
27
#{
28
#    sleep 1;
29
#    dec $__j__;
30
#    let $__global_stat__ = query_get_value(select comment from oceanbase.__all_cluster_stat where name='global_stat',comment, 1);
31
#    if($__global_stat__ == NORMAL)
32
#    {
33
#        let $__j__ = -5;
34
#    }
35
#}
36

37
#if($__j__ != -5)
38
#{
39
#    --echo major freeze failed
40
#}
41

42
if($__i__ != -5)
43
{
44
    --echo major freeze failed
45
    select * from oceanbase.CDB_OB_MAJOR_COMPACTION;
46
    let $__tenant_id__ = query_get_value(select tenant_id from oceanbase.CDB_OB_MAJOR_COMPACTION where last_scn != frozen_scn, tenant_id, 1);
47
    let $__frozen_scn__ = query_get_value(select frozen_scn from oceanbase.CDB_OB_MAJOR_COMPACTION where tenant_id = $__tenant_id__, frozen_scn, 1);
48
    eval select * from oceanbase.__all_virtual_server_compaction_event_history where tenant_id = $__tenant_id__ and compaction_scn = $__frozen_scn__;
49
    select * from oceanbase.__all_virtual_compaction_diagnose_info;
50
}
51
sleep 2;
52

53
disconnect obsys_ydm;
54
connection default;
55
--enable_query_log
56
--enable_result_log
57