diff --git a/clustertest/regression/testtruncate/testtruncate.js b/clustertest/regression/testtruncate/testtruncate.js index 80f6e873..fb05c6eb 100644 --- a/clustertest/regression/testtruncate/testtruncate.js +++ b/clustertest/regression/testtruncate/testtruncate.js @@ -91,25 +91,32 @@ function do_test(coordinator) { run_sample_load(coordinator); - // now, truncate line_items + var TruncateList = ["truncate-basic", "truncate-cascade", "truncate-multiple"]; - // another data load - run_sample_load(coordinator); - - // now, truncate orders with cascade + for (var i=0 ; i < TruncateList.length; i++) { + var sqlScript = coordinator.readFile('regression/testtruncate/' + TruncateList[i] + '.sql'); + psql = coordinator.createPsqlCommand('db1',sqlScript); + psql.run(); + coordinator.join(psql); - // another data load - run_sample_load(coordinator); + run_sample_load(coordinator); + } - // truncate customers, orders, line_items - + // drop test_237 out of replication + var slonikScript = "set drop table (origin=1, id=237);"; + var preamble = get_slonik_preamble(); + run_slonik('Drop test_237 table', coordinator, preamble, slonikScript); - // final data load - run_sample_load(coordinator); + wait_for_sync(coordinator); - // drop test_237 out of replication - // truncate test_237 on both db1 and db2 + var dblist = ["db1", "db2"]; + for (var i=0 ; i < dblist.length; i++) { + var sqlScript = coordinator.readFile('regression/testtruncate/truncate-237.sql'); + psql = coordinator.createPsqlCommand(dblist[i],sqlScript); + psql.run(); + coordinator.join(psql); + } wait_for_sync(coordinator); coordinator.log("done"); diff --git a/clustertest/regression/testtruncate/truncate-237.sql b/clustertest/regression/testtruncate/truncate-237.sql new file mode 100644 index 00000000..55bd3287 --- /dev/null +++ b/clustertest/regression/testtruncate/truncate-237.sql @@ -0,0 +1 @@ +truncate test_237; diff --git a/clustertest/regression/testtruncate/truncate-basic.sql b/clustertest/regression/testtruncate/truncate-basic.sql new file mode 100644 index 00000000..3396ce24 --- /dev/null +++ b/clustertest/regression/testtruncate/truncate-basic.sql @@ -0,0 +1 @@ +truncate line_items; diff --git a/clustertest/regression/testtruncate/truncate-cascade.sql b/clustertest/regression/testtruncate/truncate-cascade.sql new file mode 100644 index 00000000..da2a739e --- /dev/null +++ b/clustertest/regression/testtruncate/truncate-cascade.sql @@ -0,0 +1 @@ +truncate orders with cascade; diff --git a/clustertest/regression/testtruncate/truncate-multiple.sql b/clustertest/regression/testtruncate/truncate-multiple.sql new file mode 100644 index 00000000..062eca05 --- /dev/null +++ b/clustertest/regression/testtruncate/truncate-multiple.sql @@ -0,0 +1 @@ +truncate customers, orders, line_items;