#
# WARNING
# This file must be manually kept synchronized with the content of 
# "oracle.at", "ibmdb2.at", "postgresql.at", etc...
#
AT_BANNER([MySQL])

# check the database "lixa" is available and the user can connect to it
AT_SETUP([MY/0.0/0.0 MySQL availability])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([echo "\q" | mysql -h localhost -u lixa lixa], [0], [ignore], [ignore])
AT_CLEANUP

# check the xa_info parsing function inside liblixamy
AT_SETUP([MY/0.0/0.1 MySQL xa_open_info parsing])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0020 ; lixa_test_exec.sh reset start case0040 0 0], [0], [ignore], [ignore])
AT_CLEANUP

# check the xa_info parsing function inside liblixamy
# the xa_open_info string contains a trailing comma
AT_SETUP([MY/0.0/0.2 MySQL xa_open_info parsing])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0021 ; lixa_test_exec.sh noreset none case0040 0 0], [0], [ignore], [ignore])
AT_CLEANUP

# check the xa_info parsing function inside liblixamy
# the xa_open_info string contains == and ,,
AT_SETUP([MY/0.0/0.3 MySQL xa_open_info parsing])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0022 ; lixa_test_exec.sh noreset none case0040 -6 0], [0], [ignore], [ignore])
AT_CLEANUP

# check the xa_info parsing function inside liblixamy
# the xa_open_info string contains blank and tab
AT_SETUP([MY/0.0/0.4 MySQL xa_open_info parsing])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0023 ; lixa_test_exec.sh noreset none case0040 -6 0], [0], [ignore], [ignore])
AT_CLEANUP

# check the current user has SELECT privilege on table authors
AT_SETUP([MY/0.0/1.0 authors table exists])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([echo "SELECT * FROM authors;" | mysql -h localhost -u lixa lixa], [0], [ignore], [ignore])
AT_CLEANUP

# check the current user has DELETE & INSERT privilege on table authors
AT_SETUP([MY/0.0/1.1 DELETE & INSERT INTO authors])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([echo "DELETE FROM authors;" | mysql -h localhost -u lixa lixa], [0], [ignore], [ignore])
AT_CHECK([echo "INSERT INTO authors VALUES(999,'surname','name');" | mysql -h localhost -u lixa lixa], [0], [ignore], [ignore])
AT_CHECK([echo "DELETE FROM authors;" | mysql -h localhost -u lixa lixa], [0], [ignore], [ignore])
AT_CLEANUP

# try one phase commit
AT_SETUP([MY/0.1/0.0 One phase commit])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0020 ; lixa_test_exec.sh noreset none case0041 1 1 0], [0], [ignore], [ignore])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0020 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_CLEANUP

# try two phase commit
AT_SETUP([MY/0.1/0.1 Two phase commit])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 1 0], [0], [ignore], [ignore])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_CLEANUP

# try rollback after prepare
AT_SETUP([MY/0.1/0.2 Rollback after prepare])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/-3
xa_rollback/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 1 -2], [0], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/0.3 Rollback without prepare (one RM)])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0020 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0020 ; lixa_test_exec.sh noreset none case0045], [0], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/0.4 Rollback without prepare (two RMs)])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0025 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_start/0
xa_end/0
xa_rollback/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_start/0
xa_end/0
xa_rollback/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0025 ; lixa_test_exec.sh noreset none case0045], [0], [ignore], [ignore])
AT_CLEANUP


AT_SETUP([MY/0.1/1.0 Crash after connect])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=2 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/1.1 Crash in the middle of xa_open])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=3 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/1.2 Crash in the middle of xa_open (2)])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=4 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/1.3 Crash after xa_open])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=5 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/2.0 Crash in the middle of xa_end])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=11 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/2.1 Automatic recovery])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_rollback/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 1 0], [0], [ignore], [ignore])
AT_CHECK([lixad --config-file=$TESTS_ETC_DIR/lixad_conf.xml --dump=u|tee $TESTS_TMP_FILE1 ; grep 'recovery failed: 1' $TESTS_TMP_FILE1], [1], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/2.2 Crash after end])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=12 ; lixa_test_exec.sh noreset none case0041 1 0 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/2.3 Automatic recovery])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_rollback/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_CHECK([lixad --config-file=$TESTS_ETC_DIR/lixad_conf.xml --dump=u|tee $TESTS_TMP_FILE1 ; grep 'recovery failed: 1' $TESTS_TMP_FILE1], [1], [ignore], [ignore])
AT_CLEANUP

# crash in the middle of prepare
AT_SETUP([MY/0.1/3.0 Crash in the middle of prepare])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=14 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/3.1 Automatic recovery])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_commit/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_CLEANUP

# crash after prepare
AT_SETUP([MY/0.1/4.0 Crash after prepare])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=15 ; lixa_test_exec.sh noreset none case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/4.1 Automatic recovery])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_commit/0
xa_start/0
xa_end/0
xa_prepare/0
xa_commit/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset none case0041 1 0 0], [0], [ignore], [ignore])
AT_CLEANUP

# crash after prepare
AT_SETUP([MY/0.1/5.0 Crash after prepare])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_start/0
xa_end/0
xa_prepare/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; export LIXA_CRASH_POINT=15 ; lixa_test_exec.sh noreset stop case0041 1 1 0], [134], [ignore], [ignore])
AT_CLEANUP

AT_SETUP([MY/0.1/5.1 Manual recovery])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_DATA([monkey1s.conf],
[[# monkey R.M. config
xa_open/0
xa_recover/0
xa_close/0
]])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh reset start lixar -p >$TESTS_TMP_FILE1], [0], [ignore], [ignore])
AT_CHECK([grep '^xid=' $TESTS_TMP_FILE1 | cut -d "'" -f 2 > $TESTS_TMP_FILE2], [0], [ignore], [ignore])
AT_CHECK([export LIXA_PROFILE=CASE_PROF_0024 ; lixa_test_exec.sh noreset stop lixar -p -r -X $TESTS_TMP_FILE2], [0], [ignore], [ignore])
AT_CHECK([echo "SELECT * FROM authors;" | mysql -h localhost -u lixa lixa], [0], [ignore], [ignore])
AT_CLEANUP
#
# WARNING:
# this case test certificate there is a bug in MySQL, it does NOT certificate
# the bug is solved
# It must be executed after $TESTS_TMP_FILE1 has prepared by the previous step
#
AT_SETUP([MY/0.1/5.2 Check MySQL bug n. 12161])
AT_CHECK([if test "$LIXA_CRASH" = "no"; then exit 77; fi])
AT_CHECK([if test "$HAVE_MYSQL" = "no"; then exit 77; fi])
AT_CHECK([grep '^xid=' $TESTS_TMP_FILE1], [1], [ignore], [ignore])
AT_CHECK([echo "SELECT * FROM authors WHERE id = 9;" | mysql -h localhost -u lixa lixa|grep Surname], [1], [ignore], [ignore])
AT_CLEANUP