diff: fix sourcetable in table struct diff (pingcap#122)

amyangfei · web-flow · commit 94e36e48b3d1 · 2018-11-16T14:00:54.000+08:00
diff --git a/pkg/diff/diff.go b/pkg/diff/diff.go
@@ -128,7 +128,7 @@ func (t *TableDiff) CheckTableStruct(ctx context.Context) (bool, error) {
 	t.TargetTable.info = removeColumns(tableInfo, t.RemoveColumns)
 
 	for _, sourceTable := range t.SourceTables {
-		tableInfo, err := dbutil.GetTableInfoWithRowID(ctx, t.TargetTable.Conn, t.TargetTable.Schema, t.TargetTable.Table, t.UseRowID)
+		tableInfo, err := dbutil.GetTableInfoWithRowID(ctx, sourceTable.Conn, sourceTable.Schema, sourceTable.Table, t.UseRowID)
 		if err != nil {
 			return false, errors.Trace(err)
 		}

Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ func (t *TableDiff) CheckTableStruct(ctx context.Context) (bool, error) {`
`128`	`128`	`t.TargetTable.info = removeColumns(tableInfo, t.RemoveColumns)`
`129`	`129`
`130`	`130`	`for _, sourceTable := range t.SourceTables {`
`131`		`- tableInfo, err := dbutil.GetTableInfoWithRowID(ctx, t.TargetTable.Conn, t.TargetTable.Schema, t.TargetTable.Table, t.UseRowID)`
	`131`	`+ tableInfo, err := dbutil.GetTableInfoWithRowID(ctx, sourceTable.Conn, sourceTable.Schema, sourceTable.Table, t.UseRowID)`
`132`	`132`	`if err != nil {`
`133`	`133`	`return false, errors.Trace(err)`
`134`	`134`	`}`