Oracle sink plugin failing with null error when input schema contains small case letters.

Author: vikasrathee-cs

oracle-plugin/src/main/java/io/cdap/plugin/oracle/OracleSinkDBRecord.java

@@ -17,9 +17,12 @@
 package io.cdap.plugin.oracle;
 
 import io.cdap.cdap.api.data.format.StructuredRecord;
+import io.cdap.cdap.api.data.schema.Schema;
 import io.cdap.plugin.db.ColumnType;
 import io.cdap.plugin.db.SchemaReader;
 
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.List;
 
 /**
@@ -37,4 +40,14 @@ public OracleSinkDBRecord(StructuredRecord record, List<ColumnType> columnTypes)
   protected SchemaReader getSchemaReader() {
     return new OracleSinkSchemaReader();
   }
+
+  @Override
+  public void write(PreparedStatement stmt) throws SQLException {
+    for (int i = 0; i < columnTypes.size(); i++) {
+      ColumnType columnType = columnTypes.get(i);
+      // Get the field from the schema that corresponds to the column name with ignoring case
+      Schema.Field field = record.getSchema().getField(columnType.getName(), true);
+      writeToDB(stmt, field, i);
+    }
+  }
 }