oceanbase

1
--disable_query_log
2
set @@session.explicit_defaults_for_timestamp=off;
3
--enable_query_log
4
# owner: yuchen.wyc
5
# owner group: SQL1
6
# description: OUR GOAL: Make all this simple and effective!
7
--disable_warnings
8
drop table if exists t1,t2,t3,t4;
9
--enable_warnings
10

11
connect (conn1,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
12
connect (conn2,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
13
connect (conn3,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
14
connect (conn4,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
15

16
###
17
# account test
18
##
19
create table t1(id int primary key, money1 int, when1 datetime default now());
20
insert into t1(id,money1) values(1,100);
21
insert into t1(id,money1) values(2,100);
22
--replace_column 3 searched
23
select id,money1,when1 from t1;
24

25
--let $user1_ct=query_get_value(select * from t1, when1, 1)
26
--let $user2_ct=query_get_value(select * from t1, when1, 2)
27

28
--echo id1 - 100  id2 + 100
29
connection conn1;
30
begin;
31
update t1 set money1 = money1-100 where id = 1;
32
update t1 set money1 = money1+100 where id = 2;
33
commit;
34
--replace_column 3 searched
35
select id,money1,when1 from t1;
36

37
connection conn2;
38
--replace_column 3 searched
39
select id,money1,when1 from t1;
40

41
--let $user1_c_2=query_get_value(select * from t1, when1, 1)
42
--let $user2_c_2=query_get_value(select * from t1, when1, 2)
43

44
if($user1_c_2 != $user1_ct)
45
{
46
    --echo send success
47
}
48

49
if($user2_c_2 != $user2_ct)
50
{
51
    --echo receive success
52
}
53

54
drop table t1;
55

56

57
###
58
# account fail test
59
##
60
create table t1(id int primary key, money1 int, when1 datetime default now());
61
insert into t1(id,money1) values(1,100);
62
insert into t1(id,money1) values(2,100);
63
--replace_column 3 searched
64
select id,money1,when1 from t1;
65

66
--let $user1_ct=query_get_value(select * from t1, when1, 1)
67
--let $user2_ct=query_get_value(select * from t1, when1, 2)
68

69
--echo id1 - 100  id2 + 100
70
connection conn1;
71
begin;
72
update t1 set money1 = money1-100 where id = 1;
73
disconnect conn1;
74

75
--error 2006
76
update t1 set money1 = money1+100 where id = 2;
77
--error 2006
78
commit;
79

80
connection conn2;
81
--replace_column 3 searched
82
select id,money1,when1 from t1;
83

84
--let $user1_c_2=query_get_value(select * from t1, when1, 1)
85
--let $user2_c_2=query_get_value(select * from t1, when1, 2)
86

87
if($user1_c_2 != $user1_ct)
88
{
89
    --echo send success
90
}
91
if($user1_c_2 == $user1_ct)
92
{
93
    --echo send failed
94
}
95

96
if($user2_c_2 != $user2_ct)
97
{
98
    --echo receive success
99
}
100
if($user2_c_2 == $user2_ct)
101
{
102
    --echo receive failed
103
}
104

105
drop table t1;
106

107

108

109

110