From e4544360d12da7d6fa441a3a41cde7b2068771f4 Mon Sep 17 00:00:00 2001 From: FlechazoW Date: Fri, 20 Oct 2023 16:55:32 +0800 Subject: [PATCH] Add some test. --- .../com/wtz/java/stream/_01_Stream_Test.java | 21 +++++++++ .../main/java/com/wtz/kafka/_01_Consumer.java | 5 +- _09_jdbc/pom.xml | 37 +++++++++++++++ .../java/com/wtz/jdbc/common/_01_Split.java | 46 +++++++++++++++++++ .../wtz/jdbc/hikari/_01_MySQL_HikariCP.java | 36 +++++++++++++++ pom.xml | 1 + 6 files changed, 144 insertions(+), 2 deletions(-) create mode 100644 _05_java/src/main/java/com/wtz/java/stream/_01_Stream_Test.java create mode 100644 _09_jdbc/src/main/java/com/wtz/jdbc/common/_01_Split.java create mode 100644 _09_jdbc/src/main/java/com/wtz/jdbc/hikari/_01_MySQL_HikariCP.java diff --git a/_05_java/src/main/java/com/wtz/java/stream/_01_Stream_Test.java b/_05_java/src/main/java/com/wtz/java/stream/_01_Stream_Test.java new file mode 100644 index 0000000..136ba18 --- /dev/null +++ b/_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 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())); + } +} diff --git a/_06_kafka/src/main/java/com/wtz/kafka/_01_Consumer.java b/_06_kafka/src/main/java/com/wtz/kafka/_01_Consumer.java index efff8e8..d415789 100644 --- a/_06_kafka/src/main/java/com/wtz/kafka/_01_Consumer.java +++ b/_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 consumer = new KafkaConsumer<>(properties); @@ -48,7 +49,7 @@ public static void main(String[] args) throws Exception { for (ConsumerRecord 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); diff --git a/_09_jdbc/pom.xml b/_09_jdbc/pom.xml index cc66cda..ad5120b 100644 --- a/_09_jdbc/pom.xml +++ b/_09_jdbc/pom.xml @@ -7,6 +7,18 @@ org.example 1.0-SNAPSHOT + + + + org.apache.maven.plugins + maven-compiler-plugin + + 9 + 9 + + + + 4.0.0 _09_JDBC @@ -35,6 +47,31 @@ mssql-jdbc 9.2.1.jre8 + + + com.zaxxer + HikariCP + 5.0.0 + + + + + mysql + mysql-connector-java + 8.0.15 + + + + ch.qos.logback + logback-core + 1.2.3 + + + ch.qos.logback + logback-classic + 1.2.3 + + \ No newline at end of file diff --git a/_09_jdbc/src/main/java/com/wtz/jdbc/common/_01_Split.java b/_09_jdbc/src/main/java/com/wtz/jdbc/common/_01_Split.java new file mode 100644 index 0000000..53dc572 --- /dev/null +++ b/_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 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); + } +} diff --git a/_09_jdbc/src/main/java/com/wtz/jdbc/hikari/_01_MySQL_HikariCP.java b/_09_jdbc/src/main/java/com/wtz/jdbc/hikari/_01_MySQL_HikariCP.java new file mode 100644 index 0000000..69b556b --- /dev/null +++ b/_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)); + } + + } + } +} diff --git a/pom.xml b/pom.xml index 3f520b5..5aadb1e 100644 --- a/pom.xml +++ b/pom.xml @@ -22,6 +22,7 @@ _11_ShardingSphere-JDBC _12_Pulsar _13_flink_1_15 + _15_LiteFlow