X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fdatabase%2FConnectionFactory.java;h=38c063c3819e71e222392692e3eb8642289b39dc;hp=1d93d68b5a99a48c43e51eb8088fa94f37396eaf;hb=f283c8d30ab3e5cde52906bc41c368f07733bb81;hpb=1c6b5fa580c9b82e17b710dbc4cf9bbce57eb5bc

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
--- 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) {