285_connection = connection; 306_connection = new SqlConnection(connectionString); 825_connection = null;

404if(null != _connection) { 405if(_connection.StatisticsEnabled) { 406return _connection.Statistics; 443if (_connection.IsShiloh) { 447if (_connection.IsKatmaiOrNewer) { 450else if (_connection.IsYukonOrNewer) { 538if (_connection.IsShiloh && 0 == internalResults[CollationResultId].Count) { 552isInTransaction = _connection.HasLocalTransaction; 558if(isInTransaction && null == _externalTransaction && null == _internalTransaction && (_connection.Parser != null && _connection.Parser.CurrentTransaction != null && _connection.Parser.CurrentTransaction.IsLocal)) { 657if(_connection.IsShiloh) { 821if(_connection != null) { 823_connection.Dispose(); 1163if(null == _connection) { 1166if (_connection.IsContextConnection) { 1170if(_ownConnection && _connection.State != ConnectionState.Open) { 1171_connection.Open(); 1175_connection.ValidateConnectionForExecute(method, null); 1180if(null != _externalTransaction && _connection != _externalTransaction.Connection) { 1189SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 1204SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 1216SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 1232SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 1428value = _connection.GetBytes(value); 1748Task reconnectTask = _connection._currentReconnectionTask; 1772SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 1790bestEffortCleanupTarget = SqlInternalConnection.GetBestEffortCleanupTarget(_connection); 1824_connection.Abort(e); 1828_connection.Abort(e); 1832_connection.Abort(e); 1936SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 1986if ((_SqlDataReaderRowSource != null) && (_connection.IsKatmaiOrNewer)) { 2005SqlConnection connection = _connection; 2059_connection.GetOpenTdsConnection()); 2084if (ConnectionState.Open != _connection.State) { 2085exception = ADP.OpenConnectionRequired("CheckAndRaiseNotification", _connection.State); 2112if (_connection.State != ConnectionState.Open) { 2113throw ADP.OpenConnectionRequired(SQL.WriteToServer, _connection.State); 2187AsyncHelper.ContinueTask(readTask, source, () => CopyRowsAsync(i + 1, totalRows, cts, source), connectionToDoom: _connection.GetOpenTdsConnection()); 2203AsyncHelper.ContinueTask(readTask, source, onSuccess: () => CopyRowsAsync(i + 1, totalRows, cts, source), connectionToDoom: _connection.GetOpenTdsConnection()); 2205}, connectionToDoom: _connection.GetOpenTdsConnection()); 2234SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 2239_internalTransaction = _connection.BeginTransaction(); 2267}, _connection.GetOpenTdsConnection()); 2302_connection.DataSource); 2318}, _connection.GetOpenTdsConnection(), _ => CopyBatchesAsyncContinuedOnError(cleanupParser: false), () => CopyBatchesAsyncContinuedOnError(cleanupParser: true)); 2369}, connectionToDoom: _connection.GetOpenTdsConnection(), onFailure: _ => CopyBatchesAsyncContinuedOnError(cleanupParser: false)); 2386SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 2514}, _connection.GetOpenTdsConnection()); 2559SqlInternalConnectionTds internalConnection = _connection.GetOpenTdsConnection(); 2561_parser = _connection.Parser; 2566reconnectTask = _connection.ValidateAndReconnect( 2596_parserLock = _connection.GetOpenTdsConnection()._parserLock; 2600connectionToAbort: _connection, 2613_parserLock = _connection.GetOpenTdsConnection()._parserLock; 2620_connection.AddWeakReference(this, SqlReferenceCollection.BulkCopyTag); 2642AsyncHelper.ContinueTask(internalResultsTask, source, () => WriteToServerInternalRestContinuedAsync(internalResultsTask.Result, cts, source), _connection.GetOpenTdsConnection()); 2706}, _connection.GetOpenTdsConnection());