(statement string, limit int)
| 321 | } |
| 322 | |
| 323 | func getStatementWithResultLimit(statement string, limit int) string { |
| 324 | limitPart := "" |
| 325 | if limit > 0 { |
| 326 | limitPart = fmt.Sprintf(" LIMIT %d", limit) |
| 327 | } |
| 328 | return fmt.Sprintf("WITH result AS (%s) SELECT * FROM result%s;", util.TrimStatement(statement), limitPart) |
| 329 | } |
| 330 | |
| 331 | func convertValue(v bigquery.Value, fieldType bigquery.FieldType) *v1pb.RowValue { |
| 332 | if v == nil { |
no test coverage detected