Skip to content

Commit 95d517f

Browse files
author
Vanshikaa Gupta
committed
provide XML support for oracle plugin
1 parent 085e485 commit 95d517f

2 files changed

Lines changed: 4 additions & 0 deletions

File tree

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -265,6 +265,7 @@ private void handleOracleSpecificType(ResultSet resultSet, StructuredRecord.Buil
265265
switch (sqlType) {
266266
case OracleSourceSchemaReader.INTERVAL_YM:
267267
case OracleSourceSchemaReader.INTERVAL_DS:
268+
case OracleSourceSchemaReader.XML:
268269
case OracleSourceSchemaReader.LONG:
269270
case Types.NCLOB:
270271
recordBuilder.set(field.getName(), resultSet.getString(columnIndex));

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ public class OracleSourceSchemaReader extends CommonSchemaReader {
4444
public static final int BINARY_DOUBLE = 101;
4545
public static final int BFILE = -13;
4646
public static final int LONG = -1;
47+
public static final int XML = 2009;
4748
public static final int LONG_RAW = -4;
4849

4950
/**
@@ -61,6 +62,7 @@ public class OracleSourceSchemaReader extends CommonSchemaReader {
6162
BINARY_DOUBLE,
6263
BFILE,
6364
LONG,
65+
XML,
6466
LONG_RAW,
6567
Types.NUMERIC,
6668
Types.DECIMAL
@@ -102,6 +104,7 @@ public Schema getSchema(ResultSetMetaData metadata, int index) throws SQLExcepti
102104
return Schema.of(Schema.Type.BYTES);
103105
case INTERVAL_DS:
104106
case INTERVAL_YM:
107+
case XML:
105108
case LONG:
106109
return Schema.of(Schema.Type.STRING);
107110
case Types.NUMERIC:

0 commit comments

Comments
 (0)