code: private void createIfNotExists(String tableName, String createTableStatement) throws SQLException {
  		logger.entering(CLASSNAME, "createIfNotExists", new Object[] {tableName, createTableStatement});
  
  		Connection conn = getConnection();
  		DatabaseMetaData dbmd = conn.getMetaData();
  		ResultSet rs = dbmd.getTables(null, schema, tableName, null);
  		PreparedStatement ps = null;
  		if(!rs.next()) {
  			logger.log(Level.INFO, tableName + " table does not exists. Trying to create it.");
  			ps = conn.prepareStatement(createTableStatement);
  			ps.executeUpdate();
  		}
  
  		cleanupConnection(conn, rs, ps);
  		logger.exiting(CLASSNAME, "createIfNotExists");
  	}
docs: Creates tableName using the createTableStatement DDL.
  
  @param tableName
  @param createTableStatement
  @throws SQLException