summaryrefslogtreecommitdiff
path: root/ndb/test/ndbapi/testBasic.cpp
diff options
context:
space:
mode:
authorunknown <tomas@poseidon.(none)>2004-05-26 15:36:55 +0000
committerunknown <tomas@poseidon.(none)>2004-05-26 15:36:55 +0000
commitabee640f44e4475a6b5448f30dcec9bca5455bda (patch)
treed3d9058cf001e85ae696c10f65a429f2115fab0b /ndb/test/ndbapi/testBasic.cpp
parent5e53268b6979066630b76af1e88899014e613be3 (diff)
downloadmariadb-git-abee640f44e4475a6b5448f30dcec9bca5455bda.tar.gz
neww ndb automake
ndb/test/tools/hugoCalculator.cpp: Rename: ndb/test/tools/hugoCalculator/hugoCalculator.cpp -> ndb/test/tools/hugoCalculator.cpp ndb/test/tools/hugoLoad.cpp: Rename: ndb/test/tools/hugoLoad/hugoLoad.cpp -> ndb/test/tools/hugoLoad.cpp ndb/test/tools/hugoFill.cpp: Rename: ndb/test/tools/hugoFill/hugoFill.cpp -> ndb/test/tools/hugoFill.cpp ndb/test/tools/hugoLockRecords.cpp: Rename: ndb/test/tools/hugoLockRecords/hugoLockRecords.cpp -> ndb/test/tools/hugoLockRecords.cpp ndb/test/tools/hugoPkRead.cpp: Rename: ndb/test/tools/hugoPkRead/hugoPkRead.cpp -> ndb/test/tools/hugoPkRead.cpp ndb/test/tools/hugoPkReadRecord.cpp: Rename: ndb/test/tools/hugoPkReadRecord/hugoPkReadRecord.cpp -> ndb/test/tools/hugoPkReadRecord.cpp ndb/test/tools/hugoScanRead.cpp: Rename: ndb/test/tools/hugoScanRead/hugoScanRead.cpp -> ndb/test/tools/hugoScanRead.cpp ndb/test/tools/restart.cpp: Rename: ndb/test/tools/restart/restart.cpp -> ndb/test/tools/restart.cpp ndb/test/ndbapi/TraceNdbApi.cpp: Rename: ndb/test/ndbapi/acid2/TraceNdbApi.cpp -> ndb/test/ndbapi/TraceNdbApi.cpp ndb/test/ndbapi/VerifyNdbApi.cpp: Rename: ndb/test/ndbapi/acid2/VerifyNdbApi.cpp -> ndb/test/ndbapi/VerifyNdbApi.cpp ndb/test/ndbapi/acid.cpp: Rename: ndb/test/ndbapi/acid/acid.cpp -> ndb/test/ndbapi/acid.cpp ndb/test/ndbapi/acid2.cpp: Rename: ndb/test/ndbapi/acid2/acid2.cpp -> ndb/test/ndbapi/acid2.cpp ndb/test/ndbapi/bulk_copy.cpp: Rename: ndb/test/ndbapi/bulk_copy/bulk_copy.cpp -> ndb/test/ndbapi/bulk_copy.cpp ndb/test/ndbapi/celloDb.cpp: Rename: ndb/test/ndbapi/cello-sessionDb/celloDb.cpp -> ndb/test/ndbapi/celloDb.cpp ndb/test/ndbapi/create_all_tabs.cpp: Rename: ndb/test/ndbapi/create_all_tabs/create_all_tabs.cpp -> ndb/test/ndbapi/create_all_tabs.cpp ndb/test/ndbapi/create_tab.cpp: Rename: ndb/test/ndbapi/create_tab/create_tab.cpp -> ndb/test/ndbapi/create_tab.cpp ndb/test/ndbapi/drop_all_tabs.cpp: Rename: ndb/test/ndbapi/drop_all_tabs/drop_all_tabs.cpp -> ndb/test/ndbapi/drop_all_tabs.cpp ndb/test/ndbapi/flexAsynch.cpp: Rename: ndb/test/ndbapi/flexAsynch/flexAsynch.cpp -> ndb/test/ndbapi/flexAsynch.cpp ndb/test/ndbapi/flexBench.cpp: Rename: ndb/test/ndbapi/flexBench/flexBench.cpp -> ndb/test/ndbapi/flexBench.cpp ndb/test/ndbapi/flexHammer.cpp: Rename: ndb/test/ndbapi/flexHammer/flexHammer.cpp -> ndb/test/ndbapi/flexHammer.cpp ndb/test/ndbapi/flexScan.cpp: Rename: ndb/test/ndbapi/flexScan/flexScan.cpp -> ndb/test/ndbapi/flexScan.cpp ndb/test/ndbapi/flexTT.cpp: Rename: ndb/test/ndbapi/flexTT/flexTT.cpp -> ndb/test/ndbapi/flexTT.cpp ndb/test/ndbapi/flexTimedAsynch.cpp: Rename: ndb/test/ndbapi/flexTimedAsynch/flexTimedAsynch.cpp -> ndb/test/ndbapi/flexTimedAsynch.cpp ndb/test/ndbapi/flex_bench_mysql.cpp: Rename: ndb/test/ndbapi/flex_bench_mysql/flex_bench_mysql.cpp -> ndb/test/ndbapi/flex_bench_mysql.cpp ndb/test/ndbapi/index.cpp: Rename: ndb/test/ndbapi/indexTest/index.cpp -> ndb/test/ndbapi/index.cpp ndb/test/ndbapi/asyncGenerator.cpp: Rename: ndb/test/ndbapi/lmc-bench/async-src/generator/asyncGenerator.cpp -> ndb/test/ndbapi/asyncGenerator.cpp ndb/test/ndbapi/index2.cpp: Rename: ndb/test/ndbapi/indexTest2/index2.cpp -> ndb/test/ndbapi/index2.cpp ndb/test/ndbapi/interpreterInTup.cpp: Rename: ndb/test/ndbapi/interpreterInTup/interpreterInTup.cpp -> ndb/test/ndbapi/interpreterInTup.cpp ndb/test/ndbapi/mainAsyncGenerator.cpp: Rename: ndb/test/ndbapi/lmc-bench/async-src/generator/mainAsyncGenerator.cpp -> ndb/test/ndbapi/mainAsyncGenerator.cpp ndb/test/ndbapi/ndb_async1.cpp: Rename: ndb/test/ndbapi/lmc-bench/async-src/user/ndb_async1.cpp -> ndb/test/ndbapi/ndb_async1.cpp ndb/test/ndbapi/ndb_async2.cpp: Rename: ndb/test/ndbapi/lmc-bench/async-src/user/ndb_async2.cpp -> ndb/test/ndbapi/ndb_async2.cpp ndb/test/ndbapi/ndb_user_populate.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_populate.cpp -> ndb/test/ndbapi/ndb_user_populate.cpp ndb/test/ndbapi/ndb_user_transaction.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction.cpp -> ndb/test/ndbapi/ndb_user_transaction.cpp ndb/test/ndbapi/ndb_user_transaction2.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction2.cpp -> ndb/test/ndbapi/ndb_user_transaction2.cpp ndb/test/ndbapi/ndb_user_transaction3.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction3.cpp -> ndb/test/ndbapi/ndb_user_transaction3.cpp ndb/test/ndbapi/userInterface.cpp: Rename: ndb/test/ndbapi/lmc-bench/async-src/user/userInterface.cpp -> ndb/test/ndbapi/userInterface.cpp ndb/test/ndbapi/benchronja.cpp: Rename: ndb/test/ndbapi/ronja/benchronja/benchronja.cpp -> ndb/test/ndbapi/benchronja.cpp ndb/test/ndbapi/ndb_user_transaction4.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction4.cpp -> ndb/test/ndbapi/ndb_user_transaction4.cpp ndb/test/ndbapi/ndb_user_transaction5.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction5.cpp -> ndb/test/ndbapi/ndb_user_transaction5.cpp ndb/test/ndbapi/ndb_user_transaction6.cpp: Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction6.cpp -> ndb/test/ndbapi/ndb_user_transaction6.cpp ndb/test/ndbapi/restarter.cpp: Rename: ndb/test/ndbapi/restarter/restarter.cpp -> ndb/test/ndbapi/restarter.cpp ndb/test/ndbapi/restarter2.cpp: Rename: ndb/test/ndbapi/restarter2/restarter2.cpp -> ndb/test/ndbapi/restarter2.cpp ndb/test/ndbapi/restarts.cpp: Rename: ndb/test/ndbapi/restarts/restarts.cpp -> ndb/test/ndbapi/restarts.cpp ndb/test/ndbapi/InsertRecs.cpp: Rename: ndb/test/ndbapi/telco/InsertRecs.cpp -> ndb/test/ndbapi/InsertRecs.cpp ndb/test/ndbapi/adoInsertRecs.cpp: Rename: ndb/test/ndbapi/telco/adoInsertRecs.cpp -> ndb/test/ndbapi/adoInsertRecs.cpp ndb/test/ndbapi/initronja.cpp: Rename: ndb/test/ndbapi/ronja/initronja/initronja.cpp -> ndb/test/ndbapi/initronja.cpp ndb/test/ndbapi/msa.cpp: Rename: ndb/test/ndbapi/telco/msa.cpp -> ndb/test/ndbapi/msa.cpp ndb/test/ndbapi/testBasic.cpp: Rename: ndb/test/ndbapi/testBasic/testBasic.cpp -> ndb/test/ndbapi/testBasic.cpp ndb/test/ndbapi/testDataBuffers.cpp: Rename: ndb/test/ndbapi/testDataBuffers/testDataBuffers.cpp -> ndb/test/ndbapi/testDataBuffers.cpp ndb/test/ndbapi/testDict.cpp: Rename: ndb/test/ndbapi/testDict/testDict.cpp -> ndb/test/ndbapi/testDict.cpp ndb/test/ndbapi/testGrep.cpp: Rename: ndb/test/ndbapi/testGrep/testGrep.cpp -> ndb/test/ndbapi/testGrep.cpp ndb/test/ndbapi/testGrepVerify.cpp: Rename: ndb/test/ndbapi/testGrep/verify/testGrepVerify.cpp -> ndb/test/ndbapi/testGrepVerify.cpp ndb/test/ndbapi/testIndex.cpp: Rename: ndb/test/ndbapi/testIndex/testIndex.cpp -> ndb/test/ndbapi/testIndex.cpp ndb/test/ndbapi/testInterpreter.cpp: Rename: ndb/test/ndbapi/testInterpreter/testInterpreter.cpp -> ndb/test/ndbapi/testInterpreter.cpp ndb/test/ndbapi/testMgm.cpp: Rename: ndb/test/ndbapi/testMgm/testMgm.cpp -> ndb/test/ndbapi/testMgm.cpp ndb/test/ndbapi/testNdbApi.cpp: Rename: ndb/test/ndbapi/testNdbApi/testNdbApi.cpp -> ndb/test/ndbapi/testNdbApi.cpp ndb/test/ndbapi/testNodeRestart.cpp: Rename: ndb/test/ndbapi/testNodeRestart/testNodeRestart.cpp -> ndb/test/ndbapi/testNodeRestart.cpp ndb/test/ndbapi/testOIBasic.cpp: Rename: ndb/test/ndbapi/testOIBasic/testOIBasic.cpp -> ndb/test/ndbapi/testOIBasic.cpp ndb/test/ndbapi/testOperations.cpp: Rename: ndb/test/ndbapi/testOperations/testOperations.cpp -> ndb/test/ndbapi/testOperations.cpp ndb/test/ndbapi/testOrderedIndex.cpp: Rename: ndb/test/ndbapi/testOrderedIndex/testOrderedIndex.cpp -> ndb/test/ndbapi/testOrderedIndex.cpp ndb/test/ndbapi/testRestartGci.cpp: Rename: ndb/test/ndbapi/testRestartGci/testRestartGci.cpp -> ndb/test/ndbapi/testRestartGci.cpp ndb/test/ndbapi/testScan.cpp: Rename: ndb/test/ndbapi/testScan/testScan.cpp -> ndb/test/ndbapi/testScan.cpp ndb/test/ndbapi/testScanInterpreter.cpp: Rename: ndb/test/ndbapi/testScanInterpreter/testScanInterpreter.cpp -> ndb/test/ndbapi/testScanInterpreter.cpp ndb/test/ndbapi/testSystemRestart.cpp: Rename: ndb/test/ndbapi/testSystemRestart/testSystemRestart.cpp -> ndb/test/ndbapi/testSystemRestart.cpp ndb/test/ndbapi/testTimeout.cpp: Rename: ndb/test/ndbapi/testTimeout/testTimeout.cpp -> ndb/test/ndbapi/testTimeout.cpp ndb/test/ndbapi/cdrserver.cpp: Rename: ndb/test/ndbapi/vw_test/cdrserver.cpp -> ndb/test/ndbapi/cdrserver.cpp ndb/test/ndbapi/size.cpp: Rename: ndb/test/ndbapi/vw_test/size.cpp -> ndb/test/ndbapi/size.cpp ndb/test/ndbapi/testTransactions.cpp: Rename: ndb/test/ndbapi/testTransactions/testTransactions.cpp -> ndb/test/ndbapi/testTransactions.cpp ndb/test/ndbapi/test_event.cpp: Rename: ndb/test/ndbapi/test_event/test_event.cpp -> ndb/test/ndbapi/test_event.cpp ndb/tools/delete_all.cpp: Rename: ndb/tools/delete_all/delete_all.cpp -> ndb/tools/delete_all.cpp ndb/tools/desc.cpp: Rename: ndb/tools/desc/desc.cpp -> ndb/tools/desc.cpp ndb/tools/drop_index.cpp: Rename: ndb/tools/drop_index/drop_index.cpp -> ndb/tools/drop_index.cpp ndb/tools/drop_tab.cpp: Rename: ndb/tools/drop_tab/drop_tab.cpp -> ndb/tools/drop_tab.cpp ndb/tools/listTables.cpp: Rename: ndb/tools/list_tables/listTables.cpp -> ndb/tools/listTables.cpp ndb/tools/ndbsql.cpp: Rename: ndb/tools/ndbsql/ndbsql.cpp -> ndb/tools/ndbsql.cpp ndb/tools/select_all.cpp: Rename: ndb/tools/select_all/select_all.cpp -> ndb/tools/select_all.cpp ndb/tools/select_count.cpp: Rename: ndb/tools/select_count/select_count.cpp -> ndb/tools/select_count.cpp ndb/test/tools/hugoScanUpdate.cpp: Rename: ndb/test/tools/hugoScanUpd.cpp -> ndb/test/tools/hugoScanUpdate.cpp ndb/test/tools/hugoPkUpdate.cpp: Rename: ndb/test/tools/hugoPkUpd.cpp -> ndb/test/tools/hugoPkUpdate.cpp ndb/test/tools/hugoPkDelete.cpp: Rename: ndb/test/tools/hugoPkDel.cpp -> ndb/test/tools/hugoPkDelete.cpp ndb/tools/Makefile_old: Rename: ndb/tools/Makefile -> ndb/tools/Makefile_old ndb/test/tools/transproxy.cpp: Rename: ndb/tools/transproxy.cpp -> ndb/test/tools/transproxy.cpp ndb/test/tools/verify_index.cpp: Rename: ndb/tools/verify_index.cpp -> ndb/test/tools/verify_index.cpp ndb/test/tools/copy_tab.cpp: Rename: ndb/tools/copy_tab.cpp -> ndb/test/tools/copy_tab.cpp ndb/test/tools/cpcc.cpp: Rename: ndb/tools/cpcc.cpp -> ndb/test/tools/cpcc.cpp ndb/test/tools/create_index.cpp: Rename: ndb/tools/create_index.cpp -> ndb/test/tools/create_index.cpp ndb/test/tools/old_dirs/waiter/Makefile_old: mvdir ndb/test/tools/old_dirs/waiter/waiter.cpp: mvdir ndb/test/tools/old_dirs/restart/Makefile: mvdir ndb/test/tools/old_dirs/hugoScanUpdate/Makefile: mvdir ndb/test/tools/old_dirs/hugoScanRead/Makefile: mvdir ndb/test/tools/old_dirs/hugoPkUpdate/Makefile: mvdir ndb/test/tools/old_dirs/hugoPkReadRecord/Makefile: mvdir ndb/test/tools/old_dirs/hugoPkRead/Makefile: mvdir ndb/test/tools/old_dirs/hugoPkDelete/Makefile: mvdir ndb/test/tools/old_dirs/hugoLockRecords/Makefile: mvdir ndb/test/tools/old_dirs/hugoLoad/Makefile: mvdir ndb/test/tools/old_dirs/hugoFill/Makefile: mvdir ndb/test/tools/old_dirs/hugoCalculator/Makefile: mvdir ndb/tools/old_dirs/copy_tab/Makefile: mvdir ndb/tools/old_dirs/cpcc/Makefile: mvdir ndb/tools/old_dirs/create_index/Makefile: mvdir ndb/tools/old_dirs/delete_all/Makefile: mvdir ndb/tools/old_dirs/desc/Makefile: mvdir ndb/tools/old_dirs/drop_index/Makefile: mvdir ndb/tools/old_dirs/drop_tab/Makefile: mvdir ndb/tools/old_dirs/list_tables/Makefile: mvdir ndb/tools/old_dirs/select_all/Makefile: mvdir ndb/tools/old_dirs/select_count/Makefile: mvdir ndb/test/tools/old_dirs/transproxy/Makefile: mvdir ndb/test/tools/old_dirs/verify_index/Makefile: mvdir ndb/test/ndbapi/old_dirs/flexTT/Makefile: mvdir ndb/test/ndbapi/old_dirs/flexTimedAsynch/Makefile: mvdir ndb/test/ndbapi/old_dirs/flexHammer/Makefile: mvdir ndb/test/ndbapi/old_dirs/flexHammer/README: mvdir ndb/test/ndbapi/old_dirs/flexBench/Makefile.am: mvdir ndb/test/ndbapi/old_dirs/flexBench/Makefile_old: mvdir ndb/test/ndbapi/old_dirs/flexBench/ndbplot.pl: mvdir ndb/test/ndbapi/old_dirs/flexAsynch/Makefile: mvdir ndb/test/ndbapi/old_dirs/drop_all_tabs/Makefile: mvdir ndb/test/ndbapi/old_dirs/create_tab/Makefile: mvdir ndb/test/ndbapi/old_dirs/testOIBasic/Makefile: mvdir ndb/test/ndbapi/old_dirs/testOIBasic/times.txt: mvdir ndb/test/ndbapi/old_dirs/testNodeRestart/Makefile: mvdir ndb/test/ndbapi/old_dirs/testOperations/Makefile: mvdir ndb/test/ndbapi/old_dirs/testBlobs/Makefile: mvdir ndb/test/ndbapi/old_dirs/testBackup/Makefile: mvdir ndb/test/ndbapi/old_dirs/testDict/Makefile: mvdir ndb/test/ndbapi/old_dirs/test_event/Makefile: mvdir ndb/test/ndbapi/old_dirs/testTransactions/Makefile: mvdir ndb/test/ndbapi/old_dirs/testTimeout/Makefile: mvdir ndb/test/ndbapi/old_dirs/testSystemRestart/Makefile: mvdir ndb/test/ndbapi/old_dirs/testScanInterpreter/Makefile: mvdir ndb/test/ndbapi/old_dirs/testDataBuffers/Makefile: mvdir ndb/test/ndbapi/old_dirs/testIndex/Makefile: mvdir ndb/test/ndbapi/old_dirs/testMgm/Makefile: mvdir ndb/test/ndbapi/old_dirs/restarter/Makefile: mvdir ndb/test/ndbapi/old_dirs/flexScan/Makefile: mvdir ndb/test/ndbapi/old_dirs/flexScan/README: mvdir ndb/test/ndbapi/old_dirs/testRestartGci/Makefile: mvdir ndb/test/ndbapi/old_dirs/flex_bench_mysql/Makefile: mvdir ndb/test/ndbapi/old_dirs/indexTest/Makefile: mvdir ndb/test/ndbapi/old_dirs/indexTest2/Makefile: mvdir ndb/test/ndbapi/old_dirs/testBasic/Makefile: mvdir ndb/test/ndbapi/old_dirs/basicAsynch/Makefile: mvdir ndb/test/ndbapi/old_dirs/create_all_tabs/Makefile: mvdir ndb/test/ndbapi/old_dirs/testNdbApi/Makefile: mvdir ndb/test/ndbapi/old_dirs/testOrderedIndex/Makefile: mvdir ndb/test/ndbapi/old_dirs/restarter2/Makefile: mvdir ndb/test/ndbapi/old_dirs/telco/Makefile: mvdir ndb/test/ndbapi/old_dirs/telco/readme: mvdir ndb/test/ndbapi/old_dirs/acid/Makefile: mvdir ndb/test/ndbapi/old_dirs/acid2/Makefile: mvdir ndb/test/ndbapi/old_dirs/acid2/TraceNdbApi.hpp: mvdir ndb/test/ndbapi/old_dirs/acid2/VerifyNdbApi.hpp: mvdir ndb/test/ndbapi/old_dirs/interpreterInTup/Makefile: mvdir ndb/test/ndbapi/old_dirs/ronja/Makefile: mvdir ndb/test/ndbapi/old_dirs/ronja/benchronja/Makefile: mvdir ndb/test/ndbapi/old_dirs/ronja/initronja/Makefile: mvdir ndb/test/ndbapi/old_dirs/testScan/Makefile: mvdir ndb/test/ndbapi/old_dirs/vw_test/Makefile: mvdir ndb/test/ndbapi/old_dirs/vw_test/bcd.h: mvdir ndb/test/ndbapi/old_dirs/vw_test/utv.h: mvdir ndb/test/ndbapi/old_dirs/vw_test/vcdrfunc.h: mvdir ndb/test/ndbapi/old_dirs/vw_test/script/client_start: mvdir ndb/test/ndbapi/old_dirs/testGrep/Makefile: mvdir ndb/test/ndbapi/old_dirs/testGrep/verify/Makefile: mvdir ndb/test/ndbapi/old_dirs/testInterpreter/Makefile: mvdir ndb/test/ndbapi/old_dirs/restarts/Makefile: mvdir ndb/test/ndbapi/old_dirs/bulk_copy/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/generator/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/include/dbGenerator.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/include/testData.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/include/userInterface.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/user/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/user/macros.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/async-src/user/ndb_error.hpp: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/bin/.empty: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/include/ndb_schema.hpp: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/include/testDefinitions.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/lib/.empty: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/script/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench-l-p10.sh: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench-l.sh: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench-p10.sh: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench.sh: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/README: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/dbGenerator.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/makevars.linux: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/makevars.sparc: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/dbGenerator.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/mainGenerator.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/include/testData.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/include/userInterface.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/dbPopulate.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/dbPopulate.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/mainPopulate.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/localDbPrepare.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/macros.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/ndb_error.hpp: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/Makefile: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/userHandle.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/userInterface.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/userTransaction.c: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/userHandle.h: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/userInterface.cpp: mvdir ndb/test/ndbapi/old_dirs/lmc-bench/src/user/userTransaction.c: mvdir ndb/test/ndbapi/testBasicAsynch.cpp: Change mode to -rw-rw-r-- ndb/tools/old_dirs/ndbnet/Makefile.PL: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Base.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Client.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Command.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Config.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Run.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util.pm: mvdir ndb/tools/old_dirs/ndbnet/ndbnet.pl: mvdir ndb/tools/old_dirs/ndbnet/ndbnetd.pl: mvdir ndb/tools/old_dirs/ndbnet/ndbrun: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Database.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Env.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Node.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/NodeApi.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/NodeDb.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/NodeMgmt.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Server.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/ServerINET.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Net/ServerUNIX.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Base.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Database.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Env.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Node.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Base.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Dir.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Event.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/File.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/IO.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Lock.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Log.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Socket.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/SocketINET.pm: mvdir ndb/tools/old_dirs/ndbnet/lib/NDB/Util/SocketUNIX.pm: mvdir ndb/tools/old_dirs/ndbsql/Makefile: mvdir ndb/tools/old_dirs/src/counterviewer/CounterViewer.java: mvdir ndb/test/ndbapi/bank/Bank.hpp: mvdir ndb/test/ndbapi/bank/Makefile_old: Rename: ndb/test/ndbapi/bank/Makefile -> ndb/test/ndbapi/bank/Makefile_old ndb/test/ndbapi/bank/old_dirs/bankCreator/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/bankSumAccounts/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/bankMakeGL/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/bankTimer/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/bankValidateAllGLs/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/bankTransactionMaker/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/src/Makefile: mvdir ndb/test/ndbapi/bank/old_dirs/testBank/Makefile: mvdir ndb/test/ndbapi/ScanFilter.hpp: Rename: ndb/test/ndbapi/old_dirs/testScanInterpreter/ScanFilter.hpp -> ndb/test/ndbapi/ScanFilter.hpp ndb/test/ndbapi/ScanInterpretTest.hpp: Rename: ndb/test/ndbapi/old_dirs/testScanInterpreter/ScanInterpretTest.hpp -> ndb/test/ndbapi/ScanInterpretTest.hpp ndb/test/ndbapi/ScanFunctions.hpp: Rename: ndb/test/ndbapi/old_dirs/testScan/ScanFunctions.hpp -> ndb/test/ndbapi/ScanFunctions.hpp
Diffstat (limited to 'ndb/test/ndbapi/testBasic.cpp')
-rw-r--r--ndb/test/ndbapi/testBasic.cpp1265
1 files changed, 1265 insertions, 0 deletions
diff --git a/ndb/test/ndbapi/testBasic.cpp b/ndb/test/ndbapi/testBasic.cpp
new file mode 100644
index 00000000000..64dfe492c2c
--- /dev/null
+++ b/ndb/test/ndbapi/testBasic.cpp
@@ -0,0 +1,1265 @@
+/* Copyright (C) 2003 MySQL AB
+
+ This program is free software; you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation; either version 2 of the License, or
+ (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program; if not, write to the Free Software
+ Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
+
+#include <NDBT_Test.hpp>
+#include <NDBT_ReturnCodes.h>
+#include <HugoTransactions.hpp>
+#include <UtilTransactions.hpp>
+#include <NdbRestarter.hpp>
+
+#define GETNDB(ps) ((NDBT_NdbApiStep*)ps)->getNdb()
+
+
+/**
+ * TODO
+ * dirtyWrite, write, dirtyUpdate
+ * delete should be visible to same transaction
+ *
+ */
+
+int runLoadTable(NDBT_Context* ctx, NDBT_Step* step){
+
+ int records = ctx->getNumRecords();
+ HugoTransactions hugoTrans(*ctx->getTab());
+ if (hugoTrans.loadTable(GETNDB(step), records) != 0){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+int runInsert(NDBT_Context* ctx, NDBT_Step* step){
+
+ int records = ctx->getNumRecords();
+ HugoTransactions hugoTrans(*ctx->getTab());
+ // Insert records, dont allow any
+ // errors(except temporary) while inserting
+ if (hugoTrans.loadTable(GETNDB(step), records, 1, false) != 0){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+int runInsertTwice(NDBT_Context* ctx, NDBT_Step* step){
+
+ int records = ctx->getNumRecords();
+ HugoTransactions hugoTrans(*ctx->getTab());
+ // Insert records, expect primary key violation 630
+ if (hugoTrans.loadTable(GETNDB(step), records, 1, false) != 630){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+int runVerifyInsert(NDBT_Context* ctx, NDBT_Step* step){
+ int records = ctx->getNumRecords();
+
+ HugoTransactions hugoTrans(*ctx->getTab());
+ if (hugoTrans.pkDelRecords(GETNDB(step), records, 1, false) != 0){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+int runInsertUntilStopped(NDBT_Context* ctx, NDBT_Step* step){
+ int records = ctx->getNumRecords();
+ int i = 0;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (ctx->isTestStopped() == false) {
+ g_info << i << ": ";
+ if (hugoTrans.loadTable(GETNDB(step), records) != 0){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+int runClearTable(NDBT_Context* ctx, NDBT_Step* step){
+ int records = ctx->getNumRecords();
+ int batchSize = ctx->getProperty("BatchSize", 1);
+
+ HugoTransactions hugoTrans(*ctx->getTab());
+ if (hugoTrans.pkDelRecords(GETNDB(step), records, batchSize) != 0){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+int runPkDelete(NDBT_Context* ctx, NDBT_Step* step){
+ int loops = ctx->getNumLoops();
+ int records = ctx->getNumRecords();
+
+ int i = 0;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (i<loops) {
+ g_info << i << ": ";
+ if (hugoTrans.pkDelRecords(GETNDB(step), records) != 0){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ // Load table, don't allow any primary key violations
+ if (hugoTrans.loadTable(GETNDB(step), records, 512, false) != 0){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+
+int runPkRead(NDBT_Context* ctx, NDBT_Step* step){
+ int loops = ctx->getNumLoops();
+ int records = ctx->getNumRecords();
+ int batchSize = ctx->getProperty("BatchSize", 1);
+ int i = 0;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (i<loops) {
+ g_info << i << ": ";
+ if (hugoTrans.pkReadRecords(GETNDB(step), records, batchSize) != NDBT_OK){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+int runPkDirtyRead(NDBT_Context* ctx, NDBT_Step* step){
+ int loops = ctx->getNumLoops();
+ int records = ctx->getNumRecords();
+ int batchSize = ctx->getProperty("BatchSize", 1);
+ int i = 0;
+ bool dirty = true;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (i<loops) {
+ g_info << i << ": ";
+ if (hugoTrans.pkReadRecords(GETNDB(step), records,
+ batchSize, dirty) != NDBT_OK){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+int runPkReadUntilStopped(NDBT_Context* ctx, NDBT_Step* step){
+ int records = ctx->getNumRecords();
+ int batchSize = ctx->getProperty("BatchSize", 1);
+ int i = 0;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (ctx->isTestStopped() == false) {
+ g_info << i << ": ";
+ if (hugoTrans.pkReadRecords(GETNDB(step), records, batchSize) != 0){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+int runPkUpdate(NDBT_Context* ctx, NDBT_Step* step){
+ int loops = ctx->getNumLoops();
+ int records = ctx->getNumRecords();
+ int batchSize = ctx->getProperty("BatchSize", 1);
+ int i = 0;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (i<loops) {
+ g_info << "|- " << i << ": ";
+ if (hugoTrans.pkUpdateRecords(GETNDB(step), records, batchSize) != 0){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+int runPkUpdateUntilStopped(NDBT_Context* ctx, NDBT_Step* step){
+ int records = ctx->getNumRecords();
+ int batchSize = ctx->getProperty("BatchSize", 1);
+ int i = 0;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ while (ctx->isTestStopped()) {
+ g_info << i << ": ";
+ if (hugoTrans.pkUpdateRecords(GETNDB(step), records, batchSize) != 0){
+ g_info << endl;
+ return NDBT_FAILED;
+ }
+ i++;
+ }
+ g_info << endl;
+ return NDBT_OK;
+}
+
+int runLocker(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ int records = ctx->getNumRecords();
+ HugoTransactions hugoTrans(*ctx->getTab());
+
+ if (hugoTrans.lockRecords(GETNDB(step), records, 10, 500) != 0){
+ result = NDBT_FAILED;
+ }
+ ctx->stopTest();
+
+ return result;
+}
+
+int
+runInsertOne(NDBT_Context* ctx, NDBT_Step* step){
+
+ if(ctx->getProperty("InsertCommitted", (Uint32)0) != 0){
+ abort();
+ }
+
+ while(ctx->getProperty("Read1Performed", (Uint32)0) == 0){
+ NdbSleep_MilliSleep(20);
+ }
+
+ HugoTransactions hugoTrans(*ctx->getTab());
+
+ if (hugoTrans.loadTable(GETNDB(step), 1, 1) != 0){
+ return NDBT_FAILED;
+ }
+
+ ctx->setProperty("InsertCommitted", 1);
+
+ NdbSleep_SecSleep(2);
+
+ return NDBT_OK;
+}
+
+static
+int
+readOneNoCommit(Ndb* pNdb, NdbConnection* pTrans,
+ const NdbDictionary::Table* tab,NDBT_ResultRow * row){
+
+ NdbOperation * pOp = pTrans->getNdbOperation(tab->getName());
+ if (pOp == NULL){
+ ERR(pTrans->getNdbError());
+ return NDBT_FAILED;
+ }
+
+ HugoTransactions tmp(*tab);
+
+ int check = pOp->readTuple();
+ if( check == -1 ) {
+ ERR(pTrans->getNdbError());
+ return NDBT_FAILED;
+ }
+
+ // Define primary keys
+ for(int a = 0; a<tab->getNoOfColumns(); a++){
+ if (tab->getColumn(a)->getPrimaryKey() == true){
+ if(tmp.equalForAttr(pOp, a, 0) != 0){
+ ERR(pTrans->getNdbError());
+ return NDBT_FAILED;
+ }
+ }
+ }
+
+ // Define attributes to read
+ for(int a = 0; a<tab->getNoOfColumns(); a++){
+ if((row->attributeStore(a) =
+ pOp->getValue(tab->getColumn(a)->getName())) == 0) {
+ ERR(pTrans->getNdbError());
+ return NDBT_FAILED;
+ }
+ }
+
+ check = pTrans->execute(NoCommit);
+ if( check == -1 ) {
+ const NdbError err = pTrans->getNdbError();
+ ERR(err);
+ return err.code;
+ }
+ return NDBT_OK;
+}
+
+int
+runReadOne(NDBT_Context* ctx, NDBT_Step* step){
+
+ Ndb* pNdb = GETNDB(step);
+ const NdbDictionary::Table* tab = ctx->getTab();
+ NDBT_ResultRow row1(*tab);
+ NDBT_ResultRow row2(*tab);
+
+ if(ctx->getProperty("Read1Performed", (Uint32)0) != 0){
+ abort();
+ }
+
+ if(ctx->getProperty("InsertCommitted", (Uint32)0) != 0){
+ abort();
+ }
+
+ NdbConnection * pTrans = pNdb->startTransaction();
+ if (pTrans == NULL) {
+ abort();
+ }
+
+ // Read a record with NoCommit
+ // Since the record isn't inserted yet it wil return 626
+ const int res1 = readOneNoCommit(pNdb, pTrans, tab, &row1);
+ g_info << "|- res1 = " << res1 << endl;
+
+ ctx->setProperty("Read1Performed", 1);
+
+ while(ctx->getProperty("InsertCommitted", (Uint32)0) == 0 &&
+ !ctx->isTestStopped()){
+ g_info << "|- Waiting for insert" << endl;
+ NdbSleep_MilliSleep(20);
+ }
+
+ if(ctx->isTestStopped()){
+ abort();
+ }
+
+ // Now the record should have been inserted
+ // Read it once again in the same transaction
+ // Should also reutrn 626 if reads are consistent
+
+ // NOTE! Currently it's not possible to start a new operation
+ // on a transaction that has returned an error code
+ // This is wat fail in this test
+ // MASV 20030624
+ const int res2 = readOneNoCommit(pNdb, pTrans, tab, &row2);
+
+ pTrans->execute(Commit);
+ pNdb->closeTransaction(pTrans);
+ g_info << "|- res2 = " << res2 << endl;
+
+ if (res2 == 626 && res1 == res2)
+ return NDBT_OK;
+ else
+ return NDBT_FAILED;
+}
+
+int runFillTable(NDBT_Context* ctx, NDBT_Step* step){
+ int batch = 512; //4096;
+ HugoTransactions hugoTrans(*ctx->getTab());
+ if (hugoTrans.fillTable(GETNDB(step), batch ) != 0){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+int runClearTable2(NDBT_Context* ctx, NDBT_Step* step){
+ int records = ctx->getNumRecords();
+
+ UtilTransactions utilTrans(*ctx->getTab());
+ if (utilTrans.clearTable2(GETNDB(step), records, 240) != 0){
+ return NDBT_FAILED;
+ }
+ return NDBT_OK;
+}
+
+#define CHECK(b) if (!(b)) { \
+ ndbout << "ERR: "<< step->getName() \
+ << " failed on line " << __LINE__ << endl; \
+ result = NDBT_FAILED; \
+ break; }
+
+int runNoCommitSleep(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+ int sleepTime = 100; // ms
+ for (int i = 2; i < 8; i++){
+
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ ndbout << i <<": Sleeping for " << sleepTime << " ms" << endl;
+ NdbSleep_MilliSleep(sleepTime);
+
+ // Dont care about result of these ops
+ hugoOps.pkReadRecord(pNdb, 1, true);
+ hugoOps.closeTransaction(pNdb);
+
+ sleepTime = sleepTime *i;
+ }
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCommit626(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Commit transaction
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 626);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Commit transaction
+ // Multiple operations
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 2, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 3, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 626);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCommit630(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Commit transaction
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 630);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCommit_TryCommit626(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Commit transaction, TryCommit
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb, TryCommit) == 626);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Commit transaction, TryCommit
+ // Several operations in one transaction
+ // The insert is OK
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 2, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 3, true) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 4, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb, TryCommit) == 626);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCommit_TryCommit630(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Commit transaction, TryCommit
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb, TryCommit) == 630);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCommit_CommitAsMuchAsPossible626(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Commit transaction, CommitAsMuchAsPossible
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb, CommitAsMuchAsPossible) == 626);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Commit transaction, CommitAsMuchAsPossible
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 2, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 3, true) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 4, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb, CommitAsMuchAsPossible) == 626);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCommit_CommitAsMuchAsPossible630(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Commit transaction, CommitAsMuchAsPossible
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb, CommitAsMuchAsPossible) == 630);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runNoCommit626(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // No commit transaction, readTuple
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, false) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // No commit transaction, readTupleExcluive
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runNoCommit630(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // No commit transaction
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 630);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runNoCommitRollback626(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // No commit transaction, rollback
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // No commit transaction, rollback
+ // Multiple operations
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 2, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 3, true) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 4, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runNoCommitRollback630(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // No commit transaction, rollback
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkInsertRecord(pNdb, 1) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 630);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+
+int runNoCommitAndClose(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Read
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ for (int i = 0; i < 10; i++)
+ CHECK(hugoOps.pkReadRecord(pNdb, i, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Update
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ for (int i = 0; i < 10; i++)
+ CHECK(hugoOps.pkUpdateRecord(pNdb, i) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Delete
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ for (int i = 0; i < 10; i++)
+ CHECK(hugoOps.pkDeleteRecord(pNdb, i) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Try to insert, record should already exist
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ for (int i = 0; i < 10; i++)
+ CHECK(hugoOps.pkInsertRecord(pNdb, i) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 630);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+
+
+int runCheckRollbackDelete(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+
+ // Read value and save it for later
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.saveCopyOfRecord() == NDBT_OK);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Delete record 5
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkDeleteRecord(pNdb, 5) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ // Check record is deleted
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Check record is not deleted
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Check record is back to original value
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.compareRecordToCopy() == NDBT_OK);
+
+
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCheckRollbackUpdate(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+ int numRecords = 5;
+ do{
+
+ // Read value and save it for later
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, false, numRecords) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(0) == NDBT_OK); // Update value 0
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Update record 5
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkUpdateRecord(pNdb, 1, numRecords, 5) == 0);// Updates value 5
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ // Check record is updated
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true, numRecords) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(5) == NDBT_OK); // Updates value 5
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Check record is back to original value
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 1, true, numRecords) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(0) == NDBT_OK); // Updates value 0
+
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCheckRollbackDeleteMultiple(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Read value and save it for later
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, false, 10) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(0) == NDBT_OK);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ Uint32 updatesValue = 0;
+
+ for(Uint32 i = 0; i<1; i++){
+ // Read record 5 - 10
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ for(Uint32 j = 0; j<10; j++){
+ // Update record 5 - 10
+ updatesValue++;
+ CHECK(hugoOps.pkUpdateRecord(pNdb, 5, 10, updatesValue) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(updatesValue) == 0);
+ }
+
+ for(Uint32 j = 0; j<10; j++){
+ // Delete record 5 - 10 times
+ CHECK(hugoOps.pkDeleteRecord(pNdb, 5, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+#if 0
+ // Check records are deleted
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+#endif
+
+ updatesValue++;
+ CHECK(hugoOps.pkInsertRecord(pNdb, 5, 10, updatesValue) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(updatesValue) == 0);
+ }
+
+ CHECK(hugoOps.pkDeleteRecord(pNdb, 5, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ // Check records are deleted
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 626);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+ }
+
+ // Check records are not deleted
+ // after rollback
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.verifyUpdatesValue(0) == NDBT_OK);
+
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+
+int runCheckImplicitRollbackDelete(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Read record 5
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Update record 5
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkUpdateRecord(pNdb, 5) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Delete record 5
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkDeleteRecord(pNdb, 5) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Check record is not deleted
+ // Close transaction should have rollbacked
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runCheckCommitDelete(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Read 10 records
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ // Update 10 records
+ CHECK(hugoOps.pkUpdateRecord(pNdb, 5, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ // Delete 10 records
+ CHECK(hugoOps.pkDeleteRecord(pNdb, 5, 10) == 0);
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Check record's are deleted
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 626);
+
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runRollbackNothing(NDBT_Context* ctx, NDBT_Step* step){
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ do{
+ // Delete record 5 - 15
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkDeleteRecord(pNdb, 5, 10) == 0);
+ // Rollback
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ // Check records are not deleted
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.pkReadRecord(pNdb, 5, true, 10) == 0);
+ CHECK(hugoOps.execute_Commit(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+
+ }while(false);
+
+ hugoOps.closeTransaction(pNdb);
+
+ return result;
+}
+
+int runMassiveRollback(NDBT_Context* ctx, NDBT_Step* step){
+
+ NdbRestarter restarter;
+ const int records = 4 * restarter.getNumDbNodes();
+
+ HugoTransactions hugoTrans(*ctx->getTab());
+ if (hugoTrans.loadTable(GETNDB(step), records) != 0){
+ return NDBT_FAILED;
+ }
+
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ const Uint32 OPS_PER_TRANS = 256;
+ const Uint32 OPS_TOTAL = 4096;
+
+ for(int row = 0; row < records; row++){
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ for(int i = 0; i<OPS_TOTAL; i += OPS_PER_TRANS){
+ for(int j = 0; j<OPS_PER_TRANS; j++){
+ CHECK(hugoOps.pkUpdateRecord(pNdb, row, 1, i) == 0);
+ }
+ g_info << "Performed " << (i+OPS_PER_TRANS) << " updates on row: " << row
+ << endl;
+ if(result != NDBT_OK){
+ break;
+ }
+ CHECK(hugoOps.execute_NoCommit(pNdb) == 0);
+ }
+ if(result != NDBT_OK){
+ break;
+ }
+ g_info << "executeRollback" << endl;
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+ }
+
+ hugoOps.closeTransaction(pNdb);
+ return result;
+}
+
+int
+runMassiveRollback2(NDBT_Context* ctx, NDBT_Step* step){
+
+ HugoTransactions hugoTrans(*ctx->getTab());
+ if (hugoTrans.loadTable(GETNDB(step), 1) != 0){
+ return NDBT_FAILED;
+ }
+
+ int result = NDBT_OK;
+ HugoOperations hugoOps(*ctx->getTab());
+ Ndb* pNdb = GETNDB(step);
+
+ const Uint32 OPS_TOTAL = 4096;
+ const Uint32 LOOPS = 10;
+
+ for(int loop = 0; loop<LOOPS; loop++){
+ CHECK(hugoOps.startTransaction(pNdb) == 0);
+ for(int i = 0; i<OPS_TOTAL-1; i ++){
+ if((i & 1) == 0){
+ CHECK(hugoOps.pkUpdateRecord(pNdb, 0, 1, loop) == 0);
+ } else {
+ CHECK(hugoOps.pkUpdateRecord(pNdb, 1, 1, loop) == 0);
+ }
+ }
+ CHECK(hugoOps.execute_Commit(pNdb) == 626);
+ CHECK(hugoOps.execute_Rollback(pNdb) == 0);
+ CHECK(hugoOps.closeTransaction(pNdb) == 0);
+ }
+
+ hugoOps.closeTransaction(pNdb);
+ return result;
+}
+
+
+NDBT_TESTSUITE(testBasic);
+TESTCASE("PkInsert",
+ "Verify that we can insert and delete from this table using PK"
+ "NOTE! No errors are allowed!" ){
+ INITIALIZER(runInsert);
+ VERIFIER(runVerifyInsert);
+}
+TESTCASE("PkRead",
+ "Verify that we can insert, read and delete from this table using PK"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkRead);
+ FINALIZER(runClearTable);
+}
+TESTCASE("PkDirtyRead",
+ "Verify that we can insert, dirty read and delete from this table using PK"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkDirtyRead);
+ FINALIZER(runClearTable);
+}
+TESTCASE("PkUpdate",
+ "Verify that we can insert, update and delete from this table using PK"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkUpdate);
+ FINALIZER(runClearTable);
+}
+TESTCASE("PkDelete",
+ "Verify that we can delete from this table using PK"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkDelete);
+ FINALIZER(runClearTable);
+}
+TESTCASE("UpdateAndRead",
+ "Verify that we can read and update at the same time"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkRead);
+ STEP(runPkRead);
+ STEP(runPkRead);
+ STEP(runPkUpdate);
+ STEP(runPkUpdate);
+ STEP(runPkUpdate);
+ FINALIZER(runClearTable);
+}
+TESTCASE("PkReadAndLocker",
+ "Verify that we can read although there are "\
+ " a number of 1 second locks in the table"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkReadUntilStopped);
+ STEP(runLocker);
+ FINALIZER(runClearTable);
+}
+TESTCASE("PkReadAndLocker2",
+ "Verify that we can read and update although there are "\
+ " a number of 1 second locks in the table"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runLocker);
+ FINALIZER(runClearTable);
+}
+TESTCASE("PkReadUpdateAndLocker",
+ "Verify that we can read and update although there are "\
+ " a number of 1 second locks in the table"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkUpdateUntilStopped);
+ STEP(runPkUpdateUntilStopped);
+ STEP(runLocker);
+ FINALIZER(runClearTable);
+}
+TESTCASE("ReadWithLocksAndInserts",
+ "TR457: This test is added to verify that an insert of a records "\
+ "that is already in the database does not delete the record"){
+ INITIALIZER(runLoadTable);
+ STEP(runPkReadUntilStopped);
+ STEP(runPkReadUntilStopped);
+ STEP(runLocker);
+ STEP(runInsertUntilStopped);
+ FINALIZER(runClearTable);
+}
+TESTCASE("ReadConsistency",
+ "Check that a read within a transaction returns the " \
+ "same result no matter"){
+ STEP(runInsertOne);
+ STEP(runReadOne);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("PkInsertTwice",
+ "Verify that we can't insert an already inserted record."
+ "Error should be returned" ){
+ INITIALIZER(runLoadTable);
+ STEP(runInsertTwice);
+ FINALIZER(runClearTable);
+}
+TESTCASE("Fill",
+ "Verify what happens when we fill the db" ){
+ INITIALIZER(runFillTable);
+ INITIALIZER(runPkRead);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("NoCommitSleep",
+ "Verify what happens when a NoCommit transaction is aborted by "
+ "NDB because the application is sleeping" ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runNoCommitSleep);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("Commit626",
+ "Verify what happens when a Commit transaction is aborted by "
+ "NDB because the record does no exist" ){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runCommit626);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("CommitTry626",
+ "Verify what happens when a Commit(TryCommit) \n"
+ "transaction is aborted by "
+ "NDB because the record does no exist" ){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runCommit_TryCommit626);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("CommitAsMuch626",
+ "Verify what happens when a Commit(CommitAsMuchAsPossible) \n"
+ "transaction is aborted by\n"
+ "NDB because the record does no exist" ){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runCommit_CommitAsMuchAsPossible626);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("NoCommit626",
+ "Verify what happens when a NoCommit transaction is aborted by "
+ "NDB because the record does no exist" ){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runNoCommit626);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("NoCommitRollback626",
+ "Verify what happens when a NoCommit transaction is aborted by "
+ "NDB because the record does no exist and then we try to rollback\n"
+ "the transaction" ){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runNoCommitRollback626);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("Commit630",
+ "Verify what happens when a Commit transaction is aborted by "
+ "NDB because the record already exist" ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCommit630);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("CommitTry630",
+ "Verify what happens when a Commit(TryCommit) \n"
+ "transaction is aborted by "
+ "NDB because the record already exist" ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCommit_TryCommit630);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("CommitAsMuch630",
+ "Verify what happens when a Commit(CommitAsMuchAsPossible) \n"
+ "transaction is aborted by\n"
+ "NDB because the record already exist" ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCommit_CommitAsMuchAsPossible630);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("NoCommit630",
+ "Verify what happens when a NoCommit transaction is aborted by "
+ "NDB because the record already exist" ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runNoCommit630);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("NoCommitRollback630",
+ "Verify what happens when a NoCommit transaction is aborted by "
+ "NDB because the record already exist and then we try to rollback\n"
+ "the transaction" ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runNoCommitRollback630);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("NoCommitAndClose",
+ "Verify what happens when a NoCommit transaction is closed "
+ "without rolling back the transaction " ){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runNoCommitAndClose);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("RollbackDelete",
+ "Test rollback of a no committed delete"){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCheckRollbackDelete);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("RollbackUpdate",
+ "Test rollback of a no committed update"){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCheckRollbackUpdate);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("RollbackDeleteMultiple",
+ "Test rollback of 10 non committed delete"){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCheckRollbackDeleteMultiple);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("ImplicitRollbackDelete",
+ "Test close transaction after a no commited delete\n"
+ "this would give an implicit rollback of the delete\n"){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCheckImplicitRollbackDelete);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("CommitDelete",
+ "Test close transaction after a no commited delete\n"
+ "this would give an implicit rollback of the delete\n"){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runCheckCommitDelete);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("RollbackNothing",
+ "Test rollback of nothing"){
+ INITIALIZER(runLoadTable);
+ INITIALIZER(runRollbackNothing);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("MassiveRollback",
+ "Test rollback of 4096 operations"){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runMassiveRollback);
+ FINALIZER(runClearTable2);
+}
+TESTCASE("MassiveRollback2",
+ "Test rollback of 4096 operations"){
+ INITIALIZER(runClearTable2);
+ INITIALIZER(runMassiveRollback2);
+ FINALIZER(runClearTable2);
+}
+NDBT_TESTSUITE_END(testBasic);
+
+int main(int argc, const char** argv){
+ return testBasic.execute(argc, argv);
+}
+
+
+