MXS-1507: Test transaction limits
The test cases check that the size limit works and that following transactions work.
This commit is contained in:
@ -18,6 +18,7 @@ servers=server1,server2,server3,server4
|
|||||||
user=maxskysql
|
user=maxskysql
|
||||||
passwd=skysql
|
passwd=skysql
|
||||||
transaction_replay=true
|
transaction_replay=true
|
||||||
|
transaction_replay_max_size=200
|
||||||
|
|
||||||
[RW Split Listener]
|
[RW Split Listener]
|
||||||
type=listener
|
type=listener
|
||||||
|
|||||||
@ -131,7 +131,46 @@ int main(int argc, char** argv)
|
|||||||
bind(ok, "COMMIT"),
|
bind(ok, "COMMIT"),
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"Exceed transaction length limit",
|
||||||
|
{
|
||||||
|
bind(ok, "BEGIN"),
|
||||||
|
bind(ok, "SELECT 'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'"),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
bind(err, "SELECT 7"),
|
||||||
|
bind(err, "COMMIT"),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"Normal trx after hitting limit",
|
||||||
|
{
|
||||||
|
bind(ok, "BEGIN"),
|
||||||
|
bind(ok, "SELECT 'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
|
||||||
|
"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'"),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
bind(err, "SELECT 7"),
|
||||||
|
bind(err, "COMMIT"),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
bind(ok, "BEGIN"),
|
||||||
|
bind(ok, "SELECT 1"),
|
||||||
|
bind(ok, "SELECT 2"),
|
||||||
|
bind(ok, "COMMIT"),
|
||||||
|
}
|
||||||
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
// Create a table for testing
|
// Create a table for testing
|
||||||
|
|||||||
Reference in New Issue
Block a user