|
1 | 1 | package replication
|
2 | 2 |
|
3 | 3 | import (
|
4 |
| - "fmt" |
5 | 4 | "testing"
|
6 | 5 |
|
7 |
| - "github.com/pingcap/errors" |
8 | 6 | "github.com/shopspring/decimal"
|
9 | 7 | "github.com/stretchr/testify/require"
|
10 | 8 |
|
11 | 9 | "github.com/go-mysql-org/go-mysql/mysql"
|
12 | 10 | )
|
13 | 11 |
|
14 |
| -func check(params []interface{}, names []string) error { |
15 |
| - var test int |
16 |
| - val := struct { |
17 |
| - Value decimal.Decimal |
18 |
| - Pos int |
19 |
| - Err error |
20 |
| - EValue decimal.Decimal |
21 |
| - EPos int |
22 |
| - EErr error |
23 |
| - }{} |
24 |
| - |
25 |
| - for i, name := range names { |
26 |
| - switch name { |
27 |
| - case "obtainedValue": |
28 |
| - val.Value, _ = params[i].(decimal.Decimal) |
29 |
| - case "obtainedPos": |
30 |
| - val.Pos, _ = params[i].(int) |
31 |
| - case "obtainedErr": |
32 |
| - val.Err, _ = params[i].(error) |
33 |
| - case "expectedValue": |
34 |
| - val.EValue, _ = params[i].(decimal.Decimal) |
35 |
| - case "expectedPos": |
36 |
| - val.EPos, _ = params[i].(int) |
37 |
| - case "expectedErr": |
38 |
| - val.EErr, _ = params[i].(error) |
39 |
| - case "caseNumber": |
40 |
| - test = params[i].(int) |
41 |
| - } |
42 |
| - } |
43 |
| - errorMsgFmt := fmt.Sprintf("For Test %v: ", test) + "Did not get expected %v(%v), got %v instead." |
44 |
| - if val.Err != val.EErr { |
45 |
| - return errors.Errorf(errorMsgFmt, "error", val.EErr, val.Err) |
46 |
| - } |
47 |
| - if val.Pos != val.EPos { |
48 |
| - return errors.Errorf(errorMsgFmt, "position", val.EPos, val.Pos) |
49 |
| - } |
50 |
| - if !val.Value.Equal(val.EValue) { |
51 |
| - return errors.Errorf(errorMsgFmt, "value", val.EValue, val.Value) |
52 |
| - } |
53 |
| - return nil |
54 |
| -} |
55 |
| - |
56 | 12 | func TestDecodeDecimal(t *testing.T) {
|
57 | 13 | // _PLACEHOLDER_ := 0
|
58 | 14 | testcases := []struct {
|
@@ -1180,7 +1136,7 @@ func TestInvalidEvent(t *testing.T) {
|
1180 | 1136 | e2.tables = map[uint64]*TableMapEvent{}
|
1181 | 1137 | e2.tables[0x140] = table
|
1182 | 1138 | err := e2.Decode([]byte(data))
|
1183 |
| - require.NoError(t, err) |
| 1139 | + require.Error(t, err) |
1184 | 1140 | }
|
1185 | 1141 |
|
1186 | 1142 | func TestDecodeTime2(t *testing.T) {
|
|
0 commit comments