204
}
205
207
>
shardID := rand.Int31()
208
>
minTaskID := int64(1)
209
>
maxTaskID := int64(101)
210
>
211
>
filter := sqlplugin.ReplicationTasksRangeFilter{
212
>
ShardID: shardID,
213
>
InclusiveMinTaskID: minTaskID,
214
>
ExclusiveMaxTaskID: maxTaskID,
215
>
PageSize: 0,
216
>
}
217
>
result, err := s.store.RangeDeleteFromReplicationTasks(newExecutionContext(), filter)
218
>
s.NoError(err)
219
>
rowsAffected, err := result.RowsAffected()
220
>
s.NoError(err)
221
>
s.Equal(0, int(rowsAffected))
222
>
223
>
rows, err := s.store.RangeSelectFromReplicationTasks(newExecutionContext(), filter)
224
>
s.NoError(err)
225
>
for index := range rows {
226
rows[index].ShardID = shardID
227
}
229
}
230