diff --git a/src/main/java/com/yugabyte/sample/apps/AppBase.java b/src/main/java/com/yugabyte/sample/apps/AppBase.java index d1236c0..014c8ea 100644 --- a/src/main/java/com/yugabyte/sample/apps/AppBase.java +++ b/src/main/java/com/yugabyte/sample/apps/AppBase.java @@ -218,15 +218,6 @@ protected Connection getPostgresConnection(String database, String username, Str String connectStr = String.format("%s//%s:%d/%s", url, contactPoint.getHost(), contactPoint.getPort(), database); - if (!username.equalsIgnoreCase("yugabyte") || !username.equalsIgnoreCase("postgres")){ - Properties newProps = new Properties(); - newProps.setProperty("user", "yugabyte"); - Connection controlConnection = DriverManager.getConnection(connectStr, newProps); - Statement st = controlConnection.createStatement(); - String grantPermission = String.format("grant create on schema public to %s with grant option;", username); - st.execute(grantPermission); - controlConnection.close(); - } Connection connection = DriverManager.getConnection(connectStr, props); return connection; } catch (Exception e) {