Using connection string schema when working with metadata.

include/soci/soci-backend.h

@@ -332,7 +332,7 @@ class blob_backend
 class session_backend
 {
 public:
-    session_backend() : failoverCallback_(NULL), session_(NULL) {}
+    session_backend() : failoverCallback_(NULL), session_(NULL), schema_name_("public") {}
     virtual ~session_backend() {}
 
     virtual bool is_connected() = 0;
@@ -366,7 +366,7 @@ class session_backend
     {
         return "select table_name as \"TABLE_NAME\""
             " from information_schema.tables"
-            " where table_schema = 'public'";
+            " where table_schema = '" + schema_name_ + "'";
     }
 
     // Returns a query with a single parameter (table name) for the list
@@ -380,7 +380,7 @@ class session_backend
             " numeric_scale as \"NUMERIC_SCALE\","
             " is_nullable as \"IS_NULLABLE\""
             " from information_schema.columns"
-            " where table_schema = 'public' and table_name = :t";
+            " where table_schema = '" + schema_name_ + "' and table_name = :t";
     }
 
     virtual std::string create_table(const std::string & tableName)
@@ -565,6 +565,7 @@ class session_backend
 
     failover_callback * failoverCallback_;
     session * session_;
+    std::string schema_name_;
 
 private:
     SOCI_NOT_COPYABLE(session_backend)

src/backends/mysql/session.cpp

@@ -509,6 +509,7 @@ mysql_session_backend::mysql_session_backend(
         clean_up();
         throw mysql_soci_error(errMsg, errNum);
     }
+    schema_name_ = db;
 }
 
 #if defined(__GNUC__) && ( __GNUC__ > 4 || (__GNUC__ == 4 && (__GNUC_MINOR__ > 6)))

src/backends/postgresql/session.cpp

@@ -67,6 +67,16 @@ void postgresql_session_backend::connect(
                          : "SET extra_float_digits = 2",
         "Cannot set extra_float_digits parameter");
 
+    PGresult* res = PQexec(conn, "SHOW search_path");
+    if (PQresultStatus(res) == PGRES_TUPLES_OK)
+    {
+        if (PQntuples(res) > 0)
+        {
+            schema_name_ = PQgetvalue(res, 0, 0);
+        }
+    }
+    PQclear(res);
+
     conn_ = conn;
     connectionParameters_ = parameters;
 }