Add reflection support for new data types

pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>org.liquibase.ext</groupId>
     <artifactId>liquibase-databricks</artifactId>
-    <version>1.1.2-SNAPSHOT</version>
+    <version>1.1.3-SNAPSHOT</version>
 
     <name>Liquibase Extension: Databricks support</name>
     <description>Liquibase Extension for Databricks.</description>

src/main/java/liquibase/ext/databricks/datatype/BooleanDatatypeDatabricks.java

@@ -0,0 +1,40 @@
+package liquibase.ext.databricks.datatype;
+
+import liquibase.change.core.LoadDataChange;
+import liquibase.database.Database;
+import liquibase.datatype.DataTypeInfo;
+import liquibase.datatype.DatabaseDataType;
+import liquibase.datatype.LiquibaseDataType;
+import liquibase.ext.databricks.database.DatabricksDatabase;
+
+@DataTypeInfo(
+        name = "boolean",
+        minParameters = 0,
+        maxParameters = 0,
+        priority = DatabricksDatabase.PRIORITY_DATABASE
+)
+public class BooleanDatatypeDatabricks extends LiquibaseDataType {
+
+    public BooleanDatatypeDatabricks() {
+    }
+
+    public boolean supports(Database database) {
+        return database instanceof DatabricksDatabase;
+    }
+
+    public DatabaseDataType toDatabaseDataType(Database database) {
+        if (database instanceof DatabricksDatabase) {
+
+            DatabaseDataType type = new DatabaseDataType("BOOLEAN", this.getParameters());
+            type.setType("BOOLEAN");
+            return type;
+        } else {
+            return super.toDatabaseDataType(database);
+        }
+
+    }
+
+    public LoadDataChange.LOAD_DATA_TYPE getLoadTypeName() {
+        return LoadDataChange.LOAD_DATA_TYPE.BOOLEAN;
+    }
+}

src/main/java/liquibase/ext/databricks/datatype/DoubleDatatypeDatabricks.java

@@ -0,0 +1,40 @@
+package liquibase.ext.databricks.datatype;
+
+import liquibase.change.core.LoadDataChange;
+import liquibase.database.Database;
+import liquibase.datatype.DataTypeInfo;
+import liquibase.datatype.DatabaseDataType;
+import liquibase.datatype.LiquibaseDataType;
+import liquibase.ext.databricks.database.DatabricksDatabase;
+
+@DataTypeInfo(
+        name = "double",
+        minParameters = 0,
+        maxParameters = 0,
+        priority = DatabricksDatabase.PRIORITY_DATABASE
+)
+public class DoubleDatatypeDatabricks extends LiquibaseDataType {
+
+    public DoubleDatatypeDatabricks() {
+    }
+
+    public boolean supports(Database database) {
+        return database instanceof DatabricksDatabase;
+    }
+
+    public DatabaseDataType toDatabaseDataType(Database database) {
+        if (database instanceof DatabricksDatabase) {
+
+            DatabaseDataType type = new DatabaseDataType("DOUBLE", this.getParameters());
+            type.setType("DOUBLE");
+            return type;
+        } else {
+            return super.toDatabaseDataType(database);
+        }
+
+    }
+
+    public LoadDataChange.LOAD_DATA_TYPE getLoadTypeName() {
+        return LoadDataChange.LOAD_DATA_TYPE.NUMERIC;
+    }
+}

src/main/java/liquibase/ext/databricks/datatype/FloatDatatypeDatabricks.java

@@ -0,0 +1,40 @@
+package liquibase.ext.databricks.datatype;
+
+import liquibase.change.core.LoadDataChange;
+import liquibase.database.Database;
+import liquibase.datatype.DataTypeInfo;
+import liquibase.datatype.DatabaseDataType;
+import liquibase.datatype.LiquibaseDataType;
+import liquibase.ext.databricks.database.DatabricksDatabase;
+
+
+@DataTypeInfo(
+        name = "float",
+        minParameters = 0,
+        maxParameters = 0,
+        priority = DatabricksDatabase.PRIORITY_DATABASE
+)
+public class FloatDatatypeDatabricks extends LiquibaseDataType {
+    public FloatDatatypeDatabricks() {
+    }
+
+    public boolean supports(Database database) {
+        return database instanceof DatabricksDatabase;
+    }
+
+    public DatabaseDataType toDatabaseDataType(Database database) {
+        if (database instanceof DatabricksDatabase) {
+
+            DatabaseDataType type = new DatabaseDataType("FLOAT", this.getParameters());
+            type.setType("FLOAT");
+            return type;
+        } else {
+            return super.toDatabaseDataType(database);
+        }
+
+    }
+
+    public LoadDataChange.LOAD_DATA_TYPE getLoadTypeName() {
+        return LoadDataChange.LOAD_DATA_TYPE.NUMERIC;
+    }
+}

src/main/java/liquibase/ext/databricks/datatype/IntegerDatatypeDatabricks.java

@@ -7,14 +7,12 @@
 import liquibase.datatype.LiquibaseDataType;
 import liquibase.ext.databricks.database.DatabricksDatabase;
 
-import static liquibase.ext.databricks.database.DatabricksDatabase.PRIORITY_DATABASE;
-
 
 @DataTypeInfo(
         name = "int",
         minParameters = 0,
         maxParameters = 0,
-        priority = PRIORITY_DATABASE
+        priority = DatabricksDatabase.PRIORITY_DATABASE
 )
 public class IntegerDatatypeDatabricks extends LiquibaseDataType {
     public IntegerDatatypeDatabricks() {

src/main/resources/META-INF/services/liquibase.datatype.LiquibaseDataType

@@ -2,3 +2,6 @@ liquibase.ext.databricks.datatype.DatetimeDatatypeDatabricks
 liquibase.ext.databricks.datatype.BigintDatatypeDatabricks
 liquibase.ext.databricks.datatype.StringDatatypeDatabricks
 liquibase.ext.databricks.datatype.IntegerDatatypeDatabricks
+liquibase.ext.databricks.datatype.BooleanDatatypeDatabricks
+liquibase.ext.databricks.datatype.FloatDatatypeDatabricks
+liquibase.ext.databricks.datatype.DoubleDatatypeDatabricks