176
}
177
179
>
shardID := rand.Int31()
180
>
taskID := int64(1)
181
>
182
>
filter := sqlplugin.ReplicationTasksFilter{
183
>
ShardID: shardID,
184
>
TaskID: taskID,
185
>
}
186
>
result, err := s.store.DeleteFromReplicationTasks(newExecutionContext(), filter)
187
>
s.NoError(err)
188
>
rowsAffected, err := result.RowsAffected()
189
>
s.NoError(err)
190
>
s.Equal(0, int(rowsAffected))
191
>
192
>
rangeFilter := sqlplugin.ReplicationTasksRangeFilter{
193
>
ShardID: shardID,
194
>
InclusiveMinTaskID: taskID,
195
>
ExclusiveMaxTaskID: taskID + 1,
196
>
PageSize: 1,
197
>
}
198
>
rows, err := s.store.RangeSelectFromReplicationTasks(newExecutionContext(), rangeFilter)
199
>
s.NoError(err)
200
>
for index := range rows {
201
rows[index].ShardID = shardID
202
}
204
}
205