#205 fix (#206)

M2shad0w · siddontang · commit 81d903fddd01 · 2018-03-06T11:17:26.000+08:00
diff --git a/river/sync.go b/river/sync.go
@@ -314,7 +314,7 @@ func (r *River) makeReqColumnData(col *schema.TableColumn, value interface{}) in
 		if err == nil && f != nil {
 			return f
 		}
-	case schema.TYPE_DATETIME:
+	case schema.TYPE_DATETIME, schema.TYPE_TIMESTAMP:
 		switch v := value.(type) {
 		case string:
 			vt, _ := time.ParseInLocation(mysql.TimeFormat, string(v), time.Local)

Original file line number	Diff line number	Diff line change
`@@ -314,7 +314,7 @@ func (r River) makeReqColumnData(col schema.TableColumn, value interface{}) in`
`314`	`314`	`if err == nil && f != nil {`
`315`	`315`	`return f`
`316`	`316`	`}`
`317`		`- case schema.TYPE_DATETIME:`
	`317`	`+ case schema.TYPE_DATETIME, schema.TYPE_TIMESTAMP:`
`318`	`318`	`switch v := value.(type) {`
`319`	`319`	`case string:`
`320`	`320`	`vt, _ := time.ParseInLocation(mysql.TimeFormat, string(v), time.Local)`