From 2d18c5dcd033050e607420b85f92492dc6f01707 Mon Sep 17 00:00:00 2001 From: KushnirykOleh Date: Wed, 24 Jul 2024 15:51:53 +0300 Subject: [PATCH] added clob as string alias --- .../ext/databricks/database/DatabricksDatabase.java | 7 ++++++- .../databricks/datatype/StringDatatypeDatabricks.java | 10 ++++++---- 2 files changed, 12 insertions(+), 5 deletions(-) diff --git a/src/main/java/liquibase/ext/databricks/database/DatabricksDatabase.java b/src/main/java/liquibase/ext/databricks/database/DatabricksDatabase.java index 18c3a469..bd1a09ef 100644 --- a/src/main/java/liquibase/ext/databricks/database/DatabricksDatabase.java +++ b/src/main/java/liquibase/ext/databricks/database/DatabricksDatabase.java @@ -30,7 +30,7 @@ public class DatabricksDatabase extends AbstractJdbcDatabase { private Set systemTablesAndViews = new HashSet<>(); //Define data type names enabled for auto-increment columns - currently only BIGINT - public static final List VALID_AUTO_INCREMENT_COLUMN_TYPE_NAMES = Collections.unmodifiableList(Arrays.asList("BIGINT")); + public static final List VALID_AUTO_INCREMENT_COLUMN_TYPE_NAMES = Collections.singletonList("BIGINT"); public DatabricksDatabase() { super.setCurrentDateTimeFunction("current_timestamp()"); @@ -133,6 +133,11 @@ public boolean supportsTablespaces() { @Override public boolean supportsSequences() { return false; } + @Override + public boolean supportsDatabaseChangeLogHistory() { + return true; + } + @Override public String getAutoIncrementClause(final BigInteger startWith, final BigInteger incrementBy, final String generationType, final Boolean defaultOnNull) { if (!this.supportsAutoIncrement()) { diff --git a/src/main/java/liquibase/ext/databricks/datatype/StringDatatypeDatabricks.java b/src/main/java/liquibase/ext/databricks/datatype/StringDatatypeDatabricks.java index 8001ebd6..4cddd1a2 100644 --- a/src/main/java/liquibase/ext/databricks/datatype/StringDatatypeDatabricks.java +++ b/src/main/java/liquibase/ext/databricks/datatype/StringDatatypeDatabricks.java @@ -4,23 +4,25 @@ import liquibase.database.Database; import liquibase.datatype.DataTypeInfo; import liquibase.datatype.DatabaseDataType; -import liquibase.datatype.LiquibaseDataType; +import liquibase.datatype.core.VarcharType; import liquibase.ext.databricks.database.DatabricksDatabase; @DataTypeInfo( name = "string", minParameters = 0, maxParameters = 0, - priority = DatabricksDatabase.DATABRICKS_PRIORITY_DATABASE + priority = DatabricksDatabase.DATABRICKS_PRIORITY_DATABASE, + aliases = { "varchar", "clob", "java.lang.String" } ) -public class StringDatatypeDatabricks extends LiquibaseDataType { +public class StringDatatypeDatabricks extends VarcharType { public StringDatatypeDatabricks() { } + @Override public boolean supports(Database database) { return database instanceof DatabricksDatabase; } - + @Override public DatabaseDataType toDatabaseDataType(Database database) { if (database instanceof DatabricksDatabase) {