@@ -11,27 +11,27 @@ public class V4_55__Update_catalog_connector_configuration_type extends BaseJava
1111 public void migrate (Context context ) throws Exception {
1212 try (Statement select = context .getConnection ().createStatement ()) {
1313 select .execute (
14- """
15- CREATE TYPE connector_configuration_type AS ENUM ('ARRAY', 'BOOLEAN', 'INTEGER', 'OBJECT', 'STRING');
16- CREATE TYPE connector_configuration_format AS ENUM ('DATE', 'DATETIME', 'DURATION', 'EMAIL', 'PASSWORD', 'URI');
17-
18- ALTER TABLE catalog_connectors_configuration
19- DROP COLUMN IF EXISTS connector_configuration_type,
20- DROP COLUMN IF EXISTS connector_configuration_format
21- """ );
14+ """
15+ CREATE TYPE connector_configuration_type AS ENUM ('ARRAY', 'BOOLEAN', 'INTEGER', 'OBJECT', 'STRING');
16+ CREATE TYPE connector_configuration_format AS ENUM ('DATE', 'DATETIME', 'DURATION', 'EMAIL', 'PASSWORD', 'URI');
17+
18+ ALTER TABLE catalog_connectors_configuration
19+ DROP COLUMN IF EXISTS connector_configuration_type,
20+ DROP COLUMN IF EXISTS connector_configuration_format
21+ """ );
2222
2323 select .execute (
24- """
25- ALTER TABLE catalog_connectors_configuration
26- ADD COLUMN connector_configuration_type connector_configuration_type,
27- ADD COLUMN connector_configuration_format connector_configuration_format
28- """ );
24+ """
25+ ALTER TABLE catalog_connectors_configuration
26+ ADD COLUMN connector_configuration_type connector_configuration_type,
27+ ADD COLUMN connector_configuration_format connector_configuration_format
28+ """ );
2929
3030 select .execute (
31- """
32- ALTER TABLE connector_instance_logs
33- RENAME COLUMN connector_configuration_created_at TO connector_instance_log_created_at;
34- """ );
31+ """
32+ ALTER TABLE connector_instance_logs
33+ RENAME COLUMN connector_configuration_created_at TO connector_instance_log_created_at;
34+ """ );
3535 }
3636 }
3737}
0 commit comments