Struct InsertBuilder

pub struct InsertBuilder { /* private fields */ }

Implementations

impl InsertBuilder

pub fn new(table_name: &str, record_batches: Vec<RecordBatch>) -> Self

pub fn construct_insert_stmt<T: QueryBuilder + 'static>( &self, insert_stmt: &mut InsertStatement, record_batch: &RecordBatch, query_builder: &T, ) -> Result<()>

Create an Insert statement from a RecordBatch.

Errors

Returns an error if a column’s data type is not supported, or its conversion failed.

pub fn build_postgres(self, on_conflict: Option<OnConflict>) -> Result<String>

Errors

Returns an error if any RecordBatch fails to convert into a valid postgres insert statement.

pub fn build_sqlite(self, on_conflict: Option<OnConflict>) -> Result<String>

Errors

Returns an error if any RecordBatch fails to convert into a valid sqlite insert statement.

pub fn build_mysql(self, on_conflict: Option<OnConflict>) -> Result<String>

Errors

Returns an error if any RecordBatch fails to convert into a valid MySQL insert statement.

pub fn build<T: GenericBuilder + 'static>( &self, query_builder: T, on_conflict: Option<OnConflict>, ) -> Result<String>

Errors

Returns an error if any RecordBatch fails to convert into a valid insert statement. Upon error, no further RecordBatch is processed.