summaryrefslogtreecommitdiff
path: root/lib/output/pq/writePqCopyStrm.h
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-08-08 12:48:37 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-08-08 16:15:07 +0100
commit5378ffd0aca410c50887fee57899776e62bfb766 (patch)
tree699e11a5b6cfcf7f6d2c29083ec84c7ed3fe36c5 /lib/output/pq/writePqCopyStrm.h
parentCreate indexes and keys after copying table data (diff)
downloadmygrate-5378ffd0aca410c50887fee57899776e62bfb766.tar.bz2
mygrate-5378ffd0aca410c50887fee57899776e62bfb766.tar.xz
mygrate-5378ffd0aca410c50887fee57899776e62bfb766.zip
Extract WritePqCopyStrm into its own file
Diffstat (limited to 'lib/output/pq/writePqCopyStrm.h')
-rw-r--r--lib/output/pq/writePqCopyStrm.h38
1 files changed, 38 insertions, 0 deletions
diff --git a/lib/output/pq/writePqCopyStrm.h b/lib/output/pq/writePqCopyStrm.h
new file mode 100644
index 0000000..e8a4fd3
--- /dev/null
+++ b/lib/output/pq/writePqCopyStrm.h
@@ -0,0 +1,38 @@
+#ifndef MYGRATE_OUTPUT_PQ_WRITEPQSTRM_H
+#define MYGRATE_OUTPUT_PQ_WRITEPQSTRM_H
+
+#include <concepts>
+#include <cstdio>
+#include <dbTypes.h>
+
+namespace MyGrate::Output::Pq {
+ struct WritePqCopyStream {
+ explicit WritePqCopyStream(FILE * o);
+
+ void nextRecord();
+ void nextField();
+
+ void operator()(std::nullptr_t) const;
+ void
+ operator()(std::integral auto v) const
+ {
+ fprintf(out, printer<decltype(v)>::fmt, v);
+ }
+ void
+ operator()(std::floating_point auto v) const
+ {
+ fprintf(out, printer<decltype(v)>::fmt, v);
+ }
+ void operator()(timespec) const;
+ void operator()(Date v) const;
+ void operator()(Time v) const;
+ void operator()(DateTime v) const;
+ void operator()(std::string_view v) const;
+ void operator()(BitSet) const;
+ void operator()(Blob v) const;
+
+ FILE * out;
+ };
+}
+
+#endif