Struct edm_core::connector::DataSource

pub struct DataSource { /* private fields */ }

Available on crate feature connector only.

Data sources.

Implementations

impl DataSource

pub fn try_new( protocol: &'static str, config: &Table ) -> Result<DataSource, Error>

Constructs a new instance with the protocol and configuration, returning an error if it fails.

Currently, we have built-in support for the following protocols:

• arrow
• http
• mssql
• mysql
• postgres
• sqlite

pub fn protocol(&self) -> &'static str

Returns the protocol.

pub fn source_type(&self) -> &str

Returns the data source type.

pub fn name(&self) -> &str

Returns the name.

pub fn catalog(&self) -> &str

Returns the catalog.

pub fn get_arrow_connector(&self) -> Option<&ArrowConnector>

Available on crate feature connector-arrow only.

Returns a reference to the inner connector if it is of type ArrowConnector, or None if it isn’t.

pub fn get_http_connector(&self) -> Option<&HttpConnector>

Available on crate feature connector-http only.

Returns a reference to the inner connector if it is of type HttpConnector, or None if it isn’t.

Trait Implementations

impl Connector for DataSource

fn try_new_data_source(config: &Table) -> Result<DataSource, Error>

Constructs a new data source with the configuration, returning an error if it fails.

async fn execute( &self, query: &str, params: Option<&Map> ) -> Result<Option<u64>, Error>

Executes the query and returns the total number of rows affected.

async fn query( &self, query: &str, params: Option<&Map> ) -> Result<Vec<Record>, Error>

Executes the query and parses it as Vec<Record>.

async fn query_one( &self, query: &str, params: Option<&Map> ) -> Result<Option<Record>, Error>

Executes the query and parses it as a Record.

async fn query_as<T: DeserializeOwned>( &self, query: &str, params: Option<&Map> ) -> Result<Vec<T>, Error>

Executes the query and parses it as Vec<T>.

async fn query_one_as<T: DeserializeOwned>( &self, query: &str, params: Option<&Map> ) -> Result<Option<T>, Error>

Executes the query and parses it as an instance of type T.