(a *require.Assertions, databaseName string, query string, affectedRows []*v1pb.QueryResult, results []*v1pb.QueryResult)
| 193 | } |
| 194 | |
| 195 | func checkResults(a *require.Assertions, databaseName string, query string, affectedRows []*v1pb.QueryResult, results []*v1pb.QueryResult) { |
| 196 | a.Equal(len(affectedRows), len(results)) |
| 197 | for idx, result := range results { |
| 198 | a.Equal("", result.Error, "database %s: %s", databaseName, query) |
| 199 | result.Latency = nil |
| 200 | affectedRows[idx].Statement = query |
| 201 | diff := cmp.Diff(affectedRows[idx], result, protocmp.Transform(), protocmp.IgnoreMessages(&durationpb.Duration{})) |
| 202 | a.Empty(diff, "database %s: %s", databaseName, query) |
| 203 | } |
| 204 | } |
no test coverage detected