Skip to content

Commit 9db98d7

Browse files
committed
fix bug when checking if schema exists
1 parent 94d0c16 commit 9db98d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

samples/mysql-schema/src/main/java/com/github/containersolutions/operator/sample/SchemaController.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public class SchemaController implements ResourceController<Schema> {
2424
@Override
2525
public Optional<Schema> createOrUpdateResource(Schema schema) {
2626
try (Connection connection = getConnection()) {
27-
if (schemaExists(connection, schema.getMetadata().getName())) {
27+
if (!schemaExists(connection, schema.getMetadata().getName())) {
2828
connection.createStatement().execute(format("CREATE SCHEMA `%1$s` DEFAULT CHARACTER SET %2$s",
2929
schema.getMetadata().getName(),
3030
schema.getSpec().getEncoding()));

0 commit comments

Comments
 (0)