From 51ac5d2007f1caf6bc6e65b485ba896357696654 Mon Sep 17 00:00:00 2001
From: Dan Goodliffe <dan@randomdan.homeip.net>
Date: Sun, 6 Jun 2021 00:59:03 +0100
Subject: Add RecordSet RowView

This represents a view into a recordset by row number and provides easy
access to values in a column by index and the ability to create a new
object instance by N columns which are passed to the object's
constructor.
---
 lib/output/pq/updateDatabase.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

(limited to 'lib/output')

diff --git a/lib/output/pq/updateDatabase.cpp b/lib/output/pq/updateDatabase.cpp
index ebcabb3..352517e 100644
--- a/lib/output/pq/updateDatabase.cpp
+++ b/lib/output/pq/updateDatabase.cpp
@@ -4,6 +4,7 @@
 #include <dbRecordSet.h>
 #include <eventSourceBase.h>
 #include <helpers.h>
+#include <input/replStream.h>
 #include <memory>
 #include <output/pq/sql/selectSource.h>
 #include <stdexcept>
@@ -16,6 +17,6 @@ namespace MyGrate::Output::Pq {
 	{
 		auto srcrec = output::pq::sql::selectSource::execute(this, source);
 		verify<std::runtime_error>(srcrec->rows() == 1, "Wrong number of source config rows");
-		return {};
+		return (*srcrec)[0].create<Input::ReplicationStream, 7>();
 	}
 }
-- 
cgit v1.2.3