add serverTimeZone option for mysql source (#110)

hstreamdb · Aug 19, 2024 · 3e1a7e1 · 3e1a7e1
1 parent 1ce4aa1
commit 3e1a7e1
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/source-debezium/app/src/main/java/source/debezium/MysqlSourceTask.java b/source-debezium/app/src/main/java/source/debezium/MysqlSourceTask.java
@@ -17,6 +17,9 @@ public void run(HRecord cfg, SourceTaskContext ctx) {
         if (table.split("\\.").length == 1) {
             props.setProperty("table.include.list", dbname + "." + table);
         }
+        if(cfg.contains("serverTimeZone")){
+            props.setProperty("database.connectionTimeZone ", cfg.getString("serverTimeZone"));
+        }
         super.run(cfg, ctx);
     }
 

diff --git a/source-debezium/app/src/main/resources/source_mysql_spec.json b/source-debezium/app/src/main/resources/source_mysql_spec.json
@@ -42,8 +42,14 @@
       "description": "table name of the database",
       "type": "string",
       "examples": ["t1", "public.t1"]
+    },
+    "serverTimeZone": {
+      "title": "Server Time Zone",
+      "description": "configured server timezone",
+      "type": "string",
+      "examples": ["UTC"]
     }
   },
   "required": [ "stream", "host", "port", "user", "password", "database", "table" ],
-  "ui:order": [ "stream", "host", "port", "user", "password", "database", "table" ]
+  "ui:order": [ "stream", "host", "port", "user", "password", "serverTimeZone", "database", "table" ]
 }