Merge pull request #350 from apecloud/fix/fix_cross_build

1, update mysql-binlog-connector-rust version to 0.3.1 since 0.3.0 has critical bug. 2, fix panic when user manually deleted records in data_marker table.

Author: qianyiwen2019

Cargo.toml

@@ -18,7 +18,7 @@ assigning_clones = "allow"
 [workspace.dependencies]
 sqlx = {git = "https://github.com/qianyiwen2019/sqlx", features = ["runtime-async-std-rustls", "mysql", "postgres", "bigdecimal", "ipnetwork", "mac_address", "bit-vec", "time", "chrono", "json", "uuid"]}
 futures = "0.3.25"
-mysql-binlog-connector-rust = "0.3.0"
+mysql-binlog-connector-rust = "0.3.1"
 serde = {version = "1", features = ["derive"]}
 serde_json = "1.0.87"
 chrono = "0.4.38"

dt-connector/src/data_marker.rs

@@ -100,10 +100,12 @@ impl DataMarker {
             DtData::Dml { row_data } => {
                 // refresh should be only called when dt_data is a data marker
                 // update data_origin_node
-                if let Some(col_value) = row_data.after.as_ref().unwrap().get(DATA_ORIGIN_NODE) {
-                    // mysql, ColValue::Blob
-                    // pg, ColValue::String
-                    self.data_origin_node = col_value.to_string();
+                if let Some(after) = &row_data.after {
+                    if let Some(col_value) = after.get(DATA_ORIGIN_NODE) {
+                        // mysql, ColValue::Blob
+                        // pg, ColValue::String
+                        self.data_origin_node = col_value.to_string();
+                    }
                 }
             }