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

• Grant.cs
• XmlSchemaAppInfo.cs
• PageTheme.cs
• RoleGroup.cs
• SqlFileStream.cs
• UniqueEventHelper.cs
• SelectionRange.cs
• Canvas.cs
• NestedContainer.cs
• NameValueFileSectionHandler.cs
• AttachedPropertyBrowsableAttribute.cs
• PenThreadPool.cs
• XmlSchemaAttributeGroupRef.cs
• FieldAccessException.cs
• RoleGroup.cs
• SystemUdpStatistics.cs
• RotateTransform3D.cs
• ControlBindingsConverter.cs
• SimpleTextLine.cs
• PingOptions.cs
• ValueSerializerAttribute.cs
• FeedUtils.cs
• PersonalizationAdministration.cs
• AssociatedControlConverter.cs
• RowToParametersTransformer.cs
• Executor.cs
• SafeNativeMethods.cs
• Stack.cs
• CalloutQueueItem.cs
• InfoCardRSACryptoProvider.cs
• XPathAncestorQuery.cs
• PointValueSerializer.cs
• PreloadedPackages.cs
• CacheAxisQuery.cs
• PackageStore.cs
• TaskResultSetter.cs
• DatagramAdapter.cs
• lengthconverter.cs
• StyleXamlTreeBuilder.cs
• EventDescriptor.cs
• PathFigureCollection.cs
• CodeParameterDeclarationExpressionCollection.cs
• EntitySetRetriever.cs
• TextServicesLoader.cs
• SettingsBindableAttribute.cs
• OleDbEnumerator.cs
• DrawingVisual.cs
• ProcessModuleCollection.cs
• PassportAuthenticationModule.cs
• BitArray.cs
• InstanceOwnerException.cs
• DocumentOrderComparer.cs
• JsonObjectDataContract.cs
• ProxyManager.cs
• Int32Storage.cs
• ZipIOExtraField.cs
• DataControlButton.cs
• DataDocumentXPathNavigator.cs
• DateTimeValueSerializerContext.cs
• InProcStateClientManager.cs
• IndentedWriter.cs
• GridViewRowCollection.cs
• wmiprovider.cs
• TextDecorations.cs
• GacUtil.cs
• ParameterCollection.cs
• RegisteredHiddenField.cs
• DataGridViewTextBoxCell.cs
• OleDbConnectionPoolGroupProviderInfo.cs
• TextInfo.cs
• UInt32Converter.cs
• AuthenticationSection.cs
• ProfileGroupSettings.cs
• HtmlElement.cs
• Error.cs
• PermissionRequestEvidence.cs
• ThicknessConverter.cs
• Schedule.cs
• X509Extension.cs
• ProxyFragment.cs
• FormsAuthenticationTicket.cs
• ObjectConverter.cs
• DocumentPageViewAutomationPeer.cs
• HttpWebRequestElement.cs
• PackageFilter.cs
• WebPartPersonalization.cs
• MatrixCamera.cs
• MetadataArtifactLoaderXmlReaderWrapper.cs
• EventListener.cs
• GetImportFileNameRequest.cs
• VerificationException.cs
• TextElement.cs
• ConfigurationStrings.cs
• ObjectListItemCollection.cs
• UrlAuthFailedErrorFormatter.cs
• BindingWorker.cs
• ContainerCodeDomSerializer.cs
• InstanceContextMode.cs
• SystemException.cs
• ToolStripLabel.cs