Function arrow_odbc::insert_statement_from_schema

pub fn insert_statement_from_schema(schema: &Schema, table_name: &str) -> String

Creates an SQL insert statement from an arrow schema. The resulting statement will have one placeholer (?) for each column in the statement.

Note:

If table or column names are derived from user input, be sure to sanatize the input in order to prevent SQL injection attacks.

Example

use arrow_odbc::{
    insert_statement_from_schema,
    arrow::datatypes::{Field, DataType, Schema},
};

let field_a = Field::new("a", DataType::Int64, false);
let field_b = Field::new("b", DataType::Boolean, false);

let schema = Schema::new(vec![field_a, field_b]);
let sql = insert_statement_from_schema(&schema, "MyTable");

assert_eq!("INSERT INTO MyTable (a, b) VALUES (?, ?);", sql)

This function is automatically invoked by crate::OdbcWriter::with_connection.

Examples found in repository

src/odbc_writer.rs (line 263)

    pub fn from_connection(
        connection: Connection<'env>,
        schema: &Schema,
        table_name: &str,
        row_capacity: usize,
    ) -> Result<Self, WriterError> {
        let sql = insert_statement_from_schema(schema, table_name);
        let statement = connection
            .into_prepared(&sql)
            .map_err(|source| WriterError::PreparingInsertStatement { source, sql })?;
        Self::new(row_capacity, schema, statement)
    }
}

impl<'o> OdbcWriter<StatementImpl<'o>> {
    /// A writer which borrows the connection and inserts the given schema into a table with
    /// matching column names.
    ///
    /// **Note:**
    ///
    /// If table or column names are derived from user input, be sure to sanatize the input in order
    /// to prevent SQL injection attacks.
    pub fn with_connection(
        connection: &'o Connection<'o>,
        schema: &Schema,
        table_name: &str,
        row_capacity: usize,
    ) -> Result<Self, WriterError> {
        let sql = insert_statement_from_schema(schema, table_name);
        let statement = connection
            .prepare(&sql)
            .map_err(|source| WriterError::PreparingInsertStatement { source, sql })?;
        Self::new(row_capacity, schema, statement)
    }