Files
oceanbase/tools/deploy/mysql_test/t/trx_4.test
2023-11-20 08:32:44 +00:00

110 lines
2.4 KiB
Plaintext

--disable_query_log
set @@session.explicit_defaults_for_timestamp=off;
--enable_query_log
# owner: yuchen.wyc
# owner group: SQL1
# description: OUR GOAL: Make all this simple and effective!
--disable_warnings
drop table if exists t1,t2,t3,t4;
--enable_warnings
connect (conn1,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
connect (conn2,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
connect (conn3,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
connect (conn4,$OBMYSQL_MS0,$OBMYSQL_USR,$OBMYSQL_PWD,test,$OBMYSQL_PORT);
###
# account test
##
create table t1(id int primary key, money1 int, when1 datetime default now());
insert into t1(id,money1) values(1,100);
insert into t1(id,money1) values(2,100);
--replace_column 3 searched
select id,money1,when1 from t1;
--let $user1_ct=query_get_value(select * from t1, when1, 1)
--let $user2_ct=query_get_value(select * from t1, when1, 2)
--echo id1 - 100 id2 + 100
connection conn1;
begin;
update t1 set money1 = money1-100 where id = 1;
update t1 set money1 = money1+100 where id = 2;
commit;
--replace_column 3 searched
select id,money1,when1 from t1;
connection conn2;
--replace_column 3 searched
select id,money1,when1 from t1;
--let $user1_c_2=query_get_value(select * from t1, when1, 1)
--let $user2_c_2=query_get_value(select * from t1, when1, 2)
if($user1_c_2 != $user1_ct)
{
--echo send success
}
if($user2_c_2 != $user2_ct)
{
--echo receive success
}
drop table t1;
###
# account fail test
##
create table t1(id int primary key, money1 int, when1 datetime default now());
insert into t1(id,money1) values(1,100);
insert into t1(id,money1) values(2,100);
--replace_column 3 searched
select id,money1,when1 from t1;
--let $user1_ct=query_get_value(select * from t1, when1, 1)
--let $user2_ct=query_get_value(select * from t1, when1, 2)
--echo id1 - 100 id2 + 100
connection conn1;
begin;
update t1 set money1 = money1-100 where id = 1;
disconnect conn1;
--error 2006
update t1 set money1 = money1+100 where id = 2;
--error 2006
commit;
connection conn2;
--replace_column 3 searched
select id,money1,when1 from t1;
--let $user1_c_2=query_get_value(select * from t1, when1, 1)
--let $user2_c_2=query_get_value(select * from t1, when1, 2)
if($user1_c_2 != $user1_ct)
{
--echo send success
}
if($user1_c_2 == $user1_ct)
{
--echo send failed
}
if($user2_c_2 != $user2_ct)
{
--echo receive success
}
if($user2_c_2 == $user2_ct)
{
--echo receive failed
}
drop table t1;