aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--odb/pgsql/connection.cxx28
-rw-r--r--odb/pgsql/connection.hxx5
2 files changed, 26 insertions, 7 deletions
diff --git a/odb/pgsql/connection.cxx b/odb/pgsql/connection.cxx
index 0a23ed7..be88446 100644
--- a/odb/pgsql/connection.cxx
+++ b/odb/pgsql/connection.cxx
@@ -31,10 +31,7 @@ namespace odb
{
connection::
connection (database_type& db)
- : odb::connection (db),
- db_ (db),
- handle_ (0),
- statement_cache_ (new statement_cache_type (*this))
+ : odb::connection (db), db_ (db)
{
handle_ = PQconnectdb (db.conninfo ().c_str ());
@@ -48,16 +45,33 @@ namespace odb
throw database_exception (m);
}
- // Suppress server notifications to stdout.
- //
- PQsetNoticeProcessor (handle_, &odb_pgsql_process_notice, 0);
+ init ();
+ }
+
+ connection::
+ connection (database_type& db, PGconn* handle)
+ : odb::connection (db), db_ (db), handle_ (handle)
+ {
+ init ();
+ }
+ void connection::
+ init ()
+ {
// Establish whether date/time values are represented as
// 8-byte integers.
//
if (strcmp (PQparameterStatus (handle_, "integer_datetimes"), "on") != 0)
throw database_exception ("unsupported binary format for PostgreSQL "
"date-time SQL types");
+
+ // Suppress server notifications to stdout.
+ //
+ PQsetNoticeProcessor (handle_, &odb_pgsql_process_notice, 0);
+
+ // Create statement cache.
+ //
+ statement_cache_.reset (new statement_cache_type (*this));
}
connection::
diff --git a/odb/pgsql/connection.hxx b/odb/pgsql/connection.hxx
index a44b328..063f8d4 100644
--- a/odb/pgsql/connection.hxx
+++ b/odb/pgsql/connection.hxx
@@ -43,6 +43,7 @@ namespace odb
~connection ();
connection (database_type&);
+ connection (database_type&, PGconn* handle);
database_type&
database ()
@@ -78,6 +79,10 @@ namespace odb
connection& operator= (const connection&);
private:
+ void
+ init ();
+
+ private:
database_type& db_;
PGconn* handle_;