summaryrefslogtreecommitdiff
path: root/libpqpp/pq-binarycolumn.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'libpqpp/pq-binarycolumn.cpp')
-rw-r--r--libpqpp/pq-binarycolumn.cpp43
1 files changed, 43 insertions, 0 deletions
diff --git a/libpqpp/pq-binarycolumn.cpp b/libpqpp/pq-binarycolumn.cpp
new file mode 100644
index 0000000..ff49b26
--- /dev/null
+++ b/libpqpp/pq-binarycolumn.cpp
@@ -0,0 +1,43 @@
+#include "pq-binarycolumn.h"
+#include "pq-selectbase.h"
+#include <error.h>
+
+PQ::BinaryColumn::BinaryColumn(const PQ::SelectBase * s, unsigned int f) :
+ PQ::Column(s, f)
+{
+}
+
+void
+PQ::BinaryColumn::apply(DB::HandleField & h) const
+{
+ if (isNull()) {
+ h.null();
+ return;
+ }
+ switch (oid) {
+ case 18: //CHAROID:
+ case 1043: //VARCHAROID:
+ case 25: //TEXTOID:
+ case 142: //XMLOID:
+ h.string(value(), length());
+ break;
+ case 16: //BOOLOID:
+ h.boolean(valueAs<bool>());
+ break;
+ case 21: //INT2OID:
+ h.integer(be16toh(valueAs<uint16_t>()));
+ break;
+ case 23: //INT4OID:
+ h.integer(be32toh(valueAs<uint32_t>()));
+ break;
+ case 20: //INT8OID:
+ h.integer(be64toh(valueAs<uint64_t>()));
+ break;
+ case 17: //BYTEAOID
+ h.blob(DB::Blob(value(), length()));
+ break;
+ default:
+ throw DB::ColumnTypeNotSupported();
+ }
+}
+