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

核心代码和pom修改

Browse Source
This commit is contained in:
李浩然 2024-06-24 19:32:38 +08:00
parent 1235819d62
commit a58f58f3e6
4 changed files with 83 additions and 76 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
datax-example/pom.xml
View File

@ -13,8 +13,9 @@
<packaging>pom</packaging> <packaging>pom</packaging>
<modules> <modules>
<module>datax-example-core</module> <module>datax-example-core</module>
<module>datax-example-streamreader</module> <!-- <module>datax-example-streamreader</module>-->
<module>datax-example-neo4j</module> <!-- <module>datax-example-neo4j</module>-->
<module>datax-example-iotdb</module>
</modules> </modules>
<properties> <properties>

3
mysqlwriter/pom.xml
View File

@ -40,7 +40,8 @@
<dependency> <dependency>
<groupId>mysql</groupId> <groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId> <artifactId>mysql-connector-java</artifactId>
<version>${mysql.driver.version}</version> <version>8.0.31</version>
<!-- <version>${mysql.driver.version}</version>-->
</dependency> </dependency>
</dependencies> </dependencies>

5
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java
View File

@ -269,6 +269,11 @@ public class CommonRdbmsReader {
case Types.SMALLINT: case Types.SMALLINT:
case Types.TINYINT: 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.INTEGER:
case Types.BIGINT: case Types.BIGINT:
record.addColumn(new LongColumn(rs.getString(i))); record.addColumn(new LongColumn(rs.getString(i)));

146
pom.xml
View File

@ -48,92 +48,92 @@
<!-- reader --> <!-- reader -->
<module>mysqlreader</module> <module>mysqlreader</module>
<module>drdsreader</module>
<module>sqlserverreader</module>
<module>postgresqlreader</module>
<module>kingbaseesreader</module>
<module>oraclereader</module>
<module>cassandrareader</module>
<module>oceanbasev10reader</module>
<module>rdbmsreader</module>
<module>odpsreader</module>
<module>otsreader</module>
<module>otsstreamreader</module>
<module>hbase11xreader</module>
<module>hbase094xreader</module>
<module>hbase11xsqlreader</module>
<module>hbase20xsqlreader</module>
<module>ossreader</module>
<module>hdfsreader</module>
<module>ftpreader</module>
<module>txtfilereader</module> <module>txtfilereader</module>
<module>streamreader</module> <module>streamreader</module>
<module>clickhousereader</module> <module>iotdbreader</module>
<!-- <module>drdsreader</module>-->
<module>mongodbreader</module> <!-- <module>sqlserverreader</module>-->
<!-- <module>postgresqlreader</module>-->
<!-- <module>kingbaseesreader</module>-->
<!-- <module>oraclereader</module>-->
<!-- <module>cassandrareader</module>-->
<!-- <module>oceanbasev10reader</module>-->
<!-- <module>rdbmsreader</module>-->
<!-- <module>odpsreader</module>-->
<!-- <module>otsreader</module>-->
<!-- <module>otsstreamreader</module>-->
<!-- <module>hbase11xreader</module>-->
<!-- <module>hbase094xreader</module>-->
<!-- <module>hbase11xsqlreader</module>-->
<!-- <module>hbase20xsqlreader</module>-->
<!-- <module>ossreader</module>-->
<!-- <module>hdfsreader</module>-->
<!-- <module>ftpreader</module>-->
<!-- <module>clickhousereader</module>-->
<!-- <module>mongodbreader</module>-->
<module>tdenginereader</module> <module>tdenginereader</module>
<module>gdbreader</module> <!-- <module>gdbreader</module>-->
<module>tsdbreader</module> <!-- <module>tsdbreader</module>-->
<module>opentsdbreader</module> <!-- <module>opentsdbreader</module>-->
<module>loghubreader</module> <!-- <module>loghubreader</module>-->
<module>datahubreader</module> <!-- <module>datahubreader</module>-->
<module>starrocksreader</module> <!-- <module>starrocksreader</module>-->
<module>sybasereader</module> <!-- <module>sybasereader</module>-->
<module>dorisreader</module> <!-- <module>dorisreader</module>-->
<!-- writer --> <!-- writer -->
<module>mysqlwriter</module> <module>mysqlwriter</module>
<module>starrockswriter</module>
<module>drdswriter</module>
<module>databendwriter</module>
<module>oraclewriter</module>
<module>sqlserverwriter</module>
<module>postgresqlwriter</module>
<module>kingbaseeswriter</module>
<module>adswriter</module>
<module>oceanbasev10writer</module>
<module>adbpgwriter</module>
<module>hologresjdbcwriter</module>
<module>rdbmswriter</module>
<module>odpswriter</module>
<module>osswriter</module>
<module>otswriter</module>
<module>hbase11xwriter</module>
<module>hbase094xwriter</module>
<module>hbase11xsqlwriter</module>
<module>hbase20xsqlwriter</module>
<module>kuduwriter</module>
<module>ftpwriter</module>
<module>hdfswriter</module>
<module>txtfilewriter</module> <module>txtfilewriter</module>
<module>streamwriter</module> <module>streamwriter</module>
<module>iotdbwriter</module>
<module>elasticsearchwriter</module> <!-- <module>starrockswriter</module>-->
<module>mongodbwriter</module> <!-- <module>drdswriter</module>-->
<!-- <module>databendwriter</module>-->
<!-- <module>oraclewriter</module>-->
<!-- <module>sqlserverwriter</module>-->
<!-- <module>postgresqlwriter</module>-->
<!-- <module>kingbaseeswriter</module>-->
<!-- <module>adswriter</module>-->
<!-- <module>oceanbasev10writer</module>-->
<!-- <module>adbpgwriter</module>-->
<!-- <module>hologresjdbcwriter</module>-->
<!-- <module>rdbmswriter</module>-->
<!-- <module>odpswriter</module>-->
<!-- <module>osswriter</module>-->
<!-- <module>otswriter</module>-->
<!-- <module>hbase11xwriter</module>-->
<!-- <module>hbase094xwriter</module>-->
<!-- <module>hbase11xsqlwriter</module>-->
<!-- <module>hbase20xsqlwriter</module>-->
<!-- <module>kuduwriter</module>-->
<!-- <module>ftpwriter</module>-->
<!-- <module>hdfswriter</module>-->
<!-- <module>elasticsearchwriter</module>-->
<!-- <module>mongodbwriter</module>-->
<module>tdenginewriter</module> <module>tdenginewriter</module>
<module>ocswriter</module> <!-- <module>ocswriter</module>-->
<module>tsdbwriter</module> <!-- <module>tsdbwriter</module>-->
<module>gdbwriter</module> <!-- <module>gdbwriter</module>-->
<module>oscarwriter</module> <!-- <module>oscarwriter</module>-->
<module>loghubwriter</module> <!-- <module>loghubwriter</module>-->
<module>datahubwriter</module> <!-- <module>datahubwriter</module>-->
<module>cassandrawriter</module> <!-- <module>cassandrawriter</module>-->
<module>clickhousewriter</module> <!-- <module>clickhousewriter</module>-->
<module>doriswriter</module> <!-- <module>doriswriter</module>-->
<module>selectdbwriter</module> <!-- <module>selectdbwriter</module>-->
<module>adbmysqlwriter</module> <!-- <module>adbmysqlwriter</module>-->
<module>sybasewriter</module> <!-- <module>sybasewriter</module>-->
<module>neo4jwriter</module> <!-- <module>neo4jwriter</module>-->
<!-- common support module --> <!-- common support module -->
<module>plugin-rdbms-util</module> <module>plugin-rdbms-util</module>
<module>plugin-unstructured-storage-util</module> <module>plugin-unstructured-storage-util</module>
<module>gaussdbreader</module> <!-- <module>gaussdbreader</module>-->
<module>gaussdbwriter</module> <!-- <module>gaussdbwriter</module>-->
<module>datax-example</module> <module>datax-example</module>
</modules> </modules>
<dependencyManagement> <dependencyManagement>