diff --git a/rdbmsreader/src/main/java/com/alibaba/datax/plugin/reader/rdbmsreader/SubCommonRdbmsReader.java b/rdbmsreader/src/main/java/com/alibaba/datax/plugin/reader/rdbmsreader/SubCommonRdbmsReader.java index b94021bf..787c6460 100755 --- a/rdbmsreader/src/main/java/com/alibaba/datax/plugin/reader/rdbmsreader/SubCommonRdbmsReader.java +++ b/rdbmsreader/src/main/java/com/alibaba/datax/plugin/reader/rdbmsreader/SubCommonRdbmsReader.java @@ -126,7 +126,13 @@ public class SubCommonRdbmsReader extends CommonRdbmsReader { case Types.BIT: record.addColumn(new BoolColumn(rs.getBoolean(i))); break; - + case Types.SQLXML: + String xmlData = null; + if (rs.getSQLXML(i) != null) { + xmlData = rs.getSQLXML(i).getString(); + } + record.addColumn(new StringColumn(xmlData)); + break; case Types.NULL: String stringData = null; if (rs.getObject(i) != null) {