chore: sync ap migrations (#1021)

sovity · Aug 8, 2024 · 73d00c0 · 73d00c0
1 parent 71c10d5
commit 73d00c0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...wler/src/main/java/de/sovity/edc/ext/catalog/crawler/dao/connectors/ConnectorQueries.java b/...wler/src/main/java/de/sovity/edc/ext/catalog/crawler/dao/connectors/ConnectorQueries.java
@@ -60,11 +60,11 @@ private Set<ConnectorRef> queryConnectorRefs(
                         c.CONNECTOR_ID.as("connectorId"),
                         c.ENVIRONMENT.as("environmentId"),
                         o.NAME.as("organizationLegalName"),
-                        o.MDS_ID.as("organizationId"),
+                        o.ID.as("organizationId"),
                         c.ENDPOINT_URL.as("endpoint")
                 )
                 .from(c)
-                .leftJoin(o).on(c.MDS_ID.eq(o.MDS_ID))
+                .leftJoin(o).on(c.ORGANIZATION_ID.eq(o.ID))
                 .where(condition.apply(c, o), c.ENVIRONMENT.eq(crawlerConfig.getEnvironmentId()))
                 .fetchInto(ConnectorRef.class);
 

diff --git a/...log-crawler/catalog-crawler/src/test/java/de/sovity/edc/ext/catalog/crawler/TestData.java b/...log-crawler/catalog-crawler/src/test/java/de/sovity/edc/ext/catalog/crawler/TestData.java
@@ -44,13 +44,13 @@ public static void insertConnector(
             Consumer<ConnectorRecord> applier
     ) {
         var organization = dsl.newRecord(Tables.ORGANIZATION);
-        organization.setMdsId(connectorRef.getOrganizationId());
+        organization.setId(connectorRef.getOrganizationId());
         organization.setName(connectorRef.getOrganizationLegalName());
         organization.insert();
 
         var connector = dsl.newRecord(Tables.CONNECTOR);
         connector.setEnvironment(connectorRef.getEnvironmentId());
-        connector.setMdsId(connectorRef.getOrganizationId());
+        connector.setOrganizationId(connectorRef.getOrganizationId());
         connector.setConnectorId(connectorRef.getConnectorId());
         connector.setName(connectorRef.getConnectorId() + " Name");
         connector.setEndpointUrl(connectorRef.getEndpoint());