github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-19 02:19:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: Fix the problem that the column type is ignored when it is varchar

Browse Source
This commit is contained in:
秦冲 2022-12-28 10:59:34 +08:00
parent 78d5a7b612
commit f772adad0d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java
View File

@ -1,6 +1,7 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.reader;
import com.alibaba.datax.common.element.*; import com.alibaba.datax.common.element.*;
import com.alibaba.datax.common.element.Record;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import com.alibaba.datax.common.plugin.RecordSender; import com.alibaba.datax.common.plugin.RecordSender;
import com.alibaba.datax.common.spi.Reader; import com.alibaba.datax.common.spi.Reader;
@ -15,8 +16,6 @@ import java.sql.*;
import java.text.ParseException; import java.text.ParseException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List; import java.util.List;
public class TDengineReader extends Reader { public class TDengineReader extends Reader {
@ -240,6 +239,7 @@ public class TDengineReader extends Reader {
record.addColumn(new DateColumn(rs.getTimestamp(i))); record.addColumn(new DateColumn(rs.getTimestamp(i)));
break; break;
case Types.BINARY: case Types.BINARY:
case Types.VARCHAR:
record.addColumn(new BytesColumn(rs.getBytes(i))); record.addColumn(new BytesColumn(rs.getBytes(i)));
break; break;
case Types.NCHAR: case Types.NCHAR: