[shardingsphere] branch master updated: Add emoji text at pipeline E2E test (#23521)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 2263f0c2b53 Add emoji text at pipeline E2E test (#23521)
2263f0c2b53 is described below

commit 2263f0c2b53ac8dc8a9a5209d27cbc05db0ff580
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Fri Jan 13 09:54:21 2023 +0800

    Add emoji text at pipeline E2E test (#23521)
---
 .../framework/helper/PipelineCaseHelper.java        | 15 ++++++++++-----
 .../resources/env/scenario/general/postgresql.xml   | 21 +++++++++++++++++++--
 2 files changed, 29 insertions(+), 7 deletions(-)

diff --git 
a/test/e2e/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/helper/PipelineCaseHelper.java
 
b/test/e2e/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/helper/PipelineCaseHelper.java
index fc939b34597..23624c59d72 100644
--- 
a/test/e2e/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/helper/PipelineCaseHelper.java
+++ 
b/test/e2e/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/framework/helper/PipelineCaseHelper.java
@@ -21,10 +21,12 @@ import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.tuple.Pair;
 import org.apache.shardingsphere.infra.database.type.DatabaseType;
 import org.apache.shardingsphere.infra.database.type.dialect.MySQLDatabaseType;
-import 
org.apache.shardingsphere.test.e2e.data.pipeline.util.AutoIncrementKeyGenerateAlgorithm;
 import 
org.apache.shardingsphere.sharding.algorithm.keygen.SnowflakeKeyGenerateAlgorithm;
+import 
org.apache.shardingsphere.test.e2e.data.pipeline.util.AutoIncrementKeyGenerateAlgorithm;
 
 import java.math.BigDecimal;
+import java.sql.Date;
+import java.sql.Time;
 import java.sql.Timestamp;
 import java.time.LocalDateTime;
 import java.time.OffsetDateTime;
@@ -67,16 +69,19 @@ public final class PipelineCaseHelper {
             LocalDateTime now = LocalDateTime.now();
             int randomInt = generateInt(-100, 100);
             int randomUnsignedInt = generateInt(0, 100);
+            String emojiText = "☠️x☺️x✋x☹️";
             if (databaseType instanceof MySQLDatabaseType) {
-                Object[] addObjs = {orderId, userId, generateString(6), 
randomInt, randomInt, randomInt,
+                Object[] addObjs = {orderId, userId, generateString(6) + "", 
randomInt, randomInt, randomInt,
                         randomUnsignedInt, randomUnsignedInt, 
randomUnsignedInt, randomUnsignedInt, generateFloat(), 
generateDouble(-100000000, 100000000),
                         BigDecimal.valueOf(generateDouble(1, 100)), now, now, 
now.toLocalDate(), now.toLocalTime(), Year.now().getValue(), "1", "t", "e", 
"s", "t", generateString(2),
-                        generateString(1), generateString(1), "1", "2", 
generateJsonString(32)};
+                        emojiText, generateString(1), "1", "2", 
generateJsonString(32)};
                 orderData.add(addObjs);
             } else {
+                long currentTimeMillis = System.currentTimeMillis();
                 orderData.add(new Object[]{orderId, userId, generateString(6), 
randomInt,
-                        BigDecimal.valueOf(generateDouble(1, 100)), true, 
generateString(2), generateString(2), generateFloat(),
-                        generateDouble(0, 1000), 
Timestamp.valueOf(LocalDateTime.now()), OffsetDateTime.now()});
+                        BigDecimal.valueOf(generateDouble(1, 100)), true, 
"bytea".getBytes(), generateString(2), generateString(2), generateFloat(), 
generateDouble(0, 1000),
+                        generateJsonString(8), generateJsonString(12), 
emojiText, new Date(currentTimeMillis), new Time(currentTimeMillis), 
Timestamp.valueOf(LocalDateTime.now()),
+                        OffsetDateTime.now()});
             }
             orderItemData.add(new Object[]{orderItemKeyGenerate.generateKey(), 
orderId, userId, "SUCCESS"});
         }
diff --git 
a/test/e2e/pipeline/src/test/resources/env/scenario/general/postgresql.xml 
b/test/e2e/pipeline/src/test/resources/env/scenario/general/postgresql.xml
index 175c963912e..d73c4343d53 100644
--- a/test/e2e/pipeline/src/test/resources/env/scenario/general/postgresql.xml
+++ b/test/e2e/pipeline/src/test/resources/env/scenario/general/postgresql.xml
@@ -55,8 +55,25 @@
     
     <full-insert-order>
         INSERT INTO
-        
test.%s(order_id,user_id,status,t_int2,t_numeric,t_bool,t_char,t_varchar,t_float,t_double,t_timestmap,t_timestamptz)
-        VALUES (?,?,?,?,?,?,?,?,?,?,?,?)
+        test.%s(order_id,
+        user_id,
+        status,
+        t_int2,
+        t_numeric,
+        t_bool,
+        t_bytea,
+        t_char,
+        t_varchar,
+        t_float,
+        t_double,
+        t_json,
+        t_jsonb,
+        t_text,
+        t_date,
+        t_time,
+        t_timestmap,
+        t_timestamptz)
+        VALUES (?,?,?,?,?,?,?,?,?,?,?,?::json,?::jsonb,?,?,?,?,?)
     </full-insert-order>
     
     <full-insert-order-item>