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

• StrokeNodeOperations.cs
• DropSource.cs
• webproxy.cs
• WebServiceClientProxyGenerator.cs
• ObjectListTitleAttribute.cs
• ApplicationTrust.cs
• ByteKeyFrameCollection.cs
• ViewStateModeByIdAttribute.cs
• ParserOptions.cs
• SpanIndex.cs
• SizeAnimation.cs
• DateTimeConverter2.cs
• ItemChangedEventArgs.cs
• PropertyValueChangedEvent.cs
• TransactionInformation.cs
• MouseCaptureWithinProperty.cs
• ReflectEventDescriptor.cs
• DataTrigger.cs
• AddInAttribute.cs
• GeneralTransform3DTo2D.cs
• DbConnectionPoolIdentity.cs
• DetailsViewPageEventArgs.cs
• LinqDataSourceContextData.cs
• LocationUpdates.cs
• MenuItemBinding.cs
• IisTraceListener.cs
• ConfigXmlSignificantWhitespace.cs
• TextParagraph.cs
• BitmapEffect.cs
• UMPAttributes.cs
• XmlSchemaDocumentation.cs
• FuncCompletionCallbackWrapper.cs
• BaseParagraph.cs
• NumberFormatter.cs
• WizardStepCollectionEditor.cs
• DESCryptoServiceProvider.cs
• ListenerAdapter.cs
• ColumnPropertiesGroup.cs
• PrivacyNoticeElement.cs
• EntityDataSourceEntityTypeFilterConverter.cs
• OrderedDictionary.cs
• DataGridViewRow.cs
• ZoneLinkButton.cs
• GridViewPageEventArgs.cs
• MetadataItemEmitter.cs
• PropertyMapper.cs
• WebPartCatalogAddVerb.cs
• SpellerHighlightLayer.cs
• sqlstateclientmanager.cs
• CursorConverter.cs
• Policy.cs
• DrawingContextDrawingContextWalker.cs
• GlobalEventManager.cs
• SiteMapNodeItemEventArgs.cs
• TabControl.cs
• HtmlElementEventArgs.cs
• OrthographicCamera.cs
• QuadTree.cs
• Positioning.cs
• PeerObject.cs
• FormatSettings.cs
• ProtocolsConfigurationEntry.cs
• TcpSocketManager.cs
• BaseTemplateCodeDomTreeGenerator.cs
• XamlDesignerSerializationManager.cs
• ThreadAttributes.cs
• XmlSchemaImporter.cs
• DeviceContext2.cs
• UpdatePanelControlTrigger.cs
• DownloadProgressEventArgs.cs
• DataRecordObjectView.cs
• AttributeCallbackBuilder.cs
• StylusPointPropertyUnit.cs
• SocketPermission.cs
• BooleanKeyFrameCollection.cs
• EntityDataSourceDataSelectionPanel.designer.cs
• HostProtectionException.cs
• SiteOfOriginPart.cs
• NameTable.cs
• Transform.cs
• httpserverutility.cs
• CodeDomExtensionMethods.cs
• __ComObject.cs
• MethodBuilderInstantiation.cs
• VBIdentifierTrimConverter.cs
• MetafileEditor.cs
• SetterBaseCollection.cs
• SessionMode.cs
• BufferModeSettings.cs
• CompositeDataBoundControl.cs
• DataBindEngine.cs
• DetailsViewRowCollection.cs
• CredentialManagerDialog.cs
• UshortList2.cs
• CaseInsensitiveHashCodeProvider.cs
• RemoveFromCollection.cs
• ConstructorBuilder.cs
• DataGridViewButtonCell.cs
• DataGridViewCellStyleChangedEventArgs.cs
• EventHandlerList.cs