Struct PgDialect 

pub struct PgDialect;

Trait Implementations

impl Dialect for PgDialect

fn whole_table_checksum_sql( &self, table: &TableRef, plan: &ComparePlan, ) -> Result<String>

joindiff: fast-exit precheck (whole-table checksum + count)

fn joindiff_sql( &self, a: &TableRef, b: &TableRef, plan: &ComparePlan, ) -> Result<JoinDiffQuery>

joindiff: full outer join

fn materialize_sql( &self, a: &TableRef, b: &TableRef, plan: &ComparePlan, target: &TableRef, ) -> Result<String>

materialize: one CREATE TABLE AS … writing the joindiff result (op / key / src_row / dst_row JSON) server-side. Plain CTAS: fails if target exists — never drops or replaces (docs/superpowers spec, 2026-07-05).

fn normalize_column(&self, _col: &ColumnSchema) -> Result<String>

hashdiff: normalization matrix - One column -> canonical SQL expression

fn digest_expr(&self, _canon_cols: &[String]) -> Result<String>

hashdiff: per-row digest from canonical expressions -> md5 -> two u64 halves

fn keyspace_bounds_sql( &self, _table: &TableRef, _key: &ColumnSchema, ) -> Result<String>

hashdiff: bound the keyspace

fn segment_checksum_sql( &self, _table: &TableRef, _plan: &ComparePlan, _segment: &Segment, ) -> Result<String>

hashdiff: one segment’s checksum tuple, server-side execution

fn segment_rows_sql( &self, _table: &TableRef, _plan: &ComparePlan, ) -> Result<String>

hashdiff: leaf rows for a narrowed, still-disagreeing segment