yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-10-19 04:41:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

migration: fix duplicate param key insertion (#20802)

Browse Source
This commit is contained in:
Teddy 2025-04-15 14:10:51 +02:00 committed by GitHub
parent 1a6224824b
commit 98c6b6e4ef
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
bootstrap/sql/migrations/native/1.5.7/mysql/postDataMigrationSQLScript.sql
View File

@ -14,4 +14,5 @@ SET json = JSON_MERGE_PRESERVE(
) )
) )
) )
WHERE name = 'tableDiff'; WHERE name = 'tableDiff'
AND NOT JSON_CONTAINS(json->>'$.parameterDefinition', JSON_OBJECT('name', 'caseSensitiveColumns'));

7
bootstrap/sql/migrations/native/1.5.7/postgres/postDataMigrationSQLScript.sql
View File

@ -5,4 +5,9 @@ SET json = jsonb_set(
(json->'parameterDefinition')::jsonb || (json->'parameterDefinition')::jsonb ||
'{"name": "caseSensitiveColumns", "dataType": "BOOLEAN", "required": false, "description": "Use case sensitivity when comparing the columns.", "displayName": "Case sensitive columns"}'::jsonb '{"name": "caseSensitiveColumns", "dataType": "BOOLEAN", "required": false, "description": "Use case sensitivity when comparing the columns.", "displayName": "Case sensitive columns"}'::jsonb
) )
WHERE name = 'tableDiff'; WHERE name = 'tableDiff'
AND NOT EXISTS (
SELECT 1
FROM jsonb_array_elements(json#>'{parameterDefinition}') AS elem
WHERE elem->>'name' = 'caseSensitiveColumns'
);

13
openmetadata-service/src/main/java/org/openmetadata/service/migration/utils/v157/MigrationUtil.java
View File

@ -37,9 +37,14 @@ public class MigrationUtil {
TestDefinition td = getTestDefinition(daoCollection, testCase); TestDefinition td = getTestDefinition(daoCollection, testCase);
if (Objects.nonNull(td) && Objects.equals(td.getName(), TABLE_DIFF)) { if (Objects.nonNull(td) && Objects.equals(td.getName(), TABLE_DIFF)) {
LOG.debug("Adding caseSensitiveColumns=true table diff test case: {}", testCase.getId()); LOG.debug("Adding caseSensitiveColumns=true table diff test case: {}", testCase.getId());
if (!hasCaseSensitiveColumnsParam(testCase.getParameterValues())) {
testCase testCase
.getParameterValues() .getParameterValues()
.add(new TestCaseParameterValue().withName("caseSensitiveColumns").withValue("true")); .add(
new TestCaseParameterValue()
.withName("caseSensitiveColumns")
.withValue("true"));
}
daoCollection.testCaseDAO().update(testCase); daoCollection.testCaseDAO().update(testCase);
} }
} }
@ -60,4 +65,10 @@ public class MigrationUtil {
} }
return dao.testDefinitionDAO().findEntityById(records.get(0).getId()); return dao.testDefinitionDAO().findEntityById(records.get(0).getId());
} }
private static boolean hasCaseSensitiveColumnsParam(
List<TestCaseParameterValue> parameterValues) {
return parameterValues.stream()
.anyMatch(paramValue -> paramValue.getName().equals("caseSensitiveColumns"));
}
} }