Class AdoConnectorExtensions

Namespace

Datafication.Extensions.Connectors.AdoConnector

Assembly

Datafication.AdoConnector.dll

Provides extension methods for loading data from ADO.NET-compatible databases.

public static class AdoConnectorExtensions

Inheritance

object

AdoConnectorExtensions

Remarks

These extension methods provide convenient shorthand for common database operations. Note: The appropriate ADO.NET provider must be registered before use via System.Data.Common.DbProviderFactories.RegisterFactory(string, System.Data.Common.DbProviderFactory).

Methods

LoadAdo(ConnectorExtensions, AdoConnectorConfiguration)

Loads data using a full ADO connector configuration.

public static DataBlock LoadAdo(this ConnectorExtensions connectorExtensions, AdoConnectorConfiguration configuration)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

configuration AdoConnectorConfiguration

The complete ADO connector configuration.

Returns

DataBlock

The query results as a DataBlock.

LoadAdoAsync(ConnectorExtensions, AdoConnectorConfiguration)

Asynchronously loads data using a full ADO connector configuration.

public static Task<DataBlock> LoadAdoAsync(this ConnectorExtensions connectorExtensions, AdoConnectorConfiguration configuration)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

configuration AdoConnectorConfiguration

The complete ADO connector configuration.

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

Remarks

Use this method for advanced scenarios requiring stored procedures, custom timeouts, or other configuration options not available in the shorthand methods.

LoadMySql(ConnectorExtensions, string, string)

Loads data from a MySQL database.

public static DataBlock LoadMySql(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The MySQL connection string.

query string

The SQL query to execute.

Returns

DataBlock

The query results as a DataBlock.

LoadMySql(ConnectorExtensions, string, string, Dictionary<string, object>)

Loads data from a MySQL database with parameters.

public static DataBlock LoadMySql(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The MySQL connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters.

Returns

DataBlock

The query results as a DataBlock.

LoadMySqlAsync(ConnectorExtensions, string, string)

Asynchronously loads data from a MySQL database.

public static Task<DataBlock> LoadMySqlAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The MySQL connection string.

query string

The SQL query to execute.

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

Remarks

Requires MySql.Data to be installed and registered:

DbProviderFactories.RegisterFactory("MySql.Data.MySqlClient", MySql.Data.MySqlClient.MySqlClientFactory.Instance);

LoadMySqlAsync(ConnectorExtensions, string, string, Dictionary<string, object>)

Asynchronously loads data from a MySQL database with parameters.

public static Task<DataBlock> LoadMySqlAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The MySQL connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters (e.g., "@ParamName" for MySQL).

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

LoadPostgres(ConnectorExtensions, string, string)

Loads data from a PostgreSQL database.

public static DataBlock LoadPostgres(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The PostgreSQL connection string.

query string

The SQL query to execute.

Returns

DataBlock

The query results as a DataBlock.

LoadPostgres(ConnectorExtensions, string, string, Dictionary<string, object>)

Loads data from a PostgreSQL database with parameters.

public static DataBlock LoadPostgres(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The PostgreSQL connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters.

Returns

DataBlock

The query results as a DataBlock.

LoadPostgresAsync(ConnectorExtensions, string, string)

Asynchronously loads data from a PostgreSQL database.

public static Task<DataBlock> LoadPostgresAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The PostgreSQL connection string.

query string

The SQL query to execute.

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

Remarks

Requires Npgsql to be installed and registered:

DbProviderFactories.RegisterFactory("Npgsql", Npgsql.NpgsqlFactory.Instance);

LoadPostgresAsync(ConnectorExtensions, string, string, Dictionary<string, object>)

Asynchronously loads data from a PostgreSQL database with parameters.

public static Task<DataBlock> LoadPostgresAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The PostgreSQL connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters (e.g., "@ParamName" or "$1" for PostgreSQL).

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

LoadSqlServer(ConnectorExtensions, string, string)

Loads data from a SQL Server database.

public static DataBlock LoadSqlServer(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQL Server connection string.

query string

The SQL query to execute.

Returns

DataBlock

The query results as a DataBlock.

LoadSqlServer(ConnectorExtensions, string, string, Dictionary<string, object>)

Loads data from a SQL Server database with parameters.

public static DataBlock LoadSqlServer(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQL Server connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters.

Returns

DataBlock

The query results as a DataBlock.

LoadSqlServerAsync(ConnectorExtensions, string, string)

Asynchronously loads data from a SQL Server database.

public static Task<DataBlock> LoadSqlServerAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQL Server connection string.

query string

The SQL query to execute.

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

Remarks

Requires Microsoft.Data.SqlClient to be installed and registered:

DbProviderFactories.RegisterFactory("Microsoft.Data.SqlClient", Microsoft.Data.SqlClient.SqlClientFactory.Instance);

LoadSqlServerAsync(ConnectorExtensions, string, string, Dictionary<string, object>)

Asynchronously loads data from a SQL Server database with parameters.

public static Task<DataBlock> LoadSqlServerAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQL Server connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters (e.g., "@ParamName" for SQL Server).

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

LoadSqlite(ConnectorExtensions, string, string)

Loads data from a SQLite database.

public static DataBlock LoadSqlite(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQLite connection string.

query string

The SQL query to execute.

Returns

DataBlock

The query results as a DataBlock.

LoadSqlite(ConnectorExtensions, string, string, Dictionary<string, object>)

Loads data from a SQLite database with parameters.

public static DataBlock LoadSqlite(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQLite connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters.

Returns

DataBlock

The query results as a DataBlock.

LoadSqliteAsync(ConnectorExtensions, string, string)

Asynchronously loads data from a SQLite database.

public static Task<DataBlock> LoadSqliteAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQLite connection string (e.g., "Data Source=mydb.db").

query string

The SQL query to execute.

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.

Remarks

Requires Microsoft.Data.Sqlite to be installed and registered:

DbProviderFactories.RegisterFactory("Microsoft.Data.Sqlite", Microsoft.Data.Sqlite.SqliteFactory.Instance);

LoadSqliteAsync(ConnectorExtensions, string, string, Dictionary<string, object>)

Asynchronously loads data from a SQLite database with parameters.

public static Task<DataBlock> LoadSqliteAsync(this ConnectorExtensions connectorExtensions, string connectionString, string query, Dictionary<string, object> parameters)

Parameters

connectorExtensions ConnectorExtensions

The connector extensions instance.

connectionString string

The SQLite connection string.

query string

The SQL query to execute.

parameters Dictionary<string, object>

The query parameters (e.g., "@ParamName" or "$ParamName").

Returns

Task<DataBlock>

A task that represents the asynchronous operation containing the query results as a DataBlock.