Trait Source

pub trait Source {
    type TypeSystem: TypeSystem;
    type Partition: SourcePartition<TypeSystem = Self::TypeSystem, Error = Self::Error> + Send;
    type Error: From<ConnectorXError> + Send + Debug;

    const DATA_ORDERS: &'static [DataOrder];

    // Required methods
    fn set_data_order(
        &mut self,
        data_order: DataOrder,
    ) -> Result<(), Self::Error>;
    fn set_queries<Q: ToString>(&mut self, queries: &[CXQuery<Q>]);
    fn set_origin_query(&mut self, query: Option<String>);
    fn fetch_metadata(&mut self) -> Result<(), Self::Error>;
    fn result_rows(&mut self) -> Result<Option<usize>, Self::Error>;
    fn names(&self) -> Vec<String>;
    fn schema(&self) -> Vec<Self::TypeSystem>;
    fn partition(self) -> Result<Vec<Self::Partition>, Self::Error>;
}

Required Associated Constants

const DATA_ORDERS: &'static [DataOrder]

Supported data orders, ordering by preference.

Required Associated Types

type TypeSystem: TypeSystem

The type system this Source associated with.

type Partition: SourcePartition<TypeSystem = Self::TypeSystem, Error = Self::Error> + Send

type Error: From<ConnectorXError> + Send + Debug

Required Methods

fn set_data_order(&mut self, data_order: DataOrder) -> Result<(), Self::Error>

fn set_queries<Q: ToString>(&mut self, queries: &[CXQuery<Q>])

fn set_origin_query(&mut self, query: Option<String>)

fn fetch_metadata(&mut self) -> Result<(), Self::Error>

fn result_rows(&mut self) -> Result<Option<usize>, Self::Error>

Get total number of rows if available

fn names(&self) -> Vec<String>

fn schema(&self) -> Vec<Self::TypeSystem>

fn partition(self) -> Result<Vec<Self::Partition>, Self::Error>

Object Safety

This trait is not object safe.

Implementors

impl Source for BigQuerySource

where BigQuerySourcePartition: SourcePartition<TypeSystem = BigQueryTypeSystem, Error = BigQuerySourceError>,

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = BigQuerySourcePartition

type TypeSystem = BigQueryTypeSystem

type Error = BigQuerySourceError

impl Source for CSVSource

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = CSVSourcePartition

type TypeSystem = CSVTypeSystem

type Error = CSVSourceError

impl Source for DummySource

const DATA_ORDERS: &'static [DataOrder] = _

type TypeSystem = DummyTypeSystem

type Partition = DummySourcePartition

type Error = ConnectorXError

impl Source for MsSQLSource

where MsSQLSourcePartition: SourcePartition<TypeSystem = MsSQLTypeSystem, Error = MsSQLSourceError>,

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = MsSQLSourcePartition

type TypeSystem = MsSQLTypeSystem

type Error = MsSQLSourceError

impl Source for OracleSource

where OracleSourcePartition: SourcePartition<TypeSystem = OracleTypeSystem, Error = OracleSourceError>,

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = OracleSourcePartition

type TypeSystem = OracleTypeSystem

type Error = OracleSourceError

impl Source for SQLiteSource

where SQLiteSourcePartition: SourcePartition<TypeSystem = SQLiteTypeSystem>,

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = SQLiteSourcePartition

type TypeSystem = SQLiteTypeSystem

type Error = SQLiteSourceError

impl Source for TrinoSource

where TrinoSourcePartition: SourcePartition<TypeSystem = TrinoTypeSystem, Error = TrinoSourceError>,

const DATA_ORDERS: &'static [DataOrder] = _

type TypeSystem = TrinoTypeSystem

type Partition = TrinoSourcePartition

type Error = TrinoSourceError

impl<P> Source for MySQLSource<P>

where MySQLSourcePartition<P>: SourcePartition<TypeSystem = MySQLTypeSystem, Error = MySQLSourceError>, P: Send,

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = MySQLSourcePartition<P>

type TypeSystem = MySQLTypeSystem

type Error = MySQLSourceError

impl<P, C> Source for PostgresSource<P, C>

where PostgresSourcePartition<P, C>: SourcePartition<TypeSystem = PostgresTypeSystem, Error = PostgresSourceError>, P: Send, C: MakeTlsConnect<Socket> + Clone + 'static + Sync + Send, C::TlsConnect: Send, C::Stream: Send, <C::TlsConnect as TlsConnect<Socket>>::Future: Send,

const DATA_ORDERS: &'static [DataOrder] = _

type Partition = PostgresSourcePartition<P, C>

type TypeSystem = PostgresTypeSystem

type Error = PostgresSourceError