162
}
163
165
>
filter := newChasmNodeMapsAllFilter()
166
>
167
>
var initialRows []sqlplugin.ChasmNodeMapsRow
168
>
for range 10 {
169
>
initialRows = append(initialRows, newChasmRowFromFilter(filter))
170
>
}
171
172
// Delete half of inserted rows.
174
>
var deletedPaths []string
175
>
for _, row := range initialRows[pivot:] {
176
>
deletedPaths = append(deletedPaths, row.ChasmPath)
177
>
}
178
>
expectedRows := initialRows[:pivot]
179
>
180
>
tc := &testCase{
181
>
InsertRows: initialRows,
182
>
DeleteRows: &sqlplugin.ChasmNodeMapsFilter{
183
>
ShardID: filter.ShardID,
184
>
NamespaceID: filter.NamespaceID,
185
>
WorkflowID: filter.WorkflowID,
186
>
RunID: filter.RunID,
187
>
ChasmPaths: deletedPaths,
188
>
},
189
>
ExpectedRowsFilter: filter,
190
>
ExpectedRows: expectedRows,
191
>
}
192
>
s.runTestCase(tc)
193
}
194