Introduce schema config param

[dmaap/dbcapi.git] / src / main / java / org / onap / dmaap / dbcapi / database / ConnectionFactory.java

diff --git a/src/main/java/org/onap/dmaap/dbcapi/database/ConnectionFactory.java b/src/main/java/org/onap/dmaap/dbcapi/database/ConnectionFactory.java
index 1d93d68..38c063c 100644 (file)
--- a/src/main/java/org/onap/dmaap/dbcapi/database/ConnectionFactory.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/database/ConnectionFactory.java
@@ -52,12 +52,15 @@ public class ConnectionFactory      {
        private String  dbname;
        private String  dbuser;
        private String  dbcr;
+       private String  schema;
+       
        public ConnectionFactory() {
                Properties p = DmaapConfig.getConfig();
                host = p.getProperty("DB.host", "dcae-pstg-write-ftl.domain.notset.com");
                dbname = p.getProperty("DB.name", "dmaap");
                dbuser = p.getProperty("DB.user", "dmaap_admin");
                dbcr = p.getProperty("DB.cred", "test234-ftl");
+               schema = p.getProperty("DB.schema", "public");
        }
        public static ConnectionFactory getDefaultInstance() {
                return(instance);
@@ -77,6 +80,9 @@ public class ConnectionFactory        {
                p.put("password", dbcr);
                return(DriverManager.getConnection("jdbc:postgresql://" + host + "/" + dbname, p));
        }
+       public String getSchema() {
+               return(schema);
+       }
        public void release(Connection c) {
                synchronized(this) {
                        if (cur < pool.length) {