sqlser.cs source code in C# .NET

                        
Code:
                         / Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / fx / src / Data / System / Data / Sql / sqlser.cs / 1 / sqlser.cs
                        

                        
                            //------------------------------------------------------------------------------ 
//  
//     Copyright (c) Microsoft Corporation. All Rights Reserved.
//     Information Contained Herein is Proprietary and Confidential.
//   
// [....]
// [....] 
// daltudov 
// [....]
// beysims 
// [....]
// vadimt
// venkar
// [....] 
//-----------------------------------------------------------------------------
 
using System; 
using System.Collections;
using System.Data; 
using System.Data.Common;
using System.Data.Sql;
using System.Data.SqlClient;
using System.Data.SqlTypes; 
using System.IO;
using System.Reflection; 
using System.Reflection.Emit; 
using System.Runtime.InteropServices;
using System.Runtime.Serialization; 
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;

namespace Microsoft.SqlServer.Server { 

    internal class SerializationHelperSql9 { 
        // Don't let anyone create an instance of this class. 
        private SerializationHelperSql9() {}
 
        // Get the m_size of the serialized stream for this type, in bytes.
        // This method creates an instance of the type using the public
        // no-argument constructor, serializes it, and returns the m_size
        // in bytes. 
        internal static int SizeInBytes(Type t) {
            return SizeInBytes(Activator.CreateInstance(t)); 
        } 

        // Get the m_size of the serialized stream for this type, in bytes. 
        internal static int SizeInBytes(object instance) {
            Type t = instance.GetType();
            Format k = GetFormat(t);
            DummyStream stream = new DummyStream(); 
            Serializer ser = GetSerializer(instance.GetType());
            ser.Serialize(stream, instance); 
            return (int) stream.Length; 
        }
 
        internal static void Serialize(Stream s, object instance) {
            GetSerializer(instance.GetType()).Serialize(s, instance);
        }
 
        internal static object Deserialize(Stream s, Type resultType) {
            return GetSerializer(resultType).Deserialize(s); 
        } 

        private static Format GetFormat(Type t) { 
            return GetUdtAttribute(t).Format;
        }

        //cache the relationship between a type and its serializer 
        //this is expensive to compute since it involves traversing the
        //custom attributes of the type using reflection. 
        // 
        //use a per-thread cache, so that there are no synchronization
        //issues when accessing cache entries from multiple threads. 
        [ThreadStatic]
        private static Hashtable m_types2Serializers;

        private static Serializer GetSerializer(Type t) { 
            if (m_types2Serializers == null)
                m_types2Serializers = new Hashtable(); 
 
            Serializer s = (Serializer) m_types2Serializers[t];
            if (s == null) { 
                s = (Serializer) GetNewSerializer(t);
                m_types2Serializers[t] = s;
            }
            return s; 
        }
 
        internal static int GetUdtMaxLength(Type t) { 
            SqlUdtInfo udtInfo = SqlUdtInfo.GetFromType(t);
 
            if (Format.Native == udtInfo.SerializationFormat) {
                //In the native format, the user does not specify the
                //max byte size, it is computed from the type definition
                return SerializationHelperSql9.SizeInBytes(t); 
            }
            else { 
                //In all other formats, the user specifies the maximum size in bytes. 
                return udtInfo.MaxByteSize;
            } 
        }

        private static object[] GetCustomAttributes (Type t) {
            return t.GetCustomAttributes(typeof(SqlUserDefinedTypeAttribute), false); 
        }
 
        internal static SqlUserDefinedTypeAttribute GetUdtAttribute(Type t) { 
            SqlUserDefinedTypeAttribute udtAttr = null;
            object[] attr = GetCustomAttributes (t); 

            if (attr != null && attr.Length == 1) {
                udtAttr = (SqlUserDefinedTypeAttribute) attr[0];
            } 
            else {
                throw InvalidUdtException.Create(t, Res.SqlUdtReason_NoUdtAttribute); 
            } 
            return udtAttr;
        } 

        // Create a new serializer for the given type.
        private static Serializer GetNewSerializer(Type t) {
            SqlUserDefinedTypeAttribute udtAttr = GetUdtAttribute(t); 
            Format k = GetFormat(t);
 
            switch (k) { 
                case Format.Native:
                    return new NormalizedSerializer(t); 
                case Format.UserDefined:
                    return new BinarySerializeSerializer(t);
                case Format.Unknown: // should never happen, but fall through
                default: 
                    throw ADP.InvalidUserDefinedTypeSerializationFormat(k);
            } 
        } 
    }
 
    // The base serializer class.
    internal abstract class Serializer {
        public abstract object Deserialize(Stream s);
        public abstract void Serialize(Stream s, object o); 
        protected Type m_type;
 
        protected Serializer(Type t) { 
            this.m_type = t;
        } 
    }

    internal sealed class NormalizedSerializer: Serializer {
        BinaryOrderedUdtNormalizer m_normalizer; 
        bool m_isFixedSize;
        int m_maxSize; 
 
        internal NormalizedSerializer(Type t): base(t) {
            SqlUserDefinedTypeAttribute udtAttr = SerializationHelperSql9.GetUdtAttribute(t); 
            this.m_normalizer = new BinaryOrderedUdtNormalizer(t, true);
            this.m_isFixedSize = udtAttr.IsFixedLength;
            this.m_maxSize = this.m_normalizer.Size;
        } 

        public override void Serialize(Stream s, object o) { 
            m_normalizer.NormalizeTopObject(o, s); 
        }
 
        public override object Deserialize(Stream s) {
            object result = m_normalizer.DeNormalizeTopObject(this.m_type, s);
            return result;
        } 
    }
 
    internal sealed class BinarySerializeSerializer: Serializer { 
        internal BinarySerializeSerializer(Type t): base(t) {
        } 

        public override void Serialize(Stream s, object o) {
            BinaryWriter w = new BinaryWriter(s);
            ((IBinarySerialize)o).Write(w); 
        }
 
        public override object Deserialize(Stream s) { 
            object instance = Activator.CreateInstance(m_type);
            BinaryReader r = new BinaryReader(s); 
            ((IBinarySerialize)instance).Read(r);
            return instance;
        }
    } 

    // A dummy stream class, used to get the number of bytes written 
    // to the stream. 
    internal sealed class DummyStream: Stream {
        private long m_size; 

        public DummyStream() {
        }
 
        private void DontDoIt() {
            throw new Exception(Res.GetString(Res.Sql_InternalError)); 
        } 

        public override bool CanRead { 
            get {
                return false;
            }
        } 

        public override bool CanWrite { 
            get { 
                return true;
            } 
        }

        public override bool CanSeek {
            get { 
                return false;
            } 
        } 

        public override long Position { 
            get {
                return this.m_size;
            }
            set { 
                this.m_size = value;
            } 
        } 

        public override long Length { 
            get {
                return this.m_size;
            }
        } 

        public override void SetLength(long value) { 
            this.m_size = value; 
        }
 
        public override long Seek(long value, SeekOrigin loc) {
            DontDoIt();
            return -1;
        } 

        public override void Flush() { 
        } 

        public override int Read(byte[] buffer, int offset, int count) { 
            DontDoIt();
            return -1;
        }
 
        public override void Write(byte[] buffer, int offset, int count) {
            this.m_size += count; 
        } 
    }
} 

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
//------------------------------------------------------------------------------ 
//  
//     Copyright (c) Microsoft Corporation. All Rights Reserved.
//     Information Contained Herein is Proprietary and Confidential.
//   
// [....]
// [....] 
// daltudov 
// [....]
// beysims 
// [....]
// vadimt
// venkar
// [....] 
//-----------------------------------------------------------------------------
 
using System; 
using System.Collections;
using System.Data; 
using System.Data.Common;
using System.Data.Sql;
using System.Data.SqlClient;
using System.Data.SqlTypes; 
using System.IO;
using System.Reflection; 
using System.Reflection.Emit; 
using System.Runtime.InteropServices;
using System.Runtime.Serialization; 
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;

namespace Microsoft.SqlServer.Server { 

    internal class SerializationHelperSql9 { 
        // Don't let anyone create an instance of this class. 
        private SerializationHelperSql9() {}
 
        // Get the m_size of the serialized stream for this type, in bytes.
        // This method creates an instance of the type using the public
        // no-argument constructor, serializes it, and returns the m_size
        // in bytes. 
        internal static int SizeInBytes(Type t) {
            return SizeInBytes(Activator.CreateInstance(t)); 
        } 

        // Get the m_size of the serialized stream for this type, in bytes. 
        internal static int SizeInBytes(object instance) {
            Type t = instance.GetType();
            Format k = GetFormat(t);
            DummyStream stream = new DummyStream(); 
            Serializer ser = GetSerializer(instance.GetType());
            ser.Serialize(stream, instance); 
            return (int) stream.Length; 
        }
 
        internal static void Serialize(Stream s, object instance) {
            GetSerializer(instance.GetType()).Serialize(s, instance);
        }
 
        internal static object Deserialize(Stream s, Type resultType) {
            return GetSerializer(resultType).Deserialize(s); 
        } 

        private static Format GetFormat(Type t) { 
            return GetUdtAttribute(t).Format;
        }

        //cache the relationship between a type and its serializer 
        //this is expensive to compute since it involves traversing the
        //custom attributes of the type using reflection. 
        // 
        //use a per-thread cache, so that there are no synchronization
        //issues when accessing cache entries from multiple threads. 
        [ThreadStatic]
        private static Hashtable m_types2Serializers;

        private static Serializer GetSerializer(Type t) { 
            if (m_types2Serializers == null)
                m_types2Serializers = new Hashtable(); 
 
            Serializer s = (Serializer) m_types2Serializers[t];
            if (s == null) { 
                s = (Serializer) GetNewSerializer(t);
                m_types2Serializers[t] = s;
            }
            return s; 
        }
 
        internal static int GetUdtMaxLength(Type t) { 
            SqlUdtInfo udtInfo = SqlUdtInfo.GetFromType(t);
 
            if (Format.Native == udtInfo.SerializationFormat) {
                //In the native format, the user does not specify the
                //max byte size, it is computed from the type definition
                return SerializationHelperSql9.SizeInBytes(t); 
            }
            else { 
                //In all other formats, the user specifies the maximum size in bytes. 
                return udtInfo.MaxByteSize;
            } 
        }

        private static object[] GetCustomAttributes (Type t) {
            return t.GetCustomAttributes(typeof(SqlUserDefinedTypeAttribute), false); 
        }
 
        internal static SqlUserDefinedTypeAttribute GetUdtAttribute(Type t) { 
            SqlUserDefinedTypeAttribute udtAttr = null;
            object[] attr = GetCustomAttributes (t); 

            if (attr != null && attr.Length == 1) {
                udtAttr = (SqlUserDefinedTypeAttribute) attr[0];
            } 
            else {
                throw InvalidUdtException.Create(t, Res.SqlUdtReason_NoUdtAttribute); 
            } 
            return udtAttr;
        } 

        // Create a new serializer for the given type.
        private static Serializer GetNewSerializer(Type t) {
            SqlUserDefinedTypeAttribute udtAttr = GetUdtAttribute(t); 
            Format k = GetFormat(t);
 
            switch (k) { 
                case Format.Native:
                    return new NormalizedSerializer(t); 
                case Format.UserDefined:
                    return new BinarySerializeSerializer(t);
                case Format.Unknown: // should never happen, but fall through
                default: 
                    throw ADP.InvalidUserDefinedTypeSerializationFormat(k);
            } 
        } 
    }
 
    // The base serializer class.
    internal abstract class Serializer {
        public abstract object Deserialize(Stream s);
        public abstract void Serialize(Stream s, object o); 
        protected Type m_type;
 
        protected Serializer(Type t) { 
            this.m_type = t;
        } 
    }

    internal sealed class NormalizedSerializer: Serializer {
        BinaryOrderedUdtNormalizer m_normalizer; 
        bool m_isFixedSize;
        int m_maxSize; 
 
        internal NormalizedSerializer(Type t): base(t) {
            SqlUserDefinedTypeAttribute udtAttr = SerializationHelperSql9.GetUdtAttribute(t); 
            this.m_normalizer = new BinaryOrderedUdtNormalizer(t, true);
            this.m_isFixedSize = udtAttr.IsFixedLength;
            this.m_maxSize = this.m_normalizer.Size;
        } 

        public override void Serialize(Stream s, object o) { 
            m_normalizer.NormalizeTopObject(o, s); 
        }
 
        public override object Deserialize(Stream s) {
            object result = m_normalizer.DeNormalizeTopObject(this.m_type, s);
            return result;
        } 
    }
 
    internal sealed class BinarySerializeSerializer: Serializer { 
        internal BinarySerializeSerializer(Type t): base(t) {
        } 

        public override void Serialize(Stream s, object o) {
            BinaryWriter w = new BinaryWriter(s);
            ((IBinarySerialize)o).Write(w); 
        }
 
        public override object Deserialize(Stream s) { 
            object instance = Activator.CreateInstance(m_type);
            BinaryReader r = new BinaryReader(s); 
            ((IBinarySerialize)instance).Read(r);
            return instance;
        }
    } 

    // A dummy stream class, used to get the number of bytes written 
    // to the stream. 
    internal sealed class DummyStream: Stream {
        private long m_size; 

        public DummyStream() {
        }
 
        private void DontDoIt() {
            throw new Exception(Res.GetString(Res.Sql_InternalError)); 
        } 

        public override bool CanRead { 
            get {
                return false;
            }
        } 

        public override bool CanWrite { 
            get { 
                return true;
            } 
        }

        public override bool CanSeek {
            get { 
                return false;
            } 
        } 

        public override long Position { 
            get {
                return this.m_size;
            }
            set { 
                this.m_size = value;
            } 
        } 

        public override long Length { 
            get {
                return this.m_size;
            }
        } 

        public override void SetLength(long value) { 
            this.m_size = value; 
        }
 
        public override long Seek(long value, SeekOrigin loc) {
            DontDoIt();
            return -1;
        } 

        public override void Flush() { 
        } 

        public override int Read(byte[] buffer, int offset, int count) { 
            DontDoIt();
            return -1;
        }
 
        public override void Write(byte[] buffer, int offset, int count) {
            this.m_size += count; 
        } 
    }
} 

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.

                        

                        

                        
                        

Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK

• RoleBoolean.cs
• BrowserCapabilitiesFactory35.cs
• TableCell.cs
• DataKeyArray.cs
• WebCategoryAttribute.cs
• FixedNode.cs
• WorkflowServiceBehavior.cs
• RestHandler.cs
• CalendarDay.cs
• safex509handles.cs
• ResourcesChangeInfo.cs
• LinqDataSourceSelectEventArgs.cs
• DesignerView.cs
• XamlReaderConstants.cs
• WorkflowOperationContext.cs
• Calendar.cs
• OutputCacheSettingsSection.cs
• SID.cs
• PropertyToken.cs
• MaterialGroup.cs
• TypeCollectionPropertyEditor.cs
• ModuleBuilderData.cs
• InfoCardRSAPKCS1SignatureFormatter.cs
• GenericNameHandler.cs
• XamlSerializer.cs
• ScriptingAuthenticationServiceSection.cs
• ListItemConverter.cs
• OutputCacheProfileCollection.cs
• SqlClientPermission.cs
• RuntimeHandles.cs
• StandardMenuStripVerb.cs
• CharUnicodeInfo.cs
• TextReturnReader.cs
• DbProviderConfigurationHandler.cs
• GlyphsSerializer.cs
• ExtensionQuery.cs
• XmlAttributeCache.cs
• OletxVolatileEnlistment.cs
• Size.cs
• Transform.cs
• propertytag.cs
• Delegate.cs
• _LocalDataStore.cs
• OleDbCommand.cs
• Identity.cs
• LogExtent.cs
• XmlILTrace.cs
• InvalidCommandTreeException.cs
• ClientConfigPaths.cs
• TypeAccessException.cs
• AccessDataSourceDesigner.cs
• SafeBitVector32.cs
• StreamMarshaler.cs
• WebPartConnectionsDisconnectVerb.cs
• VirtualDirectoryMappingCollection.cs
• EditorZoneAutoFormat.cs
• Exceptions.cs
• WorkflowInstanceUnhandledExceptionRecord.cs
• WorkerRequest.cs
• EntitySqlQueryCacheKey.cs
• RangeExpression.cs
• FrameDimension.cs
• CollectionBase.cs
• EditorBrowsableAttribute.cs
• CharacterMetricsDictionary.cs
• TimeoutValidationAttribute.cs
• _ShellExpression.cs
• MetadataPropertyAttribute.cs
• CompatibleComparer.cs
• LinearQuaternionKeyFrame.cs
• XmlSchemaSimpleType.cs
• PeerDefaultCustomResolverClient.cs
• DoubleLinkListEnumerator.cs
• ComponentResourceManager.cs
• DesignerAttributeInfo.cs
• ProjectionPath.cs
• SessionStateModule.cs
• SQLInt64Storage.cs
• InvalidOleVariantTypeException.cs
• ImageAutomationPeer.cs
• SocketElement.cs
• RewritingProcessor.cs
• Win32SafeHandles.cs
• SoapHelper.cs
• XmlSchemaObject.cs
• CodeObjectCreateExpression.cs
• DataRecordObjectView.cs
• SemanticBasicElement.cs
• SettingsContext.cs
• TableRow.cs
• ToolboxComponentsCreatingEventArgs.cs
• Compress.cs
• DesignerDataSchemaClass.cs
• Identity.cs
• PersonalizationProviderHelper.cs
• BasicBrowserDialog.designer.cs
• FilteredReadOnlyMetadataCollection.cs
• ListViewTableRow.cs
• SqlPersistenceWorkflowInstanceDescription.cs
• NativeMethodsCLR.cs