Terminate pgsql database sessions before dropping users/databases.
| | |
| | | assert db.getInstance().equals("pgsql"); |
| | | JDBCProcessor aJDBCP = createPostgreSqlAdminProcessor(); |
| | | String aName = AbstractEntity.escapeString(db.getName()); |
| | | aJDBCP.addSQL("SELECT pg_terminate_backend(procpid) FROM pg_stat_activity WHERE datname='" + aName + "'"); |
| | | aJDBCP.addSQL("DROP DATABASE " + aName); |
| | | return aJDBCP; |
| | | } |
| | |
| | | assert dbu.getInstance().equals("pgsql"); |
| | | JDBCProcessor aJDBCP = PgSqlDatabaseProcessorFactory.createPostgreSqlAdminProcessor(); |
| | | String aName = AbstractEntity.escapeString(dbu.getName()); |
| | | aJDBCP.addSQL("SELECT pg_terminate_backend(procpid) FROM pg_stat_activity WHERE usename='" + aName + "'"); |
| | | aJDBCP.addSQL("DROP USER " + aName); |
| | | return aJDBCP; |
| | | } |