Merge pull request #69 from data-integrations/fix/database-plugin

Fix validation of database source

Author: CuriousVini

database-commons/src/main/java/io/cdap/plugin/db/batch/source/AbstractDBSource.java

@@ -424,10 +424,12 @@ static void validateSchema(Schema actualSchema, Schema configSchema, FailureColl
         Schema expectedFieldSchema = field.getSchema().isNullable() ?
           field.getSchema().getNonNullable() : field.getSchema();
 
-        if (!actualFieldSchema.equals(expectedFieldSchema)) {
+        if (actualFieldSchema.getType() != expectedFieldSchema.getType() ||
+          actualFieldSchema.getLogicalType() != expectedFieldSchema.getLogicalType()) {
           collector.addFailure(
-            String.format("Schema field '%s' has type '%s' but found '%s' in input record",
-                          field.getName(), expectedFieldSchema.getType(), actualFieldSchema.getType()), null)
+            String.format("Schema field '%s' has type '%s but found '%s'.",
+                          field.getName(), expectedFieldSchema.getDisplayName(),
+                          actualFieldSchema.getDisplayName()), null)
             .withOutputSchemaField(field.getName());
         }
       }