From fdc6de263a58480519d683e67bb3dfa262d9b230 Mon Sep 17 00:00:00 2001
From: Dan Goodliffe <dan@randomdan.homeip.net>
Date: Thu, 5 Aug 2021 23:30:09 +0100
Subject: Handle gtid and xid transaction events

---
 test/test-e2e.cpp | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 51 insertions(+)

(limited to 'test/test-e2e.cpp')

diff --git a/test/test-e2e.cpp b/test/test-e2e.cpp
index 37fa924..31f3b95 100644
--- a/test/test-e2e.cpp
+++ b/test/test-e2e.cpp
@@ -5,11 +5,19 @@
 #include "semaphore.h"
 #include "testdb-mysql.h"
 #include "testdb-postgresql.h"
+#include <compileTimeFormatter.h>
+#include <dbConn.h>
 #include <input/replStream.h>
 #include <output/pq/updateDatabase.h>
 #include <sql/createTestTable.h>
 #include <sql/fillTestTable.h>
 #include <sql/selectTestTable.h>
+#include <sql/simpleCreate.h>
+#include <sql/simpleDeleteSome.h>
+#include <sql/simpleInsert.h>
+#include <sql/simpleSelectAll.h>
+#include <sql/simpleUpdate.h>
+#include <sql/simpleUpdateAll.h>
 #include <thread>
 
 class TestUpdateDatabase : public MyGrate::Output::Pq::UpdateDatabase {
@@ -76,3 +84,46 @@ BOOST_AUTO_TEST_CASE(e2e, *boost::unit_test::timeout(15))
 	src->stopEvents();
 	repl.join();
 }
+
+BOOST_AUTO_TEST_CASE(txns, *boost::unit_test::timeout(15))
+{
+	const char * const target_schema {"testout"};
+	using namespace MyGrate::Testing;
+	MySQLDB my;
+	PqConnDB pq {ROOT "/db/schema.sql"};
+
+	auto pqm = pq.mock();
+	auto mym = my.mock();
+
+	MyGrate::sql::simpleCreate::execute(&mym);
+
+	TestUpdateDatabase out {pqm.connstr.c_str(),
+			MyGrate::Output::Pq::UpdateDatabase::createNew(&pqm, MySQLDB::SERVER, MySQLDB::USER, MySQLDB::PASSWORD,
+					MySQLDB::PORT, my.mockname.c_str(), 100, target_schema)
+					.source};
+	BOOST_CHECK_EQUAL(out.source, 1);
+	auto src = out.getSource();
+	BOOST_REQUIRE(src);
+
+	out.addTable(&mym, "test");
+
+	std::thread repl {&MyGrate::EventSourceBase::readEvents, src.get(), std::ref(out)};
+	MyGrate::Tx {&mym}([&]() {
+		for (unsigned int x = 0; x < 10; x += 1) {
+			MyGrate::sql::simpleInsert::execute(&mym, MyGrate::scprintf<"some string %?">(x));
+		}
+		MyGrate::sql::simpleUpdateAll::execute(&mym, "Same");
+		MyGrate::sql::simpleDeleteSome::execute(&mym, 5);
+	});
+	out.waitFor(14);
+
+	src->stopEvents();
+	repl.join();
+
+	auto recs = MyGrate::sql::simpleSelectAll::execute(&pqm);
+	BOOST_REQUIRE_EQUAL(recs->rows(), 6);
+	BOOST_CHECK_EQUAL(recs->at(0, 0).get<int>(), 5);
+	BOOST_CHECK_EQUAL(recs->at(5, 0).get<int>(), 10);
+	BOOST_CHECK_EQUAL(recs->at(1, 1).get<std::string_view>(), "Same");
+	BOOST_CHECK_EQUAL(recs->at(3, 1).get<std::string_view>(), "Same");
+}
-- 
cgit v1.2.3