summaryrefslogtreecommitdiff
path: root/lib/output
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-07-04 12:48:02 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-07-04 12:48:02 +0100
commit5389571e2db6b62ecc8e45b5e8bea1739ab67957 (patch)
tree77f66babcfcf584ebc2a1c013731e19eeccbef5c /lib/output
parentPush mysqldata at into base class (diff)
downloadmygrate-5389571e2db6b62ecc8e45b5e8bea1739ab67957.tar.bz2
mygrate-5389571e2db6b62ecc8e45b5e8bea1739ab67957.tar.xz
mygrate-5389571e2db6b62ecc8e45b5e8bea1739ab67957.zip
Introduce the cursor concept
Not implemented for PQ yet.
Diffstat (limited to 'lib/output')
-rw-r--r--lib/output/pq/pqStmt.cpp6
-rw-r--r--lib/output/pq/pqStmt.h2
2 files changed, 8 insertions, 0 deletions
diff --git a/lib/output/pq/pqStmt.cpp b/lib/output/pq/pqStmt.cpp
index dc258b6..2265f64 100644
--- a/lib/output/pq/pqStmt.cpp
+++ b/lib/output/pq/pqStmt.cpp
@@ -40,6 +40,12 @@ namespace MyGrate::Output::Pq {
return std::make_unique<PqRecordSet>(std::move(res));
}
+ CursorPtr
+ PqPrepStmt::cursor()
+ {
+ throw std::logic_error("Not implemented");
+ }
+
std::string
PqPrepStmt::prepareAsNeeded(const char * const q, std::size_t n, PqConn * c)
{
diff --git a/lib/output/pq/pqStmt.h b/lib/output/pq/pqStmt.h
index 6531180..887a326 100644
--- a/lib/output/pq/pqStmt.h
+++ b/lib/output/pq/pqStmt.h
@@ -27,6 +27,8 @@ namespace MyGrate::Output::Pq {
RecordSetPtr recordSet() override;
+ CursorPtr cursor() override;
+
private:
static std::string prepareAsNeeded(const char * const q, std::size_t n, PqConn * c);