Collect SQL for TPC-H queries.
()
| 127 | |
| 128 | /// Collect SQL for TPC-H queries. |
| 129 | fn tpch_queries() -> Vec<TestQuery> { |
| 130 | let mut queries = vec![]; |
| 131 | for path in BENCHMARK_PATHS { |
| 132 | let dir = format!("{path}queries/"); |
| 133 | println!("Reading TPC-H queries from {dir}"); |
| 134 | if let Ok(dir) = std::fs::read_dir(dir) { |
| 135 | let read = iterate_queries(dir); |
| 136 | queries.extend(read); |
| 137 | } |
| 138 | } |
| 139 | println!("Total TPC-H queries found: {}", queries.len()); |
| 140 | queries.sort_unstable_by_key(|q| q.name.clone()); |
| 141 | queries |
| 142 | } |
| 143 | |
| 144 | /// Create a new SessionContext for testing that has all Clickbench tables registered. |
| 145 | /// |
no test coverage detected
searching dependent graphs…