770
ctx context.Context,
771
filter sqlplugin.ReplicationTasksRangeFilter,
772
>
) ([]sqlplugin.ReplicationTasksRow, error) {
execution.go
773
>
var rows []sqlplugin.ReplicationTasksRow
774
>
err := mdb.conn.SelectContext(ctx,
775
>
&rows,
776
>
getReplicationTasksQuery,
777
>
filter.ShardID,
778
>
filter.InclusiveMinTaskID,
779
>
filter.ExclusiveMaxTaskID,
780
>
filter.PageSize,
781
>
)
782
>
return rows, err
783
>
}
784
785
// DeleteFromReplicationTasks deletes one row from replication_tasks table