[pulsar] branch branch-3.0 updated: [fix][io] add protobuf ByteString to pulsar-io jdbc core (#20259)

[yubiao]

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

yubiao pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 952ff168593 [fix][io] add protobuf ByteString to pulsar-io jdbc core 
(#20259)
952ff168593 is described below

commit 952ff16859312dfd0902d7daa5be284fe4bfc86a
Author: Benjamin Pereto <d...@sandchaschte.ch>
AuthorDate: Wed May 10 06:50:26 2023 +0200

    [fix][io] add protobuf ByteString to pulsar-io jdbc core (#20259)
    
    Signed-off-by: tison <wander4...@gmail.com>
    Co-authored-by: tison <wander4...@gmail.com>
    (cherry picked from commit 849cbf3a46cc7e85fca6500c08ab6efb8697f12e)
---
 pom.xml                                                            | 2 +-
 pulsar-io/jdbc/core/pom.xml                                        | 7 +++++++
 .../java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java     | 5 ++++-
 3 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 44e8d0aaca6..b522ea935b0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -183,7 +183,7 @@ flexible messaging model and an intuitive client 
API.</description>
     <sqlite-jdbc.version>3.42.0.0</sqlite-jdbc.version>
     <mysql-jdbc.version>8.0.11</mysql-jdbc.version>
     <postgresql-jdbc.version>42.5.1</postgresql-jdbc.version>
-    <clickhouse-jdbc.version>0.3.2-patch11</clickhouse-jdbc.version>
+    <clickhouse-jdbc.version>0.4.6</clickhouse-jdbc.version>
     <mariadb-jdbc.version>2.7.5</mariadb-jdbc.version>
     <openmldb-jdbc.version>0.4.4-hotfix1</openmldb-jdbc.version>
     <hdfs-offload-version3>3.3.5</hdfs-offload-version3>
diff --git a/pulsar-io/jdbc/core/pom.xml b/pulsar-io/jdbc/core/pom.xml
index cda23a91144..4f4fa23d0cc 100644
--- a/pulsar-io/jdbc/core/pom.xml
+++ b/pulsar-io/jdbc/core/pom.xml
@@ -58,6 +58,13 @@
       <groupId>com.fasterxml.jackson.dataformat</groupId>
       <artifactId>jackson-dataformat-yaml</artifactId>
     </dependency>
+
+    <dependency>
+      <groupId>com.google.protobuf</groupId>
+      <artifactId>protobuf-java</artifactId>
+      <scope>provided</scope>
+    </dependency>
+
   </dependencies>
 
 </project>
\ No newline at end of file
diff --git 
a/pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java
 
b/pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java
index 1c98069403c..36c36740919 100644
--- 
a/pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java
+++ 
b/pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java
@@ -20,6 +20,7 @@ package org.apache.pulsar.io.jdbc;
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.google.common.annotations.VisibleForTesting;
+import com.google.protobuf.ByteString;
 import java.sql.PreparedStatement;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -185,8 +186,10 @@ public abstract class BaseJdbcAutoSchemaSink extends 
JdbcAbstractSink<GenericObj
             statement.setString(index, (String) value);
         } else if (value instanceof Short) {
             statement.setShort(index, (Short) value);
+        } else if (value instanceof ByteString) {
+            statement.setBytes(index, ((ByteString) value).toByteArray());
         } else {
-            throw new Exception("Not support value type, need to add it. " + 
value.getClass());
+            throw new Exception("Not supported value type, need to add it. " + 
value.getClass());
         }
     }