Minor fix

Author: eitam

canal/canal.go

@@ -439,8 +439,11 @@ func (c *Canal) GenerateCharsetQuery() (string, error) {
  SELECT 
  c.ORDINAL_POSITION,
  COALESCE(
- c.CHARACTER_SET_NAME,
- col.CHARACTER_SET_NAME,
+ CASE 
+ WHEN c.CHARACTER_SET_NAME IS NOT NULL THEN c.CHARACTER_SET_NAME
+ WHEN c.DATA_TYPE IN ('binary','varbinary','tinyblob','blob','mediumblob','longblob') THEN col.CHARACTER_SET_NAME
+ ELSE col.CHARACTER_SET_NAME
+ END,
  'utf8mb4'
  ) AS CHARACTER_SET_NAME,
  c.COLUMN_NAME