knull
knull
https://github.com/pingcap/tiflow/blob/release-6.5/cdc/sink/mysql/mysql.go#L135 here is function NewMySQLSink, and call 'GetTestDB' to create mysql-connection. in this function, it will decode the password when occur error on sql.Open. The function 'GetTestDB' definition is as...
BTW: if use base64 to encode password, the DDLSink will be created failed. owner.newDDLSink -> owner.ddlSinkInitializer -> factory.New -> mysql.NewMySQLDDLSink -> mysql.CreateMySQLDBConn
你好,方便直接交流吗?