diff --git a/datax-example/pom.xml b/datax-example/pom.xml index 9c4c9200..c428aed4 100644 --- a/datax-example/pom.xml +++ b/datax-example/pom.xml @@ -13,8 +13,9 @@ pom datax-example-core - datax-example-streamreader - datax-example-neo4j + + + datax-example-iotdb diff --git a/mysqlwriter/pom.xml b/mysqlwriter/pom.xml index 1c3891f5..58892850 100755 --- a/mysqlwriter/pom.xml +++ b/mysqlwriter/pom.xml @@ -40,7 +40,8 @@ mysql mysql-connector-java - ${mysql.driver.version} + 8.0.31 + diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java index f3180402..29f02e46 100755 --- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java +++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java @@ -269,6 +269,11 @@ public class CommonRdbmsReader { case Types.SMALLINT: case Types.TINYINT: + // 将mysql中的tinyint(1)转为boolean类型 + if (metaData.getPrecision(i) <= 3){ + record.addColumn(new BoolColumn(rs.getBoolean(i))); + break; + } case Types.INTEGER: case Types.BIGINT: record.addColumn(new LongColumn(rs.getString(i))); diff --git a/pom.xml b/pom.xml index eeb4bfaf..5f02b891 100644 --- a/pom.xml +++ b/pom.xml @@ -48,92 +48,92 @@ mysqlreader - drdsreader - sqlserverreader - postgresqlreader - kingbaseesreader - oraclereader - cassandrareader - oceanbasev10reader - rdbmsreader - - odpsreader - otsreader - otsstreamreader - hbase11xreader - hbase094xreader - hbase11xsqlreader - hbase20xsqlreader - - ossreader - hdfsreader - ftpreader txtfilereader streamreader - clickhousereader - - mongodbreader + iotdbreader + + + + + + + + + + + + + + + + + + + + tdenginereader - gdbreader - tsdbreader - opentsdbreader - loghubreader - datahubreader - starrocksreader - sybasereader - dorisreader + + + + + + + + + mysqlwriter - starrockswriter - drdswriter - databendwriter - oraclewriter - sqlserverwriter - postgresqlwriter - kingbaseeswriter - adswriter - oceanbasev10writer - adbpgwriter - hologresjdbcwriter - rdbmswriter - - - odpswriter - osswriter - otswriter - hbase11xwriter - hbase094xwriter - hbase11xsqlwriter - hbase20xsqlwriter - kuduwriter - ftpwriter - hdfswriter txtfilewriter streamwriter - - elasticsearchwriter - mongodbwriter + iotdbwriter + + + + + + + + + + + + + + + + + + + + + + + + tdenginewriter - ocswriter - tsdbwriter - gdbwriter - oscarwriter - loghubwriter - datahubwriter - cassandrawriter - clickhousewriter - doriswriter - selectdbwriter - adbmysqlwriter - sybasewriter - neo4jwriter + + + + + + + + + + + + + + plugin-rdbms-util plugin-unstructured-storage-util - gaussdbreader - gaussdbwriter + + datax-example + +