src/main/java/org/embulk/output/postgresql/PostgreSQLOutputConnection.java in embulk-output-postgresql-0.7.3 vs src/main/java/org/embulk/output/postgresql/PostgreSQLOutputConnection.java in embulk-output-postgresql-0.7.4

@@ -50,12 +50,13 @@
         StringBuilder sb = new StringBuilder();
 
         sb.append("WITH S AS (");
         sb.append("SELECT ");
         for (int i = 0; i < schema.getCount(); i++) {
+            JdbcColumn column = schema.getColumn(i);
             if (i != 0) { sb.append(", "); }
-            sb.append("? AS ");
-            quoteIdentifierString(sb, schema.getColumnName(i));
+            sb.append("CAST(? AS " + column.getSimpleTypeName() + ") AS ");
+            quoteIdentifierString(sb, column.getName());
         }
         sb.append("),");
         sb.append("updated AS (");
         sb.append("UPDATE ");
         quoteIdentifierString(sb, toTable);