Skip to content

Commit fe9d220

Browse files
committed
Fix to use conditional usrer-related queries
1 parent 401730b commit fe9d220

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraPermissionTestUtils.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,12 @@ public void createNormalUser(String userName, String password) {
1919
.getSession()
2020
.execute(
2121
String.format(
22-
"CREATE ROLE IF NOT EXISTS %s WITH PASSWORD = '%s' AND LOGIN = true",
23-
userName, password));
22+
"CREATE ROLE %s WITH PASSWORD = '%s' AND LOGIN = true", userName, password));
2423
}
2524

2625
@Override
2726
public void dropNormalUser(String userName) {
28-
clusterManager.getSession().execute(String.format("DROP ROLE IF EXISTS %s", userName));
27+
clusterManager.getSession().execute(String.format("DROP ROLE %s", userName));
2928
}
3029

3130
@Override

0 commit comments

Comments
 (0)