2 writes to _stateObj
System.Data (2)
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (2)
2444_stateObj = null; 2626_stateObj = _parser.GetSession(this);
32 references to _stateObj
System.Data (32)
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (32)
508Task executeTask = _parser.TdsExecuteSQLBatch(TDSCommand, this.BulkCopyTimeout, null, _stateObj, sync: !_isAsyncBulkCopy, callerHasConnectionLock: true); 753Task executeTask = _parser.TdsExecuteSQLBatch(TDSCommand, this.BulkCopyTimeout, null, _stateObj, sync: !_isAsyncBulkCopy, callerHasConnectionLock: true); 776_stateObj.SetTimeoutSeconds(this.BulkCopyTimeout); 779_stateObj._outputMessageType = TdsEnums.MT_BULK; 780_parser.WriteBulkCopyMetaData(metadataCollection, _sortedColumnMappings.Count, _stateObj); 1193_parser.Run(RunBehavior.UntilDone, null, null, bulkCopyHandler, _stateObj); 1207_parser.RunReliably(RunBehavior.UntilDone, null, null, bulkCopyHandler, _stateObj); 1919TdsParserStateObject stateObj = _stateObj; 1971value = _parser.EncryptColumnValue(value, metadata, metadata.column, _stateObj, isDataFeed, isSqlType); 1980writeTask = _parser.WriteBulkCopyValue(value, metadata, _stateObj, isSqlType, isDataFeed, isNull); //returns Task/Null 1991_parser.WriteSqlVariantDateTime2(((DateTime)value), _stateObj); 1994_parser.WriteSqlVariantDate(((DateTime)value), _stateObj); 1997writeTask = _parser.WriteSqlVariantDataRowValue(value, _stateObj); //returns Task/Null 2079_stateObj.BcpLock = true; 2098_stateObj.BcpLock = false; 2117Task writeTask = _parser.WriteBulkCopyDone(_stateObj); //We should complete the current batch upto this row. 2172_stateObj.WriteByte(TdsEnums.SQLROW); 2342Task writeTask = _parser.WriteBulkCopyDone(_stateObj); 2395if ((cleanupParser) && (_parser != null) && (_stateObj != null)) { 2397Task task = _parser.WriteBulkCopyDone(_stateObj); 2402if (_stateObj != null) { 2431if (_stateObj != null) { 2434_stateObj.ResetBuffer(); 2435_stateObj._outputPacketNumber = 1; 2438_stateObj.CancelRequest(); 2440_stateObj._internalTimeout = false; 2441_stateObj.CloseSession(); 2442_stateObj._bulkCopyOpperationInProgress = false; 2443_stateObj._bulkCopyWriteTimeout = false; 2465_stateObj.SniContext = SniContext.Snix_SendRows; 2627_stateObj._bulkCopyOpperationInProgress = true; 2628_stateObj.StartSession(ObjectID);