+
+ // this sets the PG search_path to a consistent schema, otherwise sometimes
+ // we get public, and sometimes we get dmaap_admin
+ String cmd = String.format( "SET search_path to %s;", cf.getSchema());
+ try {
+ stmt.execute(cmd);
+ logger.info("SCHEMA: " + cmd);
+ } catch (SQLException sqle) {
+ throw sqle;
+ }
+
+
+ // determine if an upgrade is needed