diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-07-04 12:48:02 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-07-04 12:48:02 +0100 |
| commit | 5389571e2db6b62ecc8e45b5e8bea1739ab67957 (patch) | |
| tree | 77f66babcfcf584ebc2a1c013731e19eeccbef5c /lib/output | |
| parent | Push mysqldata at into base class (diff) | |
| download | mygrate-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.cpp | 6 | ||||
| -rw-r--r-- | lib/output/pq/pqStmt.h | 2 |
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); |