From 8e1977685713c68ff483fe02e010deaa685b453a Mon Sep 17 00:00:00 2001
From: Dan Goodliffe <dan@randomdan.homeip.net>
Date: Thu, 22 Jul 2021 23:09:36 +0100
Subject: First cut replicating row updates

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

(limited to 'test')

diff --git a/test/test-e2e.cpp b/test/test-e2e.cpp
index 9394e13..60dca86 100644
--- a/test/test-e2e.cpp
+++ b/test/test-e2e.cpp
@@ -4,10 +4,12 @@
 
 #include "testdb-mysql.h"
 #include "testdb-postgresql.h"
+#include <input/replStream.h>
 #include <output/pq/updateDatabase.h>
 #include <sql/createTestTable.h>
 #include <sql/fillTestTable.h>
 #include <sql/selectTestTable.h>
+#include <thread>
 
 BOOST_AUTO_TEST_CASE(e2e)
 {
@@ -32,4 +34,14 @@ BOOST_AUTO_TEST_CASE(e2e)
 	out.copyTableContent(&mym, "session");
 
 	BOOST_CHECK_EQUAL(MyGrate::sql::selectTestTable::execute(&pqm)->rows(), 1);
+
+	std::thread repl {&MyGrate::EventSourceBase::readEvents, src.get(), std::ref(out)};
+
+	auto upd = mym.prepare("UPDATE session SET session_id = ? WHERE id = ?", 2);
+	upd->execute(std::array<MyGrate::DbValue, 2> {"food", 1});
+
+	sleep(1);
+
+	src->stopEvents();
+	repl.join();
 }
-- 
cgit v1.2.3