diff options
Diffstat (limited to 'lib/output/pq')
| -rw-r--r-- | lib/output/pq/updateDatabase.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
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>(); } } |