Struct Connection 

pub struct Connection { /* private fields */ }

A connection to a ScopeDB instance.

Implementations

impl Connection

pub fn connect(endpoint: &str) -> Self

Connect to a ScopeDB instance. The endpoint is the base URL of the instance.

pub async fn query(&self, statement: &str) -> Result<Vec<RecordBatch>, Error>

Submit query and return the result as Arrow record batches.

Example

let conn = Connection::connect("http://localhost:6543");
let result = conn.query("select 1").await.unwrap();

pub async fn insert( &self, database: &str, schema: &str, table: &str, data: &[RecordBatch], ) -> Result<(), Error>

Insert record batches into a table.

Example

let conn = Connection::connect("http://localhost:6543");
conn.insert("database", "schema", "table", &[record_batch]).await.unwrap();

pub async fn insert_with_transform( &self, database: &str, schema: &str, table: &str, data: &[RecordBatch], transform: &str, ) -> Result<(), Error>

Insert record batches into a table with custom transforms.

Example

let conn = Connection::connect("http://localhost:6543");
conn.insert_with_transform(
    "database",
    "schema",
    "table",
    &[record_batch],
    "select $1 as foo where foo is not null",
).await.unwrap();