Struct PostgresCopyHandler 

pub struct PostgresCopyHandler<'a> { /* private fields */ }

Handles PostgreSQL COPY BINARY operations for blockchain data.

Implementations

impl<'a> PostgresCopyHandler<'a>

pub const fn new(pool: &'a PgPool) -> Self

Creates a new COPY handler with a reference to the database pool.

pub async fn copy_blocks(&self, chain_id: u32, blocks: &[Block]) -> Result<()>

Inserts blocks using PostgreSQL COPY BINARY for maximum performance.

This method is significantly faster than INSERT for bulk operations as it bypasses SQL parsing and uses PostgreSQL’s native binary protocol.

Errors

Returns an error if the COPY operation fails.

pub async fn copy_tokens(&self, chain_id: u32, tokens: &[Token]) -> Result<()>

Inserts tokens using PostgreSQL COPY BINARY for maximum performance.

Errors

Returns an error if the COPY operation fails.

pub async fn copy_pools(&self, chain_id: u32, pools: &[Pool]) -> Result<()>

Inserts pools using PostgreSQL COPY BINARY for maximum performance.

Errors

Returns an error if the COPY operation fails.

pub async fn copy_pool_swaps( &self, chain_id: u32, swaps: &[PoolSwap], ) -> Result<()>

Inserts pool swaps using PostgreSQL COPY BINARY for maximum performance.

Errors

Returns an error if the COPY operation fails.

pub async fn copy_pool_liquidity_updates( &self, chain_id: u32, updates: &[PoolLiquidityUpdate], ) -> Result<()>

Inserts pool liquidity updates using PostgreSQL COPY BINARY for maximum performance.

Errors

Returns an error if the COPY operation fails.

pub async fn copy_pool_collects( &self, chain_id: u32, collects: &[PoolFeeCollect], ) -> Result<()>

Inserts pool fee collect events using PostgreSQL COPY BINARY for maximum performance.

Errors

Returns an error if the COPY operation fails.

Trait Implementations

impl<'a> Debug for PostgresCopyHandler<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.