Fix index creation statement

airbytehq · Mar 25, 2022 · 8b291d8 · 8b291d8
1 parent b24286c
commit 8b291d8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/...main/java/io/airbyte/db/instance/configs/migrations/V0_35_59_004__AddOauthParamIndex.java b/...main/java/io/airbyte/db/instance/configs/migrations/V0_35_59_004__AddOauthParamIndex.java
@@ -20,7 +20,8 @@ public void migrate(final Context context) throws Exception {
     LOGGER.info("Running migration: {}", this.getClass().getSimpleName());
 
     final DSLContext ctx = DSL.using(context.getConnection());
-    ctx.createIndexIfNotExists("actor_oauth_parameter_workspace_definition_idx").on("actor_oauth_parameter", "workspace_id", "actor_definition_id");
+    ctx.createIndexIfNotExists("actor_oauth_parameter_workspace_definition_idx").on("actor_oauth_parameter", "workspace_id", "actor_definition_id")
+        .execute();
   }
 
 }
diff --git a/airbyte-db/lib/src/main/resources/configs_database/schema_dump.txt b/airbyte-db/lib/src/main/resources/configs_database/schema_dump.txt
@@ -232,6 +232,10 @@ create unique index "actor_definition_workspace_gr_workspace_id_actor_definition
   "actor_definition_id" asc
 );
 create unique index "actor_oauth_parameter_pkey" on "public"."actor_oauth_parameter"("id" asc);
+create index "actor_oauth_parameter_workspace_definition_idx" on "public"."actor_oauth_parameter"(
+  "workspace_id" asc, 
+  "actor_definition_id" asc
+);
 create unique index "airbyte_configs_migrations_pk" on "public"."airbyte_configs_migrations"("installed_rank" asc);
 create index "airbyte_configs_migrations_s_idx" on "public"."airbyte_configs_migrations"("success" asc);
 create index "connection_destination_id_idx" on "public"."connection"("destination_id" asc);