Merge pull request #291 from brokercap/v2.3.8

V2.3.8
brokercap · Nov 5, 2024 · e8dabf2 · e8dabf2
2 parents ba0a03e + b0d9d16
commit e8dabf2
Show file tree

Hide file tree

Showing 7 changed files with 28 additions and 9 deletions.
diff --git a/Bristol/mysql/packets.go b/Bristol/mysql/packets.go
@@ -810,10 +810,13 @@ func (mc *mysqlConn) readBinaryRows(rc *rowsContent) (e error) {
 					b := int8(byteToUint8(data[pos]))
 					//length == 1 是 tinyint(1)  bool值
 					if rc.columns[i].length == 1 {
-						if b == 1 {
+						switch b {
+						case 1:
 							row[i] = true
-						} else {
+						case 0:
 							row[i] = false
+						default:
+							row[i] = b
 						}
 					} else {
 						row[i] = b

diff --git a/Bristol/mysql/parser.go b/Bristol/mysql/parser.go
@@ -485,6 +485,11 @@ func (parser *eventParser) GetTableSchemaByName(tableId uint64, database string,
 				CHARACTER_OCTET_LENGTH = uint64(dest[9].(uint32))
 			case uint64:
 				CHARACTER_OCTET_LENGTH = dest[9].(uint64)
+			case int64:
+				CHARACTER_OCTET_LENGTH = uint64(dest[9].(int64))
+			case int32:
+				CHARACTER_OCTET_LENGTH = uint64(dest[9].(int32))
+
 			default:
 				CHARACTER_OCTET_LENGTH = 0
 			}

diff --git a/README.EN.MD b/README.EN.MD
@@ -121,11 +121,11 @@ After compiling, the corresponding platform name folder will be created in the t
 ##### Binary
 
 ```
-wget https://github.com/brokercap/Bifrost/releases/download/v2.3.5-beta/bifrost_v2.3.5-beta_Linux-amd64-bin.tar.gz
+wget https://github.com/brokercap/Bifrost/releases/download/v2.3.6-beta/bifrost_v2.3.6-beta_Linux-amd64-bin.tar.gz
 
-tar -zxvf bifrost_v2.3.5-beta_Linux-amd64-bin.tar.gz
+tar -zxvf bifrost_v2.3.6-beta_Linux-amd64-bin.tar.gz
 
-cd bifrost_v2.3.5-beta_Linux-amd64-bin/bin && chmod a+x ./Bifrost*
+cd bifrost_v2.3.6-beta_Linux-amd64-bin/bin && chmod a+x ./Bifrost*
 
 ```
 

diff --git a/README.MD b/README.MD
@@ -124,11 +124,11 @@ make install prefix=./target
 ##### 二进制文件安装
 `````sh
 
-wget https://github.com/brokercap/Bifrost/releases/download/v2.3.5-beta/bifrost_v2.3.5-beta_Linux-amd64-bin.tar.gz
+wget https://github.com/brokercap/Bifrost/releases/download/v2.3.6-beta/bifrost_v2.3.6-beta_Linux-amd64-bin.tar.gz
 
-tar -zxvf bifrost_v2.3.5-beta_Linux-amd64-bin.tar.gz
+tar -zxvf bifrost_v2.3.6-beta_Linux-amd64-bin.tar.gz
 
-cd bifrost_v2.3.5-beta_Linux-amd64-bin/bin && chmod a+x ./Bifrost*
+cd bifrost_v2.3.6-beta_Linux-amd64-bin/bin && chmod a+x ./Bifrost*
 
 `````
 

diff --git a/changelog.txt b/changelog.txt
@@ -1,3 +1,13 @@
+v2.3.8-beta   2024-11-05
+1. fix mysql select tinyint(1) , value > 1 , transfer to bool ,result false bug
+
+v2.3.7-beta   2024-10-16
+1. output kakfa tableMap add binlog_timestamp field
+2. CHARACTER_OCTET_LENGTH add support for int64 and int32 in mysql parser
+
+v2.3.6-beta   2024-04-21
+1. input varchar(255) to output starrocks varchar(765)
+
 v2.3.5-beta   2024-04-05
 1. fixed output starrocks varchar(255) tansfer error bug https://github.com/brokercap/Bifrost/issues/266
 2. 修复mongo数据源全量功能无效的bug https://github.com/brokercap/Bifrost/issues/272

diff --git a/config/version.go b/config/version.go
@@ -16,4 +16,4 @@ limitations under the License.
 
 package config
 
-const VERSION = "v2.3.5-beta"
+const VERSION = "v2.3.8-beta"
diff --git a/plugin/driver/table_map_json.go b/plugin/driver/table_map_json.go
@@ -19,6 +19,7 @@ func (c *PluginDataType) ToTableMapObject() (data map[string]interface{}, err er
 	} else {
 		data["bifrost_query"] = c.Query
 	}
+	data["binlog_timestamp"] = fmt.Sprint(c.Timestamp)
 	data["binlog_event_type"] = c.EventType
 	data["bifrost_pri"] = strings.Join(c.Pri, ",")
 	data["bifrost_database"] = c.SchemaName
Original file line number	Diff line number	Diff line change
Expand Up		@@ -16,4 +16,4 @@ limitations under the License.

		package config

		const VERSION = "v2.3.5-beta"
		const VERSION = "v2.3.8-beta"