Add some test.

_05_java/src/main/java/com/wtz/java/stream/_01_Stream_Test.java

@@ -0,0 +1,21 @@
+package com.wtz.java.stream;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class _01_Stream_Test {
+    public static void main(String[] args) {
+        Map<String, Object> testMap = new HashMap<>();
+        testMap.put("a", "b");
+        testMap.put("b", "c");
+        testMap.put("c", "d");
+        testMap.put("d", "e");
+
+        String testStr = "a";
+
+        testMap.entrySet()
+                .stream()
+                .filter(entry -> !testStr.contains(entry.getKey()))
+                .forEach(entry -> System.out.println(entry.getKey() + ": " + entry.getValue()));
+    }
+}

_06_kafka/src/main/java/com/wtz/kafka/_01_Consumer.java

@@ -13,6 +13,7 @@
 import java.io.FileOutputStream;
 import java.io.InputStream;
 import java.io.OutputStream;
+import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.time.Duration;
 import java.util.Arrays;
@@ -37,7 +38,7 @@ public static void main(String[] args) throws Exception {
         properties.put(ConsumerConfig.GROUP_ID_CONFIG, GROUP_ID);
         properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, ByteArrayDeserializer.class.getName());
         properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ByteArrayDeserializer.class.getName());
-        properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
+        properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
 
         KafkaConsumer<Object, Object> consumer = new KafkaConsumer<>(properties);
 
@@ -48,7 +49,7 @@ public static void main(String[] args) throws Exception {
             for (ConsumerRecord<Object, Object> next : records) {
                 Object value = next.value();
                 if (value instanceof byte[]) {
-                    System.out.println(new String((byte[]) value, StandardCharsets.UTF_8));
+                    System.out.println(new String((byte[]) value, StandardCharsets.ISO_8859_1));
 //                    System.out.println(new String((byte[]) value, StandardCharsets.ISO_8859_1));
 //                    System.out.println(new String((byte[]) value, StandardCharsets.US_ASCII));
 //                    System.out.println(next);

_09_jdbc/pom.xml

@@ -7,6 +7,18 @@
         <groupId>org.example</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>9</source>
+                    <target>9</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>_09_JDBC</artifactId>
@@ -35,6 +47,31 @@
             <artifactId>mssql-jdbc</artifactId>
             <version>9.2.1.jre8</version>
         </dependency>
+
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>5.0.0</version>
+        </dependency>
+
+        <!-- mysql驱动 -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.15</version>
+        </dependency>
+        <!-- log -->
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-core</artifactId>
+            <version>1.2.3</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.2.3</version>
+        </dependency>
+
     </dependencies>
 
 </project>

_09_jdbc/src/main/java/com/wtz/jdbc/common/_01_Split.java

@@ -0,0 +1,46 @@
+package com.wtz.jdbc.common;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+import java.util.stream.Collectors;
+
+public class _01_Split {
+
+    public static void main(String[] args) {
+        streamTest();
+    }
+
+    public static void splitTest() {
+        String name = "dbName.tableName";
+        String escapeCharacter = "`";
+        StringBuilder result = new StringBuilder();
+        String[] split = name.split("\\.");
+        for (String param : split) {
+            result.append(escapeCharacter).append(param).append(escapeCharacter).append(".");
+        }
+
+        System.out.println(result);
+
+        String collect = Arrays.stream(split).map(item -> escapeCharacter + item + escapeCharacter).collect(Collectors.joining("."));
+        System.out.println(collect);
+    }
+
+    public static void streamTest() {
+        Map<String, String> parameters = new HashMap<>();
+        String url = "jdbc:mysql?useSSL";
+
+        parameters.put("serverTimezone", "Asia/Shanghai");
+        parameters.put("useSSL", "false");
+        parameters.put("allowPublicKeyRetrieval", "true");
+
+        Properties properties = new Properties();
+        parameters.entrySet()
+                .stream()
+                .filter(entry -> !url.contains(entry.getKey()))
+                .forEach(entry -> properties.put(entry.getKey(), entry.getValue()));
+
+        System.out.println(properties);
+    }
+}

_09_jdbc/src/main/java/com/wtz/jdbc/hikari/_01_MySQL_HikariCP.java

@@ -0,0 +1,36 @@
+package com.wtz.jdbc.hikari;
+
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Properties;
+
+public class _01_MySQL_HikariCP {
+    public static void main(String[] args) throws SQLException {
+        HikariConfig hikariConfig = new HikariConfig();
+
+        hikariConfig.setJdbcUrl("jdbc:mysql://localhost:3306?useSSL=true");
+        hikariConfig.setUsername("root");
+        hikariConfig.setPassword("admin123");
+
+        Properties properties = new Properties();
+
+        hikariConfig.setDataSourceProperties(properties);
+
+        HikariDataSource hikariDataSource = new HikariDataSource(hikariConfig);
+
+        try(Connection connection = hikariDataSource.getConnection();
+            Statement statement = connection.createStatement();
+            ResultSet resultSet = statement.executeQuery("select * from wentz._01_Sink")) {
+            while (resultSet.next()) {
+                System.out.println(resultSet.getObject(1));
+                System.out.println(resultSet.getObject(2));
+            }
+
+        }
+    }
+}

pom.xml

@@ -22,6 +22,7 @@
         <module>_11_ShardingSphere-JDBC</module>
         <module>_12_Pulsar</module>
         <module>_13_flink_1_15</module>
+        <module>_15_LiteFlow</module>
 <!--        <module>_14_Inceptor</module>-->
     </modules>