Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Data / System / Data / SqlClient / TdsParserHelperClasses.cs / 1305376 / TdsParserHelperClasses.cs
//------------------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
// [....]
// [....]
//-----------------------------------------------------------------------------
namespace System.Data.SqlClient {
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.ProviderBase;
using System.Data.Sql;
using System.Data.SqlTypes;
using System.Diagnostics;
using System.Reflection;
using System.Text;
using System.Threading;
using Microsoft.SqlServer.Server; // for SMI metadata
internal enum CallbackType {
Read = 0,
Write = 1
}
internal enum EncryptionOptions {
OFF,
ON,
NOT_SUP,
REQ,
LOGIN
}
internal enum PreLoginHandshakeStatus {
Successful,
SphinxFailure,
InstanceFailure
}
internal enum PreLoginOptions {
VERSION,
ENCRYPT,
INSTANCE,
THREADID,
MARS,
NUMOPT,
LASTOPT = 255
}
internal enum RunBehavior {
UntilDone = 1, // 0001 binary
ReturnImmediately = 2, // 0010 binary
Clean = 5, // 0101 binary - Clean AND UntilDone
Attention = 13 // 1101 binary - Clean AND UntilDone AND Attention
}
internal enum TdsParserState {
Closed,
OpenNotLoggedIn,
OpenLoggedIn,
Broken,
}
sealed internal class SqlCollation {
// First 20 bits of info field represent the lcid, bits 21-25 are compare options
private const uint IgnoreCase = 1 << 20; // bit 21 - IgnoreCase
private const uint IgnoreNonSpace = 1 << 21; // bit 22 - IgnoreNonSpace / IgnoreAccent
private const uint IgnoreWidth = 1 << 22; // bit 23 - IgnoreWidth
private const uint IgnoreKanaType = 1 << 23; // bit 24 - IgnoreKanaType
private const uint BinarySort = 1 << 24; // bit 25 - BinarySort
internal const uint MaskLcid = 0xfffff;
private const int LcidVersionBitOffset = 28;
private const uint MaskLcidVersion = unchecked((uint)(0xf << LcidVersionBitOffset));
private const uint MaskCompareOpt = IgnoreCase | IgnoreNonSpace | IgnoreWidth | IgnoreKanaType | BinarySort;
internal uint info;
internal byte sortId;
static int FirstSupportedCollationVersion(int lcid)
{
// NOTE: switch-case works ~3 times faster in this case than search with Dictionary
switch (lcid)
{
case 1044: return 2; // Norwegian_100_BIN
case 1047: return 2; // Romansh_100_BIN
case 1056: return 2; // Urdu_100_BIN
case 1065: return 2; // Persian_100_BIN
case 1068: return 2; // Azeri_Latin_100_BIN
case 1070: return 2; // Upper_Sorbian_100_BIN
case 1071: return 1; // ----n_FYROM_90_BIN
case 1081: return 1; // Indic_General_90_BIN
case 1082: return 2; // Maltese_100_BIN
case 1083: return 2; // Sami_Norway_100_BIN
case 1087: return 1; // Kazakh_90_BIN
case 1090: return 2; // Turkmen_100_BIN
case 1091: return 1; // Uzbek_Latin_90_BIN
case 1092: return 1; // Tatar_90_BIN
case 1093: return 2; // Bengali_100_BIN
case 1101: return 2; // Assamese_100_BIN
case 1105: return 2; // Tibetan_100_BIN
case 1106: return 2; // Welsh_100_BIN
case 1107: return 2; // Khmer_100_BIN
case 1108: return 2; // Lao_100_BIN
case 1114: return 1; // Syriac_90_BIN
case 1121: return 2; // Nepali_100_BIN
case 1122: return 2; // Frisian_100_BIN
case 1123: return 2; // Pashto_100_BIN
case 1125: return 1; // Divehi_90_BIN
case 1133: return 2; // Bashkir_100_BIN
case 1146: return 2; // Mapudungan_100_BIN
case 1148: return 2; // Mohawk_100_BIN
case 1150: return 2; // Breton_100_BIN
case 1152: return 2; // Uighur_100_BIN
case 1153: return 2; // Maori_100_BIN
case 1155: return 2; // Corsican_100_BIN
case 1157: return 2; // Yakut_100_BIN
case 1164: return 2; // Dari_100_BIN
case 2074: return 2; // Serbian_Latin_100_BIN
case 2092: return 2; // Azeri_Cyrillic_100_BIN
case 2107: return 2; // Sami_Sweden_Finland_100_BIN
case 2143: return 2; // Tamazight_100_BIN
case 3076: return 1; // Chinese_Hong_Kong_Stroke_90_BIN
case 3098: return 2; // Serbian_Cyrillic_100_BIN
case 5124: return 2; // Chinese_Traditional_Pinyin_100_BIN
case 5146: return 2; // Bosnian_Latin_100_BIN
case 8218: return 2; // Bosnian_Cyrillic_100_BIN
default: return 0; // other LCIDs have collation with version 0
}
}
internal int LCID {
// First 20 bits of info field represent the lcid
get {
return unchecked((int)(info & MaskLcid));
}
set {
int lcid = value & (int)MaskLcid;
Debug.Assert(lcid == value, "invalid set_LCID value");
// VSTFDEVDIV 479474: some new Katmai LCIDs do not have collation with version = 0
// since user has no way to specify collation version, we set the first (minimal) supported version for these collations
int versionBits = FirstSupportedCollationVersion(lcid) << LcidVersionBitOffset;
Debug.Assert((versionBits & MaskLcidVersion) == versionBits, "invalid version returned by FirstSupportedCollationVersion");
// combine the current compare options with the new locale ID and its first supported version
info = (info & MaskCompareOpt) | unchecked((uint)lcid) | unchecked((uint)versionBits);
}
}
internal SqlCompareOptions SqlCompareOptions {
get {
SqlCompareOptions options = SqlCompareOptions.None;
if (0 != (info & IgnoreCase))
options |= SqlCompareOptions.IgnoreCase;
if (0 != (info & IgnoreNonSpace))
options |= SqlCompareOptions.IgnoreNonSpace;
if (0 != (info & IgnoreWidth))
options |= SqlCompareOptions.IgnoreWidth;
if (0 != (info & IgnoreKanaType))
options |= SqlCompareOptions.IgnoreKanaType;
if (0 != (info & BinarySort))
options |= SqlCompareOptions.BinarySort;
return options;
}
set {
Debug.Assert((value & SqlString.x_iValidSqlCompareOptionMask) == value, "invalid set_SqlCompareOptions value");
uint tmp = 0;
if (0 != (value & SqlCompareOptions.IgnoreCase))
tmp |= IgnoreCase;
if (0 != (value & SqlCompareOptions.IgnoreNonSpace))
tmp |= IgnoreNonSpace;
if (0 != (value & SqlCompareOptions.IgnoreWidth))
tmp |= IgnoreWidth;
if (0 != (value & SqlCompareOptions.IgnoreKanaType))
tmp |= IgnoreKanaType;
if (0 != (value & SqlCompareOptions.BinarySort))
tmp |= BinarySort;
info = (info & MaskLcid) | tmp;
}
}
internal string TraceString() {
return String.Format(/*IFormatProvider*/ null, "(LCID={0}, Opts={1})", this.LCID, (int)this.SqlCompareOptions);
}
}
sealed internal class SqlEnvChange {
internal byte type;
internal byte oldLength;
internal int newLength; // 7206 TDS changes makes this length an int
internal int length;
internal string newValue;
internal string oldValue;
internal byte[] newBinValue;
internal byte[] oldBinValue;
internal long newLongValue;
internal long oldLongValue;
internal SqlCollation newCollation;
internal SqlCollation oldCollation;
}
sealed internal class SqlLogin {
internal int timeout; // login timeout
internal bool userInstance = false; // user instance
internal string hostName = ""; // client machine name
internal string userName = ""; // user id
internal string password = ""; // password
internal string applicationName = ""; // application name
internal string serverName = ""; // server name
internal string language = ""; // initial language
internal string database = ""; // initial database
internal string attachDBFilename = ""; // DB filename to be attached
internal string newPassword = ""; // new password for reset password
internal bool useReplication = false; // user login for replication
internal bool useSSPI = false; // use integrated security
internal int packetSize = SqlConnectionString.DEFAULT.Packet_Size; // packet size
}
sealed internal class SqlLoginAck {
internal string programName;
internal byte majorVersion;
internal byte minorVersion;
internal short buildNum;
internal bool isVersion8;
}
sealed internal class _SqlMetaData : SqlMetaDataPriv {
internal string column;
internal string baseColumn;
internal MultiPartTableName multiPartTableName;
internal readonly int ordinal;
internal byte updatability; // two bit field (0 is read only, 1 is updatable, 2 is updatability unknown)
internal byte tableNum;
internal bool isDifferentName;
internal bool isKey;
internal bool isHidden;
internal bool isExpression;
internal bool isIdentity;
internal bool isColumnSet;
internal byte op; // for altrow-columns only
internal ushort operand; // for altrow-columns only
internal _SqlMetaData(int ordinal) : base() {
this.ordinal = ordinal;
}
internal string serverName {
get {
return multiPartTableName.ServerName;
}
}
internal string catalogName {
get {
return multiPartTableName.CatalogName;
}
}
internal string schemaName {
get {
return multiPartTableName.SchemaName;
}
}
internal string tableName {
get {
return multiPartTableName.TableName;
}
}
internal bool IsNewKatmaiDateTimeType {
get {
return SqlDbType.Date == type || SqlDbType.Time == type || SqlDbType.DateTime2 == type || SqlDbType.DateTimeOffset == type;
}
}
internal bool IsLargeUdt {
get {
return type == SqlDbType.Udt && length == Int32.MaxValue;
}
}
}
sealed internal class _SqlMetaDataSet {
internal ushort id; // for altrow-columns only
internal int[] indexMap;
internal int visibleColumns;
internal DataTable schemaTable;
private readonly _SqlMetaData[] metaDataArray;
internal _SqlMetaDataSet(int count) {
metaDataArray = new _SqlMetaData[count];
for(int i = 0; i < metaDataArray.Length; ++i) {
metaDataArray[i] = new _SqlMetaData(i);
}
}
internal int Length {
get {
return metaDataArray.Length;
}
}
internal _SqlMetaData this [int index] {
get {
return metaDataArray[index];
}
set {
Debug.Assert(null == value, "used only by SqlBulkCopy");
metaDataArray[index] = value;
}
}
}
sealed internal class _SqlMetaDataSetCollection {
private readonly List<_SqlMetaDataSet> altMetaDataSetArray;
internal _SqlMetaDataSet metaDataSet;
internal _SqlMetaDataSetCollection () {
altMetaDataSetArray = new List<_SqlMetaDataSet>();
}
internal void SetAltMetaData(_SqlMetaDataSet altMetaDataSet) {
// VSTFDEVDIV 479675: if altmetadata with same id is found, override it rather than adding a new one
int newId = altMetaDataSet.id;
for (int i = 0; i < altMetaDataSetArray.Count; i++) {
if (altMetaDataSetArray[i].id == newId) {
// override the existing metadata with the same id
altMetaDataSetArray[i] = altMetaDataSet;
return;
}
}
// if we did not find metadata to override, add as new
altMetaDataSetArray.Add(altMetaDataSet);
}
internal _SqlMetaDataSet GetAltMetaData(int id) {
foreach (_SqlMetaDataSet altMetaDataSet in altMetaDataSetArray) {
if (altMetaDataSet.id == id) {
return altMetaDataSet;
}
}
Debug.Assert (false, "Can't match up altMetaDataSet with given id");
return null;
}
}
internal class SqlMetaDataPriv {
internal SqlDbType type; // SqlDbType enum value
internal byte tdsType; // underlying tds type
internal byte precision = TdsEnums.UNKNOWN_PRECISION_SCALE; // give default of unknown (-1)
internal byte scale = TdsEnums.UNKNOWN_PRECISION_SCALE; // give default of unknown (-1)
internal int length;
internal SqlCollation collation;
internal int codePage;
internal Encoding encoding;
internal bool isNullable;
internal bool isMultiValued = false;
// UDT specific metadata
// server metadata info
// additional temporary UDT meta data
internal string udtDatabaseName;
internal string udtSchemaName;
internal string udtTypeName;
internal string udtAssemblyQualifiedName;
// on demand
internal Type udtType;
// Xml specific metadata
internal string xmlSchemaCollectionDatabase;
internal string xmlSchemaCollectionOwningSchema;
internal string xmlSchemaCollectionName;
internal MetaType metaType; // cached metaType
// Structured type-specific metadata
internal string structuredTypeDatabaseName;
internal string structuredTypeSchemaName;
internal string structuredTypeName;
internal IList structuredFields;
internal SqlMetaDataPriv() {
}
}
sealed internal class _SqlRPC {
internal string rpcName;
internal string databaseName; // Used for UDTs
internal ushort ProcID; // Used instead of name
internal ushort options;
internal SqlParameter[] parameters;
internal byte[] paramoptions;
internal int? recordsAffected;
internal int cumulativeRecordsAffected;
internal int errorsIndexStart;
internal int errorsIndexEnd;
internal SqlErrorCollection errors;
internal int warningsIndexStart;
internal int warningsIndexEnd;
internal SqlErrorCollection warnings;
}
sealed internal class SqlReturnValue : SqlMetaDataPriv {
internal ushort parmIndex; //Yukon or later only
internal string parameter;
internal readonly SqlBuffer value;
internal SqlReturnValue() : base() {
value = new SqlBuffer();
}
}
internal struct MultiPartTableName {
private string _multipartName;
private string _serverName;
private string _catalogName;
private string _schemaName;
private string _tableName;
internal MultiPartTableName(string[] parts) {
_multipartName = null;
_serverName = parts[0];
_catalogName = parts[1];
_schemaName = parts[2];
_tableName = parts[3];
}
internal MultiPartTableName(string multipartName) {
_multipartName = multipartName;
_serverName = null;
_catalogName = null;
_schemaName = null;
_tableName = null;
}
internal string ServerName {
get {
ParseMultipartName();
return _serverName;
}
set { _serverName = value; }
}
internal string CatalogName {
get {
ParseMultipartName();
return _catalogName;
}
set { _catalogName = value; }
}
internal string SchemaName {
get {
ParseMultipartName();
return _schemaName;
}
set { _schemaName = value; }
}
internal string TableName {
get {
ParseMultipartName();
return _tableName;
}
set { _tableName = value; }
}
private void ParseMultipartName() {
if (null != _multipartName) {
string[] parts = MultipartIdentifier.ParseMultipartIdentifier(_multipartName, "[\"", "]\"", Res.SQL_TDSParserTableName, false);
_serverName = parts[0];
_catalogName = parts[1];
_schemaName = parts[2];
_tableName = parts[3];
_multipartName = null;
}
}
internal static readonly MultiPartTableName Null = new MultiPartTableName(new string[] {null, null, null, null});
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
//------------------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
// [....]
// [....]
//-----------------------------------------------------------------------------
namespace System.Data.SqlClient {
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.ProviderBase;
using System.Data.Sql;
using System.Data.SqlTypes;
using System.Diagnostics;
using System.Reflection;
using System.Text;
using System.Threading;
using Microsoft.SqlServer.Server; // for SMI metadata
internal enum CallbackType {
Read = 0,
Write = 1
}
internal enum EncryptionOptions {
OFF,
ON,
NOT_SUP,
REQ,
LOGIN
}
internal enum PreLoginHandshakeStatus {
Successful,
SphinxFailure,
InstanceFailure
}
internal enum PreLoginOptions {
VERSION,
ENCRYPT,
INSTANCE,
THREADID,
MARS,
NUMOPT,
LASTOPT = 255
}
internal enum RunBehavior {
UntilDone = 1, // 0001 binary
ReturnImmediately = 2, // 0010 binary
Clean = 5, // 0101 binary - Clean AND UntilDone
Attention = 13 // 1101 binary - Clean AND UntilDone AND Attention
}
internal enum TdsParserState {
Closed,
OpenNotLoggedIn,
OpenLoggedIn,
Broken,
}
sealed internal class SqlCollation {
// First 20 bits of info field represent the lcid, bits 21-25 are compare options
private const uint IgnoreCase = 1 << 20; // bit 21 - IgnoreCase
private const uint IgnoreNonSpace = 1 << 21; // bit 22 - IgnoreNonSpace / IgnoreAccent
private const uint IgnoreWidth = 1 << 22; // bit 23 - IgnoreWidth
private const uint IgnoreKanaType = 1 << 23; // bit 24 - IgnoreKanaType
private const uint BinarySort = 1 << 24; // bit 25 - BinarySort
internal const uint MaskLcid = 0xfffff;
private const int LcidVersionBitOffset = 28;
private const uint MaskLcidVersion = unchecked((uint)(0xf << LcidVersionBitOffset));
private const uint MaskCompareOpt = IgnoreCase | IgnoreNonSpace | IgnoreWidth | IgnoreKanaType | BinarySort;
internal uint info;
internal byte sortId;
static int FirstSupportedCollationVersion(int lcid)
{
// NOTE: switch-case works ~3 times faster in this case than search with Dictionary
switch (lcid)
{
case 1044: return 2; // Norwegian_100_BIN
case 1047: return 2; // Romansh_100_BIN
case 1056: return 2; // Urdu_100_BIN
case 1065: return 2; // Persian_100_BIN
case 1068: return 2; // Azeri_Latin_100_BIN
case 1070: return 2; // Upper_Sorbian_100_BIN
case 1071: return 1; // ----n_FYROM_90_BIN
case 1081: return 1; // Indic_General_90_BIN
case 1082: return 2; // Maltese_100_BIN
case 1083: return 2; // Sami_Norway_100_BIN
case 1087: return 1; // Kazakh_90_BIN
case 1090: return 2; // Turkmen_100_BIN
case 1091: return 1; // Uzbek_Latin_90_BIN
case 1092: return 1; // Tatar_90_BIN
case 1093: return 2; // Bengali_100_BIN
case 1101: return 2; // Assamese_100_BIN
case 1105: return 2; // Tibetan_100_BIN
case 1106: return 2; // Welsh_100_BIN
case 1107: return 2; // Khmer_100_BIN
case 1108: return 2; // Lao_100_BIN
case 1114: return 1; // Syriac_90_BIN
case 1121: return 2; // Nepali_100_BIN
case 1122: return 2; // Frisian_100_BIN
case 1123: return 2; // Pashto_100_BIN
case 1125: return 1; // Divehi_90_BIN
case 1133: return 2; // Bashkir_100_BIN
case 1146: return 2; // Mapudungan_100_BIN
case 1148: return 2; // Mohawk_100_BIN
case 1150: return 2; // Breton_100_BIN
case 1152: return 2; // Uighur_100_BIN
case 1153: return 2; // Maori_100_BIN
case 1155: return 2; // Corsican_100_BIN
case 1157: return 2; // Yakut_100_BIN
case 1164: return 2; // Dari_100_BIN
case 2074: return 2; // Serbian_Latin_100_BIN
case 2092: return 2; // Azeri_Cyrillic_100_BIN
case 2107: return 2; // Sami_Sweden_Finland_100_BIN
case 2143: return 2; // Tamazight_100_BIN
case 3076: return 1; // Chinese_Hong_Kong_Stroke_90_BIN
case 3098: return 2; // Serbian_Cyrillic_100_BIN
case 5124: return 2; // Chinese_Traditional_Pinyin_100_BIN
case 5146: return 2; // Bosnian_Latin_100_BIN
case 8218: return 2; // Bosnian_Cyrillic_100_BIN
default: return 0; // other LCIDs have collation with version 0
}
}
internal int LCID {
// First 20 bits of info field represent the lcid
get {
return unchecked((int)(info & MaskLcid));
}
set {
int lcid = value & (int)MaskLcid;
Debug.Assert(lcid == value, "invalid set_LCID value");
// VSTFDEVDIV 479474: some new Katmai LCIDs do not have collation with version = 0
// since user has no way to specify collation version, we set the first (minimal) supported version for these collations
int versionBits = FirstSupportedCollationVersion(lcid) << LcidVersionBitOffset;
Debug.Assert((versionBits & MaskLcidVersion) == versionBits, "invalid version returned by FirstSupportedCollationVersion");
// combine the current compare options with the new locale ID and its first supported version
info = (info & MaskCompareOpt) | unchecked((uint)lcid) | unchecked((uint)versionBits);
}
}
internal SqlCompareOptions SqlCompareOptions {
get {
SqlCompareOptions options = SqlCompareOptions.None;
if (0 != (info & IgnoreCase))
options |= SqlCompareOptions.IgnoreCase;
if (0 != (info & IgnoreNonSpace))
options |= SqlCompareOptions.IgnoreNonSpace;
if (0 != (info & IgnoreWidth))
options |= SqlCompareOptions.IgnoreWidth;
if (0 != (info & IgnoreKanaType))
options |= SqlCompareOptions.IgnoreKanaType;
if (0 != (info & BinarySort))
options |= SqlCompareOptions.BinarySort;
return options;
}
set {
Debug.Assert((value & SqlString.x_iValidSqlCompareOptionMask) == value, "invalid set_SqlCompareOptions value");
uint tmp = 0;
if (0 != (value & SqlCompareOptions.IgnoreCase))
tmp |= IgnoreCase;
if (0 != (value & SqlCompareOptions.IgnoreNonSpace))
tmp |= IgnoreNonSpace;
if (0 != (value & SqlCompareOptions.IgnoreWidth))
tmp |= IgnoreWidth;
if (0 != (value & SqlCompareOptions.IgnoreKanaType))
tmp |= IgnoreKanaType;
if (0 != (value & SqlCompareOptions.BinarySort))
tmp |= BinarySort;
info = (info & MaskLcid) | tmp;
}
}
internal string TraceString() {
return String.Format(/*IFormatProvider*/ null, "(LCID={0}, Opts={1})", this.LCID, (int)this.SqlCompareOptions);
}
}
sealed internal class SqlEnvChange {
internal byte type;
internal byte oldLength;
internal int newLength; // 7206 TDS changes makes this length an int
internal int length;
internal string newValue;
internal string oldValue;
internal byte[] newBinValue;
internal byte[] oldBinValue;
internal long newLongValue;
internal long oldLongValue;
internal SqlCollation newCollation;
internal SqlCollation oldCollation;
}
sealed internal class SqlLogin {
internal int timeout; // login timeout
internal bool userInstance = false; // user instance
internal string hostName = ""; // client machine name
internal string userName = ""; // user id
internal string password = ""; // password
internal string applicationName = ""; // application name
internal string serverName = ""; // server name
internal string language = ""; // initial language
internal string database = ""; // initial database
internal string attachDBFilename = ""; // DB filename to be attached
internal string newPassword = ""; // new password for reset password
internal bool useReplication = false; // user login for replication
internal bool useSSPI = false; // use integrated security
internal int packetSize = SqlConnectionString.DEFAULT.Packet_Size; // packet size
}
sealed internal class SqlLoginAck {
internal string programName;
internal byte majorVersion;
internal byte minorVersion;
internal short buildNum;
internal bool isVersion8;
}
sealed internal class _SqlMetaData : SqlMetaDataPriv {
internal string column;
internal string baseColumn;
internal MultiPartTableName multiPartTableName;
internal readonly int ordinal;
internal byte updatability; // two bit field (0 is read only, 1 is updatable, 2 is updatability unknown)
internal byte tableNum;
internal bool isDifferentName;
internal bool isKey;
internal bool isHidden;
internal bool isExpression;
internal bool isIdentity;
internal bool isColumnSet;
internal byte op; // for altrow-columns only
internal ushort operand; // for altrow-columns only
internal _SqlMetaData(int ordinal) : base() {
this.ordinal = ordinal;
}
internal string serverName {
get {
return multiPartTableName.ServerName;
}
}
internal string catalogName {
get {
return multiPartTableName.CatalogName;
}
}
internal string schemaName {
get {
return multiPartTableName.SchemaName;
}
}
internal string tableName {
get {
return multiPartTableName.TableName;
}
}
internal bool IsNewKatmaiDateTimeType {
get {
return SqlDbType.Date == type || SqlDbType.Time == type || SqlDbType.DateTime2 == type || SqlDbType.DateTimeOffset == type;
}
}
internal bool IsLargeUdt {
get {
return type == SqlDbType.Udt && length == Int32.MaxValue;
}
}
}
sealed internal class _SqlMetaDataSet {
internal ushort id; // for altrow-columns only
internal int[] indexMap;
internal int visibleColumns;
internal DataTable schemaTable;
private readonly _SqlMetaData[] metaDataArray;
internal _SqlMetaDataSet(int count) {
metaDataArray = new _SqlMetaData[count];
for(int i = 0; i < metaDataArray.Length; ++i) {
metaDataArray[i] = new _SqlMetaData(i);
}
}
internal int Length {
get {
return metaDataArray.Length;
}
}
internal _SqlMetaData this [int index] {
get {
return metaDataArray[index];
}
set {
Debug.Assert(null == value, "used only by SqlBulkCopy");
metaDataArray[index] = value;
}
}
}
sealed internal class _SqlMetaDataSetCollection {
private readonly List<_SqlMetaDataSet> altMetaDataSetArray;
internal _SqlMetaDataSet metaDataSet;
internal _SqlMetaDataSetCollection () {
altMetaDataSetArray = new List<_SqlMetaDataSet>();
}
internal void SetAltMetaData(_SqlMetaDataSet altMetaDataSet) {
// VSTFDEVDIV 479675: if altmetadata with same id is found, override it rather than adding a new one
int newId = altMetaDataSet.id;
for (int i = 0; i < altMetaDataSetArray.Count; i++) {
if (altMetaDataSetArray[i].id == newId) {
// override the existing metadata with the same id
altMetaDataSetArray[i] = altMetaDataSet;
return;
}
}
// if we did not find metadata to override, add as new
altMetaDataSetArray.Add(altMetaDataSet);
}
internal _SqlMetaDataSet GetAltMetaData(int id) {
foreach (_SqlMetaDataSet altMetaDataSet in altMetaDataSetArray) {
if (altMetaDataSet.id == id) {
return altMetaDataSet;
}
}
Debug.Assert (false, "Can't match up altMetaDataSet with given id");
return null;
}
}
internal class SqlMetaDataPriv {
internal SqlDbType type; // SqlDbType enum value
internal byte tdsType; // underlying tds type
internal byte precision = TdsEnums.UNKNOWN_PRECISION_SCALE; // give default of unknown (-1)
internal byte scale = TdsEnums.UNKNOWN_PRECISION_SCALE; // give default of unknown (-1)
internal int length;
internal SqlCollation collation;
internal int codePage;
internal Encoding encoding;
internal bool isNullable;
internal bool isMultiValued = false;
// UDT specific metadata
// server metadata info
// additional temporary UDT meta data
internal string udtDatabaseName;
internal string udtSchemaName;
internal string udtTypeName;
internal string udtAssemblyQualifiedName;
// on demand
internal Type udtType;
// Xml specific metadata
internal string xmlSchemaCollectionDatabase;
internal string xmlSchemaCollectionOwningSchema;
internal string xmlSchemaCollectionName;
internal MetaType metaType; // cached metaType
// Structured type-specific metadata
internal string structuredTypeDatabaseName;
internal string structuredTypeSchemaName;
internal string structuredTypeName;
internal IList structuredFields;
internal SqlMetaDataPriv() {
}
}
sealed internal class _SqlRPC {
internal string rpcName;
internal string databaseName; // Used for UDTs
internal ushort ProcID; // Used instead of name
internal ushort options;
internal SqlParameter[] parameters;
internal byte[] paramoptions;
internal int? recordsAffected;
internal int cumulativeRecordsAffected;
internal int errorsIndexStart;
internal int errorsIndexEnd;
internal SqlErrorCollection errors;
internal int warningsIndexStart;
internal int warningsIndexEnd;
internal SqlErrorCollection warnings;
}
sealed internal class SqlReturnValue : SqlMetaDataPriv {
internal ushort parmIndex; //Yukon or later only
internal string parameter;
internal readonly SqlBuffer value;
internal SqlReturnValue() : base() {
value = new SqlBuffer();
}
}
internal struct MultiPartTableName {
private string _multipartName;
private string _serverName;
private string _catalogName;
private string _schemaName;
private string _tableName;
internal MultiPartTableName(string[] parts) {
_multipartName = null;
_serverName = parts[0];
_catalogName = parts[1];
_schemaName = parts[2];
_tableName = parts[3];
}
internal MultiPartTableName(string multipartName) {
_multipartName = multipartName;
_serverName = null;
_catalogName = null;
_schemaName = null;
_tableName = null;
}
internal string ServerName {
get {
ParseMultipartName();
return _serverName;
}
set { _serverName = value; }
}
internal string CatalogName {
get {
ParseMultipartName();
return _catalogName;
}
set { _catalogName = value; }
}
internal string SchemaName {
get {
ParseMultipartName();
return _schemaName;
}
set { _schemaName = value; }
}
internal string TableName {
get {
ParseMultipartName();
return _tableName;
}
set { _tableName = value; }
}
private void ParseMultipartName() {
if (null != _multipartName) {
string[] parts = MultipartIdentifier.ParseMultipartIdentifier(_multipartName, "[\"", "]\"", Res.SQL_TDSParserTableName, false);
_serverName = parts[0];
_catalogName = parts[1];
_schemaName = parts[2];
_tableName = parts[3];
_multipartName = null;
}
}
internal static readonly MultiPartTableName Null = new MultiPartTableName(new string[] {null, null, null, null});
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- FixedPosition.cs
- SqlServices.cs
- Frame.cs
- ButtonBase.cs
- PageStatePersister.cs
- CodeDomConfigurationHandler.cs
- DataSet.cs
- ProcessHostConfigUtils.cs
- _OverlappedAsyncResult.cs
- PageCodeDomTreeGenerator.cs
- BindableTemplateBuilder.cs
- DataGridViewLinkColumn.cs
- StyleSelector.cs
- SqlDataSourceTableQuery.cs
- ToolStripRenderer.cs
- ProviderUtil.cs
- WeakReferenceKey.cs
- EmptyStringExpandableObjectConverter.cs
- EventHandlerService.cs
- MediaElement.cs
- isolationinterop.cs
- Base64Decoder.cs
- Trace.cs
- Number.cs
- XpsS0ValidatingLoader.cs
- ChangesetResponse.cs
- SingleObjectCollection.cs
- TextEditorDragDrop.cs
- FileSystemInfo.cs
- WebHttpSecurityModeHelper.cs
- XmlSignificantWhitespace.cs
- UnmanagedMarshal.cs
- DBSqlParserColumnCollection.cs
- GridViewPageEventArgs.cs
- SessionStateContainer.cs
- NotCondition.cs
- TextEncodedRawTextWriter.cs
- TextTreeInsertUndoUnit.cs
- LinkArea.cs
- NetStream.cs
- Opcode.cs
- ProcessInputEventArgs.cs
- SQLSingleStorage.cs
- AuthorizationContext.cs
- Literal.cs
- AutomationPropertyInfo.cs
- ListSortDescription.cs
- HandleTable.cs
- TabControlCancelEvent.cs
- New.cs
- OdbcConnectionString.cs
- DataTableNewRowEvent.cs
- PixelFormats.cs
- CacheForPrimitiveTypes.cs
- CornerRadius.cs
- EditorAttribute.cs
- NeutralResourcesLanguageAttribute.cs
- BaseCodeDomTreeGenerator.cs
- MarkerProperties.cs
- ActivityTypeCodeDomSerializer.cs
- WmlLinkAdapter.cs
- EraserBehavior.cs
- XmlSchemaType.cs
- CaseInsensitiveComparer.cs
- LateBoundChannelParameterCollection.cs
- XmlUTF8TextWriter.cs
- XmlDictionaryString.cs
- Monitor.cs
- DataContractSerializer.cs
- AlignmentYValidation.cs
- ConsoleTraceListener.cs
- WSSecurityOneDotZeroSendSecurityHeader.cs
- URLString.cs
- LongSumAggregationOperator.cs
- AddInServer.cs
- ChangeInterceptorAttribute.cs
- ZipIOExtraField.cs
- AssemblyLoader.cs
- Lease.cs
- CodeConditionStatement.cs
- List.cs
- SpecularMaterial.cs
- Lazy.cs
- BindingWorker.cs
- ConfigXmlComment.cs
- GradientBrush.cs
- HtmlEncodedRawTextWriter.cs
- EventEntry.cs
- FontStyleConverter.cs
- LineVisual.cs
- Formatter.cs
- CompilationLock.cs
- RegularExpressionValidator.cs
- ListItemParagraph.cs
- DataMemberFieldEditor.cs
- SearchExpression.cs
- GenericFlowSwitchHelper.cs
- ReflectionPermission.cs
- ProfileModule.cs
- DeferredElementTreeState.cs