@@ -284,7 +284,7 @@ func testPlayerCopyVarcharPKCaseInsensitive(t *testing.T) {
284
284
"/update _vt.vreplication set state='Copying'" ,
285
285
// Copy mode.
286
286
"insert into dst(idc,val) values ('a',1)" ,
287
- `/insert into _vt.copy_state \(lastpk, vrepl_id, table_name\) values \('fields:{name:\ "idc\ " type:VARCHAR charset:45 flags:20483} rows:{lengths:1 values:\"a\ "}'.*` ,
287
+ `/insert into _vt.copy_state \(lastpk, vrepl_id, table_name\) values \('fields:{name:"idc" type:VARCHAR charset:45 flags:20483} rows:{lengths:1 values:"a "}'.*` ,
288
288
// Copy-catchup mode.
289
289
`/insert into dst\(idc,val\) select 'B', 3 from dual where \( .* 'B' COLLATE .* \) <= \( .* 'a' COLLATE .* \)` ,
290
290
).Then (func (expect qh.ExpectationSequencer ) qh.ExpectationSequencer {
@@ -294,11 +294,11 @@ func testPlayerCopyVarcharPKCaseInsensitive(t *testing.T) {
294
294
//upd1 := expect.
295
295
upd1 := expect .Then (qh .Eventually (
296
296
"insert into dst(idc,val) values ('B',3)" ,
297
- `/insert into _vt.copy_state \(lastpk, vrepl_id, table_name\) values \('fields:{name:\ "idc\ " type:VARCHAR charset:45 flags:20483} rows:{lengths:1 values:\"B\ "}'.*` ,
297
+ `/insert into _vt.copy_state \(lastpk, vrepl_id, table_name\) values \('fields:{name:"idc" type:VARCHAR charset:45 flags:20483} rows:{lengths:1 values:"B "}'.*` ,
298
298
))
299
299
upd2 := expect .Then (qh .Eventually (
300
300
"insert into dst(idc,val) values ('c',2)" ,
301
- `/insert into _vt.copy_state \(lastpk, vrepl_id, table_name\) values \('fields:{name:\\ "idc\\ " type:VARCHAR charset:45 flags:20483} rows:{lengths:1 values:\\"c\\ "}'.*` ,
301
+ `/insert into _vt.copy_state \(lastpk, vrepl_id, table_name\) values \('fields:{name:"idc" type:VARCHAR charset:45 flags:20483} rows:{lengths:1 values:"c "}'.*` ,
302
302
))
303
303
upd1 .Then (upd2 .Eventually ())
304
304
return upd2
0 commit comments