} else if(databaseProductType != DatabaseProductType.POSTGRESQL) {\r
throw new Exception("Unrecognized database system " + databaseProductType);\r
} else {\r
- conn = JDBCTools.getConnection(dataSourceName, repositoryName);\r
+ String databaseName = JDBCTools.getDatabaseName(repositoryName, cspaceInstanceId);\r
+ conn = JDBCTools.getConnection(dataSourceName, databaseName);\r
stmt = conn.createStatement(); \r
//sql = "REVOKE SELECT ON ALL TABLES IN SCHEMA public FROM "+readerRoleName;\r
//stmt.execute(sql);\r