From f98ecb7ea6a64b02d2a28cd15e865afa76342327 Mon Sep 17 00:00:00 2001
From: Dan Goodliffe <dan@randomdan.homeip.net>
Date: Sun, 23 May 2021 00:17:24 +0100
Subject: Add PQ basics

---
 lib/output/pq/pqConn.cpp | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)
 create mode 100644 lib/output/pq/pqConn.cpp

(limited to 'lib/output/pq/pqConn.cpp')

diff --git a/lib/output/pq/pqConn.cpp b/lib/output/pq/pqConn.cpp
new file mode 100644
index 0000000..78cdc06
--- /dev/null
+++ b/lib/output/pq/pqConn.cpp
@@ -0,0 +1,27 @@
+#include "pqConn.h"
+#include <helpers.h>
+#include <stdexcept>
+
+namespace MyGrate::Output::Pq {
+	PqConn::PqConn(const char * const str) : conn {PQconnectdb(str)}
+	{
+		verify<std::runtime_error>(PQstatus(conn) == CONNECTION_OK, "Connection failure");
+		PQsetNoticeProcessor(conn, notice_processor, this);
+	}
+
+	PqConn::~PqConn()
+	{
+		PQfinish(conn);
+	}
+
+	void
+	PqConn::notice_processor(void * p, const char * n)
+	{
+		return static_cast<PqConn *>(p)->notice_processor(n);
+	}
+
+	void
+	PqConn::notice_processor(const char *) const
+	{
+	}
+}
-- 
cgit v1.2.3