From 153b2fcd657268aa1afe8a24697b6bf826d9cd11 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E6=B5=A9=E7=84=B6?= <lihaoran2048@qq.com>
Date: Fri, 19 Jul 2024 16:21:20 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=86=E4=B8=80=E4=BA=9Bpo?=
 =?UTF-8?q?m=E6=96=87=E4=BB=B6=EF=BC=8C=E5=A2=9E=E5=8A=A0=E4=BA=86iotdb?=
 =?UTF-8?q?=E4=BE=9D=E8=B5=96=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 datax-example/pom.xml             |   4 +-
 iotdbwriter/doc/iotdbwriter-CN.md |  10 ++
 mysqlwriter/pom.xml               |   3 +-
 pom.xml                           | 148 +++++++++++++++---------------
 4 files changed, 88 insertions(+), 77 deletions(-)

diff --git a/datax-example/pom.xml b/datax-example/pom.xml
index c428aed4..ac50d774 100644
--- a/datax-example/pom.xml
+++ b/datax-example/pom.xml
@@ -13,8 +13,8 @@
     <packaging>pom</packaging>
     <modules>
         <module>datax-example-core</module>
-<!--        <module>datax-example-streamreader</module>-->
-<!--        <module>datax-example-neo4j</module>-->
+        <module>datax-example-streamreader</module>
+        <module>datax-example-neo4j</module>
         <module>datax-example-iotdb</module>
     </modules>
 
diff --git a/iotdbwriter/doc/iotdbwriter-CN.md b/iotdbwriter/doc/iotdbwriter-CN.md
index 508e367a..dc350cac 100644
--- a/iotdbwriter/doc/iotdbwriter-CN.md
+++ b/iotdbwriter/doc/iotdbwriter-CN.md
@@ -75,6 +75,16 @@ IoTDB中设备与列的概念见IoTDB官方文档。
 }
 ```
 
+注意：mysqlreader插件，在src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java 中270行左右，修改了代码，将mysql中的tinyint(1)转为boolean类型
+case Types.SMALLINT:
+case Types.TINYINT:
+  // 将mysql中的tinyint(1)转为boolean类型
+  if (metaData.getPrecision(i) <= 3){
+    record.addColumn(new BoolColumn(rs.getBoolean(i)));
+    break;
+  }
+
+
 ### 3.2 参数说明
 
 * username
diff --git a/mysqlwriter/pom.xml b/mysqlwriter/pom.xml
index 58892850..1c3891f5 100755
--- a/mysqlwriter/pom.xml
+++ b/mysqlwriter/pom.xml
@@ -40,8 +40,7 @@
 		<dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
-			<version>8.0.31</version>
-<!--            <version>${mysql.driver.version}</version>-->
+            <version>${mysql.driver.version}</version>
         </dependency>
 	</dependencies>
 
diff --git a/pom.xml b/pom.xml
index 5f02b891..c6124f00 100644
--- a/pom.xml
+++ b/pom.xml
@@ -48,92 +48,94 @@
 
         <!-- reader -->
         <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>streamreader</module>
-        <module>iotdbreader</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>clickhousereader</module>-->
-<!--        <module>mongodbreader</module>-->
-        <module>tdenginereader</module>
-<!--        <module>gdbreader</module>-->
-<!--        <module>tsdbreader</module>-->
-<!--        <module>opentsdbreader</module>-->
-<!--        <module>loghubreader</module>-->
-<!--        <module>datahubreader</module>-->
-<!--        <module>starrocksreader</module>-->
-<!--        <module>sybasereader</module>-->
-<!--        <module>dorisreader</module>-->
+        <module>clickhousereader</module>
 
+        <module>mongodbreader</module>
+        <module>iotdbreader</module>
+        <module>tdenginereader</module>
+        <module>gdbreader</module>
+        <module>tsdbreader</module>
+        <module>opentsdbreader</module>
+        <module>loghubreader</module>
+        <module>datahubreader</module>
+        <module>starrocksreader</module>
+        <module>sybasereader</module>
+        <module>dorisreader</module>
         <!-- writer -->
         <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>streamwriter</module>
-        <module>iotdbwriter</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>elasticsearchwriter</module>-->
-<!--        <module>mongodbwriter</module>-->
-        <module>tdenginewriter</module>
-<!--        <module>ocswriter</module>-->
-<!--        <module>tsdbwriter</module>-->
-<!--        <module>gdbwriter</module>-->
-<!--        <module>oscarwriter</module>-->
-<!--        <module>loghubwriter</module>-->
-<!--        <module>datahubwriter</module>-->
-<!--        <module>cassandrawriter</module>-->
-<!--        <module>clickhousewriter</module>-->
-<!--        <module>doriswriter</module>-->
-<!--        <module>selectdbwriter</module>-->
-<!--        <module>adbmysqlwriter</module>-->
-<!--        <module>sybasewriter</module>-->
-<!--        <module>neo4jwriter</module>-->
 
+        <module>elasticsearchwriter</module>
+        <module>mongodbwriter</module>
+        <module>tdenginewriter</module>
+        <module>iotdbwriter</module>
+        <module>ocswriter</module>
+        <module>tsdbwriter</module>
+        <module>gdbwriter</module>
+        <module>oscarwriter</module>
+        <module>loghubwriter</module>
+        <module>datahubwriter</module>
+        <module>cassandrawriter</module>
+        <module>clickhousewriter</module>
+        <module>doriswriter</module>
+        <module>selectdbwriter</module>
+        <module>adbmysqlwriter</module>
+        <module>sybasewriter</module>
+        <module>neo4jwriter</module>
         <!-- common support module -->
         <module>plugin-rdbms-util</module>
         <module>plugin-unstructured-storage-util</module>
-<!--        <module>gaussdbreader</module>-->
-<!--        <module>gaussdbwriter</module>-->
+        <module>gaussdbreader</module>
+        <module>gaussdbwriter</module>
         <module>datax-example</module>
 
-
-
     </modules>
 
     <dependencyManagement>