package org.onap.dmaap.dbcapi.database;
-import java.util.*;
import java.lang.reflect.*;
-import java.sql.*;
+
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Vector;
class TableHandler<C> {
protected ConnectionFactory cf;
private void setup(DatabaseMetaData dmd, Class<C> cls, String tabname, String keyname) throws Exception {
this.cls = cls;
Vector<DBFieldHandler> h = new Vector<DBFieldHandler>();
- ResultSet rs = dmd.getColumns("", "public", tabname, null);
+ String qualifiedTableName = String.format( "%s.%s", cf.getSchema(), tabname );
+ ResultSet rs = dmd.getColumns("", cf.getSchema(), tabname, null);
StringBuffer sb1 = new StringBuffer();
StringBuffer sb2 = new StringBuffer();
StringBuffer sb3 = new StringBuffer();
if (haskey) {
count++;
h.add(new DBFieldHandler(cls, keyname, count, getSpecialCase(tabname, keyname)));
- delstmt = "DELETE FROM " + tabname + " WHERE " + keyname + " = ?";
- insorreplstmt = "INSERT INTO " + tabname + " (" + clist + ", " + keyname + ") VALUES (" + qlist + ", ?) ON CONFLICT(" + keyname + ") DO UPDATE SET (" + clist + ") = (" + elist + ")";
- getstmt = "SELECT " + clist + ", " + keyname + " FROM " + tabname + " WHERE " + keyname + " = ?";
- liststmt = "SELECT " + clist + ", " + keyname + " FROM " + tabname;
+ delstmt = "DELETE FROM " + qualifiedTableName + " WHERE " + keyname + " = ?";
+ insorreplstmt = "INSERT INTO " + qualifiedTableName + " (" + clist + ", " + keyname + ") VALUES (" + qlist + ", ?) ON CONFLICT(" + keyname + ") DO UPDATE SET (" + clist + ") = (" + elist + ")";
+ getstmt = "SELECT " + clist + ", " + keyname + " FROM " + qualifiedTableName + " WHERE " + keyname + " = ?";
+ liststmt = "SELECT " + clist + ", " + keyname + " FROM " + qualifiedTableName;
} else {
- delstmt = "DELETE FROM " + tabname;
- initstmt = "INSERT INTO " + tabname + " (" + clist + ") VALUES (" + qlist + ")";
- insorreplstmt = "UPDATE " + tabname + " SET (" + clist + ") = (" + qlist + ")";
- getstmt = "SELECT " + clist + ", " + keyname + " FROM " + tabname;
+ delstmt = "DELETE FROM " + qualifiedTableName;
+ initstmt = "INSERT INTO " + qualifiedTableName + " (" + clist + ") VALUES (" + qlist + ")";
+ insorreplstmt = "UPDATE " + qualifiedTableName + " SET (" + clist + ") = (" + qlist + ")";
+ getstmt = "SELECT " + clist + ", " + keyname + " FROM " + qualifiedTableName;
}
fields = h.toArray(new DBFieldHandler[h.size()]);
}