src/main/java/org/embulk/output/jdbc/setter/ColumnSetterVisitor.java in embulk-output-jdbc-0.5.1 vs src/main/java/org/embulk/output/jdbc/setter/ColumnSetterVisitor.java in embulk-output-jdbc-0.6.0

- old
+ new

@@ -77,11 +77,21 @@ throw new RuntimeException(ex); } } @Override - public void jsonColumn(Column column) { - throw new UnsupportedOperationException("This plugin doesn't support json type. Please try to upgrade version of the plugin using 'embulk gem update' command. If the latest version still doesn't support json type, please contact plugin developers, or change configuration of input plugin not to use json type."); + public void jsonColumn(Column column) + { + try { + if (pageReader.isNull(column)) { + setter.nullValue(); + } else { + setter.jsonValue(pageReader.getJson(column)); + } + } catch (IOException | SQLException ex) { + // TODO exception class + throw new RuntimeException(ex); + } } @Override public void timestampColumn(Column column) {