@@ -76,18 +76,18 @@ CREATE TABLE IF NOT EXISTS `order_line` (
76
76
仅将冲突数据添加到目的 TiDB 中的 ` lightning_task_info.conflict_error_v1 ` 表中。该表结构如下:
77
77
78
78
``` sql
79
- CREATE TABLE ' conflict_error_v1 ' (
80
- ' task_id' bigint NOT NULL ,
81
- ' create_time' datetime(6 ) NOT NULL DEFAULT now(6 ),
82
- ' table_name' varchar (261 ) NOT NULL ,
83
- ' index_name' varchar (128 ) NOT NULL ,
84
- ' key_data' text NOT NULL ,
85
- ' row_data' text NOT NULL ,
86
- ' raw_key' mediumblob NOT NULL ,
87
- ' raw_value' mediumblob NOT NULL ,
88
- ' raw_handle' mediumblob NOT NULL ,
89
- ' raw_row' mediumblob NOT NULL ,
90
- KEY (task_id, table_name)
79
+ CREATE TABLE conflict_error_v1 (
80
+ task_id bigint NOT NULL ,
81
+ create_time datetime(6 ) NOT NULL DEFAULT now(6 ),
82
+ table_name varchar (261 ) NOT NULL ,
83
+ index_name varchar (128 ) NOT NULL ,
84
+ key_data text NOT NULL ,
85
+ row_data text NOT NULL ,
86
+ raw_key mediumblob NOT NULL ,
87
+ raw_value mediumblob NOT NULL ,
88
+ raw_handle mediumblob NOT NULL ,
89
+ raw_row mediumblob NOT NULL ,
90
+ KEY (task_id, table_name)
91
91
);
92
92
```
93
93
@@ -103,11 +103,11 @@ record 模式会保留所有数据,并跳过 checksum 环节,因此 lightnin
103
103
104
104
```
105
105
mysql> select table_name,index_name,key_data,row_data from conflict_error_v1;
106
+
107
+ table_name | index_name | key_data |row_data
106
108
+---------------------+------------+----------+-----------------------------------------------------------------------------+
107
- table_name | index_name | key_data |row_data
108
- +---------------------+------------+----------+-----------------------------------------------------------------------------+
109
- `tpcc`.`order_line` | PRIMARY | 2 | (2677, 10, 10, 11, 75656, 10, NULL, 5, 5831.97, "HT5DN3EVb6kWTd4L37bsbogj")
110
- `tpcc`.`order_line` | PRIMARY | 3 | (2677, 10, 10, 11, 75656, 10, NULL, 6, 6666.66, "HT5DN3EVb6kWTd4L37bsbogj")
109
+ `tpcc`.`order_line` | PRIMARY | 2 | (2677, 10, 10, 11, 75656, 10, NULL, 5, 5831.97, "HT5DN3EVb6kWTd4L37bsbogj")
110
+ `tpcc`.`order_line` | PRIMARY | 3 | (2677, 10, 10, 11, 75656, 10, NULL, 6, 6666.66, "HT5DN3EVb6kWTd4L37bsbogj")
111
111
+---------------------+------------+----------------------------------------------------------------------------------------+
112
112
```
113
113
0 commit comments