public String getConnectionInitStatement(String schema) {
if (StringUtils.isNotBlank(schema)) {
- return "ALTER SESSION SET CURRENT_SCHEMA = " + schema;
+ return "ALTER SESSION SET CURRENT_SCHEMA = \"" + schema + "\"";
}
return null;
}
public void shouldChangeOracleSchema() {
String initStatement = new Oracle().getConnectionInitStatement("my_schema");
- assertThat(initStatement, Is.is("ALTER SESSION SET CURRENT_SCHEMA = my_schema"));
+ assertThat(initStatement, Is.is("ALTER SESSION SET CURRENT_SCHEMA = \"my_schema\""));
}
@Test