Class SnowflakeConnectionManager

    public class SnowflakeConnectionManager : DbConnectionManager<SnowflakeDbConnection, SnowflakeDbTransaction, SnowflakeDbParameter>, IConnectionManager<SnowflakeDbConnection, SnowflakeDbTransaction>, IConnectionManager, IDisposable

Examples

var snowflakeConnection = new SnowflakeConnectionManager("Server=localhost;Database=ETLBox_Logging;User Id=postgres;Password=etlboxpassword;");

Constructors

SnowflakeConnectionManager()

Declaration

    public SnowflakeConnectionManager()

SnowflakeConnectionManager(SnowflakeConnectionString)

Declaration

    public SnowflakeConnectionManager(SnowflakeConnectionString connectionString)

Parameters

Type	Name	Description
SnowflakeConnectionString	connectionString

SnowflakeConnectionManager(string)

Declaration

    public SnowflakeConnectionManager(string connectionString)

Parameters

Type	Name	Description
string	connectionString

Properties

ConnectionType

The database type for the connection manager.

Declaration

    public override ConnectionType ConnectionType { get; protected set; }

Property Value

Type	Description
ConnectionType

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.ConnectionType

MaxParameterSizeBulkCopy

Returns the maximum amount of parameters that can be used for bulk inserts.

Declaration

    public override int MaxParameterSizeBulkCopy { get; set; }

Property Value

Type	Description
int

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.MaxParameterSizeBulkCopy

MaxParameterSizeSql

Returns the maximum amount of parameters that can be passed into a sql query.

Declaration

    public override int MaxParameterSizeSql { get; set; }

Property Value

Type	Description
int

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.MaxParameterSizeSql

PP

The character that is used in front of parameter names in query to identify the parameter. Most databases use the '@' character, some use ':'.

Declaration

    public override string PP { get; protected set; }

Property Value

Type	Description
string

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.PP

QB

The quotation begin character that is used in the database. E.g. SqlServer uses: '[' and Postgres: '"'

Declaration

    public override string QB { get; protected set; }

Property Value

Type	Description
string

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.QB

QE

The quotation end character that is used in the database. E.g. SqlServer uses: ']' and Postgres: '"'

Declaration

    public override string QE { get; protected set; }

Property Value

Type	Description
string

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.QE

SupportIndexes

Indicates if database server does support indexes.

Declaration

    public override bool SupportIndexes { get; }

Property Value

Type	Description
bool

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.SupportIndexes

SupportProcedures

Indicates if the database supports procedures

Declaration

    public override bool SupportProcedures { get; }

Property Value

Type	Description
bool

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.SupportProcedures

Methods

BulkDelete(ITableData)

Performs a bulk delete

Declaration

    public override void BulkDelete(ITableData data)

Parameters

Type	Name	Description
ITableData	data	Batch of data

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.BulkDelete(ETLBox.ITableData)

BulkInsert(ITableData)

Performs a bulk insert

Declaration

    public override void BulkInsert(ITableData data)

Parameters

Type	Name	Description
ITableData	data	Batch of data

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.BulkInsert(ETLBox.ITableData)

BulkSelect(ITableData, ICollection<string>, Action, Action, params Action<object>[])

Performs a bulk select

Declaration

    public override void BulkSelect(ITableData data, ICollection<string> selectColumnNames, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] rowActions)

Parameters

Type	Name	Description
ITableData	data	Batch of data needed for the where condition
ICollection<string>	selectColumnNames	Column names included in the select
Action	beforeRowReadAction	Action invoked before any data is read
Action	afterRowReadAction	Action invoked after all data is read
Action<object>[]	rowActions

Overrides

DbConnectionManager<SnowflakeDbConnection, SnowflakeDbTransaction, SnowflakeDbParameter>.BulkSelect(ITableData, ICollection<string>, Action, Action, params Action<object>[])

BulkUpdate(ITableData, ICollection<string>, ICollection<string>)

Performs a bulk update

Declaration

    public override void BulkUpdate(ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)

Parameters

Type	Name	Description
ITableData	data	Batch of data
ICollection<string>	setColumnNames	The column names used in the set part of the update statement
ICollection<string>	joinColumnNames	The column names to join for the update

Overrides

DbConnectionManager<SnowflakeDbConnection, SnowflakeDbTransaction, SnowflakeDbParameter>.BulkUpdate(ITableData, ICollection<string>, ICollection<string>)

CleanUpBulkInsert(string)

Called after the whole bulk insert operation to change back settings made to improve bulk insert performance

Declaration

    public override void CleanUpBulkInsert(string tablename)

Parameters

Type	Name	Description
string	tablename

Overrides

DbConnectionManager<SnowflakeDbConnection, SnowflakeDbTransaction, SnowflakeDbParameter>.CleanUpBulkInsert(string)

Clone()

Cretes a clone of the current connection manager

Declaration

    public override IConnectionManager Clone()

Returns

Type	Description
IConnectionManager	A instance copy of the current connection manager

Overrides

ETLBox.DbConnectionManager<Snowflake.Data.Client.SnowflakeDbConnection, Snowflake.Data.Client.SnowflakeDbTransaction, Snowflake.Data.Client.SnowflakeDbParameter>.Clone()

PrepareBulkInsert(string)

Performs preparations needed to improved performance of a bulk insert operation

Declaration

    public override void PrepareBulkInsert(string tablename)

Parameters

Type	Name	Description
string	tablename

Overrides

DbConnectionManager<SnowflakeDbConnection, SnowflakeDbTransaction, SnowflakeDbParameter>.PrepareBulkInsert(string)

Implements

IConnectionManager<TConnection, TTransaction>

IConnectionManager

IDisposable