pg_query 0.7.0

PostgreSQL parser that uses the actual PostgreSQL server source to parse SQL queries and return the internal PostgreSQL parse tree.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

#[test]
fn it_does_not_error_when_run_in_parallel() {
    use easy_parallel::Parallel;

    let mut queries = vec![];
    for _ in 0..10000 {
        queries.push(
            r#"
            SELECT * FROM "t0"
            JOIN "t1" ON (1) JOIN "t2" ON (1) JOIN "t3" ON (1) JOIN "t4" ON (1) JOIN "t5" ON (1)
            JOIN "t6" ON (1) JOIN "t7" ON (1) JOIN "t8" ON (1) JOIN "t9" ON (1) JOIN "t10" ON (1)
            JOIN "t11" ON (1) JOIN "t12" ON (1) JOIN "t13" ON (1) JOIN "t14" ON (1) JOIN "t15" ON (1)
            JOIN "t16" ON (1) JOIN "t17" ON (1) JOIN "t18" ON (1) JOIN "t19" ON (1) JOIN "t20" ON (1)
            JOIN "t21" ON (1) JOIN "t22" ON (1) JOIN "t23" ON (1) JOIN "t24" ON (1) JOIN "t25" ON (1)
            JOIN "t26" ON (1) JOIN "t27" ON (1) JOIN "t28" ON (1) JOIN "t29" ON (1)
        "#,
        );
        queries.push(
            "
            SELECT memory_total_bytes, memory_free_bytes, memory_pagecache_bytes, memory_buffers_bytes, memory_applications_bytes,
                (memory_swap_total_bytes - memory_swap_free_bytes) AS swap, date_part($0, s.collected_at) AS collected_at
            FROM snapshots s JOIN system_snapshots ON (snapshot_id = s.id)
            WHERE s.database_id = $0 AND s.collected_at BETWEEN $0 AND $0
            ORDER BY collected_at
        ",
        );
    }

    Parallel::new()
        .each(queries, |query| {
            let result = pg_query::parse(query).unwrap();
            pg_query::fingerprint(query).unwrap();
            result.truncate(10).unwrap();
            pg_query::normalize(query).unwrap();
        })
        .run();
}