add config of mysql charset (#103)

Author: WangXiangUSTC

etc/river.toml

@@ -3,6 +3,7 @@
 my_addr = "127.0.0.1:3306"
 my_user = "root"
 my_pass = ""
+my_charset = "utf8"
 
 # Elasticsearch address
 es_addr = "127.0.0.1:9200"

glide.lock

@@ -7,7 +7,7 @@ import:
 - package: github.com/satori/go.uuid
   version: ^1.1.0
 - package: github.com/siddontang/go-mysql
-  version: 3fef0652795ca3a9d47e4af1a2f6d885e574e9bb
+  version: ead11cac47bd127a8c667efa07f171a9143d8a25
   subpackages:
   - canal
   - client

glide.yaml

@@ -17,6 +17,7 @@ type Config struct {
 	MyAddr     string `toml:"my_addr"`
 	MyUser     string `toml:"my_user"`
 	MyPassword string `toml:"my_pass"`
+	MyCharset  string `toml:"my_charset"`
 
 	ESAddr string `toml:"es_addr"`
 

river/config.go

@@ -79,6 +79,7 @@ func (r *River) newCanal() error {
 	cfg.Addr = r.c.MyAddr
 	cfg.User = r.c.MyUser
 	cfg.Password = r.c.MyPassword
+	cfg.Charset = r.c.MyCharset
 	cfg.Flavor = r.c.Flavor
 
 	cfg.ServerID = r.c.ServerID
@@ -234,6 +235,7 @@ func (r *River) prepareRule() error {
 		if len(rule.TableInfo.PKColumns) == 0 {
 			return errors.Errorf("%s.%s must have a PK for a column", rule.Schema, rule.Table)
 		}
+
 	}
 
 	return nil

river/river.go

@@ -59,6 +59,7 @@ func (s *riverTestSuite) SetUpSuite(c *C) {
 	cfg.MyAddr = *my_addr
 	cfg.MyUser = "root"
 	cfg.MyPassword = ""
+	cfg.MyCharset = "utf8"
 	cfg.ESAddr = *es_addr
 
 	cfg.ServerID = 1001
@@ -121,7 +122,7 @@ func (s *riverTestSuite) TestConfig(c *C) {
 my_addr = "127.0.0.1:3306"
 my_user = "root"
 my_pass = ""
-
+my_charset = "utf8"
 es_addr = "127.0.0.1:9200"
 
 data_dir = "./var"