2 writes to _parser
System.Data (2)
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (2)
801
_parser
= null;
2561
_parser
= _connection.Parser;
30 references to _parser
System.Data (30)
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (30)
508
Task executeTask =
_parser
.TdsExecuteSQLBatch(TDSCommand, this.BulkCopyTimeout, null, _stateObj, sync: !_isAsyncBulkCopy, callerHasConnectionLock: true);
551
if(
_parser
.IsYukonOrNewer) {
753
Task executeTask =
_parser
.TdsExecuteSQLBatch(TDSCommand, this.BulkCopyTimeout, null, _stateObj, sync: !_isAsyncBulkCopy, callerHasConnectionLock: true);
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);
1324
Debug.Assert (
_parser
.ShouldEncryptValuesForBulkCopy());
1801
if (
_parser
!= null) {
1802
_parser
._asyncWrite = false;
1844
if (
_parser
!= null) {
1845
_parser
._asyncWrite = false;
1970
Debug.Assert (
_parser
.ShouldEncryptValuesForBulkCopy());
1971
value =
_parser
.EncryptColumnValue(value, metadata, metadata.column, _stateObj, isDataFeed, isSqlType);
1980
writeTask =
_parser
.WriteBulkCopyValue(value, metadata, _stateObj, isSqlType, isDataFeed, isNull); //returns Task/Null
1991
_parser
.WriteSqlVariantDateTime2(((DateTime)value), _stateObj);
1994
_parser
.WriteSqlVariantDate(((DateTime)value), _stateObj);
1997
writeTask =
_parser
.WriteSqlVariantDataRowValue(value, _stateObj); //returns Task/Null
2116
_parser
._asyncWrite = false;
2117
Task writeTask =
_parser
.WriteBulkCopyDone(_stateObj); //We should complete the current batch upto this row.
2300
_parser
.LoadColumnEncryptionKeys(
2342
Task writeTask =
_parser
.WriteBulkCopyDone(_stateObj);
2395
if ((cleanupParser) && (
_parser
!= null) && (_stateObj != null)) {
2396
_parser
._asyncWrite = false;
2397
Task task =
_parser
.WriteBulkCopyDone(_stateObj);
2432
_parser
.Connection.ThreadHasParserLockForClose = true;
2437
if (
_parser
.State == TdsParserState.OpenNotLoggedIn ||
_parser
.State == TdsParserState.OpenLoggedIn) {
2447
_parser
.Connection.ThreadHasParserLockForClose = false;
2562
_parser
._asyncWrite = _isAsyncBulkCopy; //very important!
2626
_stateObj =
_parser
.GetSession(this);