connector_arrow 0.11.0

Load data from databases to Apache Arrow, the fastest way.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

use std::string::FromUtf8Error;

use thiserror::Error;

/// Errors that can be raised from this library.
#[derive(Error, Debug)]
pub enum ConnectorError {
    #[error("Provided query does not have a result set.")]
    NoResultSets,

    #[error("Provided query is trying to return multiple result sets.")]
    MultipleResultSets,

    #[error("Schema of the result cannot be inferred or converted to Arrow schema")]
    CannotConvertSchema,

    #[error("Result data does not match the schema")]
    DataSchemaMismatch(String),

    #[error("Schema is not compatible with Arrow data types")]
    IncompatibleSchema {
        table_name: String,
        message: String,
        hint: Option<String>,
    },

    #[error("When converting values from database representation into into an Arrow types, it fell out of supported range.")]
    DataOutOfRange,

    #[error("{connector_name} does not support {feature}")]
    NotSupported {
        connector_name: &'static str,
        feature: &'static str,
    },

    #[error(transparent)]
    UrlEncoding(#[from] FromUtf8Error),

    #[error(transparent)]
    Arrow(#[from] arrow::error::ArrowError),

    #[cfg(feature = "src_rusqlite")]
    #[error(transparent)]
    SQLite(#[from] rusqlite::Error),

    #[cfg(feature = "src_duckdb")]
    #[error(transparent)]
    DuckDB(#[from] duckdb::Error),

    #[cfg(feature = "src_postgres")]
    #[error(transparent)]
    Postgres(#[from] super::postgres::PostgresError),

    #[cfg(feature = "src_mysql")]
    #[error(transparent)]
    MySQL(#[from] mysql::Error),

    #[cfg(feature = "src_tiberius")]
    #[error(transparent)]
    Tiberius(#[from] tiberius::error::Error),
}

#[derive(Error, Debug)]
pub enum TableCreateError {
    #[error("Table already exists")]
    TableExists,

    #[error(transparent)]
    Connector(#[from] ConnectorError),
}

#[derive(Error, Debug)]
pub enum TableDropError {
    #[error("Table does not exist")]
    TableNonexistent,

    #[error(transparent)]
    Connector(#[from] ConnectorError),
}