Skip to main content
gpudb_api::sqlx_support
Source 
pub type KineticaPool = PgPool;

Type alias for SQLx PostgreSQL connection pool configured for Kinetica.

This is simply a PgPool but named to make the intent clear in your code.

​
Aliased Type

pub struct KineticaPool(/* private fields */);

​
Trait Implementations

Source

​
async fn execute_sql(&self, sql: &str) -> Result<u64, SqlxError>

Execute a raw SQL statement and return the number of rows affected.
Source

​
async fn table_exists(&self, table_name: &str) -> Result<bool, SqlxError>

Check if a table exists.
Source

​
async fn count_rows( &self, table_name: &str, condition: Option<&str>, ) -> Result<i64, SqlxError>

Get the count of rows in a table.
Source

​
async fn fetch_page( &self, sql: &str, offset: i64, limit: i64, ) -> Result<(Vec<PgRow>, i64), SqlxError>

Execute a query with pagination (LIMIT/OFFSET). Read more
Source

​
async fn fetch_all_pages<F>( &self, sql: &str, page_size: i64, callback: F, ) ->Result<SqlxPaginationStats, SqlxError>
where F: FnMut(Vec<PgRow>, u64) -> Result<bool, SqlxError> + Send,

Execute a query and process all results page by page with a callback. Read more
Source

​
async fn fetch_all_paginated( &self, sql: &str, page_size: i64, ) -> Result<Vec<PgRow>, SqlxError>

Fetch all rows from a query, automatically handling pagination. Read more