Class DataConnection

Namespace

CMS.DataProviderSQL

Assembly

CMS.DataEngine.dll

Represents SQL Server data connection.

public class DataConnection : AbstractDataConnection, IDataConnection, INotCopyThreadItem

Inheritance

object

AbstractDataConnection

DataConnection

Implements

IDataConnection

INotCopyThreadItem

Inherited Members

AbstractDataConnection.mConnectionStringName

AbstractDataConnection.mConnectionString

AbstractDataConnection.mNativeConnection

AbstractDataConnection.mUseScopeConnection

AbstractDataConnection.mCommandTimeout

AbstractDataConnection.mNestedConnectionsList

AbstractDataConnection.mNestedOpenConnections

AbstractDataConnection.mNestedOpenTransactions

AbstractDataConnection.mNestedConnections

AbstractDataConnection.mLastError

AbstractDataConnection.UseScopeConnection

AbstractDataConnection.NativeConnection

AbstractDataConnection.NativeDBConnection

AbstractDataConnection.Transaction

AbstractDataConnection.LocalTransaction

AbstractDataConnection.ConnectionString

AbstractDataConnection.CommandTimeout

AbstractDataConnection.KeepOpen

AbstractDataConnection.LocalKeepOpen

AbstractDataConnection.ExecuteQuery(string, QueryDataParameters, QueryTypeEnum, bool)

AbstractDataConnection.ExecuteNonQueryAsync(string, QueryDataParameters, QueryTypeEnum, bool, CancellationToken)

AbstractDataConnection.ExecuteNonQuery(string, QueryDataParameters, QueryTypeEnum, bool)

AbstractDataConnection.ExecuteReaderAsync(string, QueryDataParameters, QueryTypeEnum, CommandBehavior, CancellationToken)

AbstractDataConnection.ExecuteReader(string, QueryDataParameters, QueryTypeEnum, CommandBehavior)

AbstractDataConnection.ExecuteScalarAsync(string, QueryDataParameters, QueryTypeEnum, bool, CancellationToken)

AbstractDataConnection.ExecuteScalar(string, QueryDataParameters, QueryTypeEnum, bool)

AbstractDataConnection.CheckThreadSafety()

AbstractDataConnection.NativeDBConnectionExists()

AbstractDataConnection.NativeConnectionExists()

AbstractDataConnection.IsOpen()

AbstractDataConnection.Open()

AbstractDataConnection.Close()

AbstractDataConnection.BeginTransaction(IsolationLevel)

AbstractDataConnection.BeginTransaction()

AbstractDataConnection.CommitTransaction()

AbstractDataConnection.RollbackTransaction()

AbstractDataConnection.IsTransaction()

AbstractDataConnection.Dispose()

AbstractDataConnection.LoadDefaultConnectionString()

AbstractDataConnection.HandleError(string, Exception)

AbstractDataConnection.ValidateTransaction(IDbTransaction)

AbstractDataConnection.PrepareCommand(string, QueryDataParameters, QueryTypeEnum, bool, ref bool, ref bool)

AbstractDataConnection.GetNestedConnection(string, bool)

AbstractDataConnection.GetExecutingConnection(string, bool)

Extension Methods

DataExtensions.With<T>(T, Action<T>)

QueryExtensions.AsLiteral<T>(T)

QueryExtensions.AsValue<T>(T, bool)

Constructors

DataConnection(string)

Constructor.

protected DataConnection(string connectionString)

Parameters

connectionString string

Connection string

Methods

BulkInsert(DataTable, string, BulkInsertSettings)

Performs a bulk insert of the data into a target database table

public override void BulkInsert(DataTable sourceData, string targetTable, BulkInsertSettings insertSettings = null)

Parameters

sourceData DataTable

Source data table

targetTable string

Name of the target DB table

insertSettings BulkInsertSettings

Bulk insert configuration

CreateCommand(string)

Creates a new SQL command

protected override DbCommand CreateCommand(string cmdText)

Parameters

cmdText string

Command text

Returns

DbCommand

CreateDataAdapter()

Creates a data adapter

protected override DbDataAdapter CreateDataAdapter()

Returns

DbDataAdapter

CreateNativeConnection()

Creates a new native connection

protected override IDbConnection CreateNativeConnection()

Returns

IDbConnection

CreateParameter(DataParameter)

Creates a new command parameter

protected override DbParameter CreateParameter(DataParameter parameter)

Parameters

parameter DataParameter

Query parameter

Returns

DbParameter

HandleDbError(string, DbException)

Handles the database error. Returns false, if the error was not handled

protected override bool HandleDbError(string message, DbException ex)

Parameters

message string

Error message

ex DbException

Database exception

Returns

bool

ProcessOutParameters(DbParameterCollection, IEnumerable<DataParameter>)

Ensures propagation of output (or input-output or stored procedure return value) parameters after the SQL command execution to the query parameters collection.

protected override void ProcessOutParameters(DbParameterCollection commandParams, IEnumerable<DataParameter> queryParams)

Parameters

commandParams DbParameterCollection

SQL command parameters

queryParams IEnumerable<DataParameter>

Query parameters

Remarks

Processing of output parameters is ensured for the following methods (and their async variants if exist): ExecuteQuery(string, QueryDataParameters, QueryTypeEnum, bool), ExecuteNonQuery(string, QueryDataParameters, QueryTypeEnum, bool), ExecuteScalar(string, QueryDataParameters, QueryTypeEnum, bool).

SetParameterType(DbParameter, Type)

Sets the parameter type to a destination type.

protected override void SetParameterType(DbParameter param, Type type)

Parameters

param DbParameter

Parameter to set

type Type

Desired parameter type