使用 CLR 和 XML 创建联系信息

项目
05/08/2013

SQL Server 的联系人示例提供了一些有用的实用工具，这些实用工具在基本的 AdventureWorks2012 示例数据库之上形成了一层额外的功能。第一个实用工具为 AdventureWorks2012 数据库中所涉及的各种类型的人创建联系记录。联系信息通过使用 XML 来指定，并传递到基于 C# 的存储过程或 VB 存储过程，以创建 XML 并将其放入该数据库中的正确表。

先决条件

若要创建和运行此项目，必须安装下列软件：

SQL Server 或 SQL Server Express。您可以从 SQL Server Express Documentation and Samples （Express 文档和示例）网站免费获取 SQL Server Express。
SQL Server 开发人员网站提供的 AdventureWorks 数据库
.NET Framework SDK 2.0 或更高版本，或 Microsoft Visual Studio 2005 或更高版本。您可以免费获取 .NET Framework SDK。
此外，还必须满足以下条件：
您使用的 SQL Server 实例必须已启用 CLR 集成。
若要启用 CLR 集成，请执行以下步骤：

启用 CLR 集成
- 执行以下 Transact-SQL 命令：
sp_configure 'clr enabled', 1

GO

RECONFIGURE

GO

注意

若要启用 CLR，您必须具有 ALTER SETTINGS 服务器级别权限，sysadmin 和 serveradmin 固定服务器角色的成员隐式拥有该权限。
必须在您使用的 SQL Server 实例上安装 AdventureWorks 数据库。
如果您不是要使用的 SQL Server 实例的管理员，则必须让管理员授予您 CreateAssembly 权限，才能完成安装。

注意
若要启用 CLR，您必须具有 ALTER SETTINGS 服务器级别权限，sysadmin 和 serveradmin 固定服务器角色的成员隐式拥有该权限。

生成示例

按照以下说明创建和运行该示例：

打开 Visual Studio 或 .NET Framework 命令提示符。
如有必要，为您的示例创建目录。对于此示例，我们将使用 C:\MySample。
在 c:\MySample 中，创建 Contacts.vb（用于 Visual Basic 示例）或 Contacts.cs（用于 C# 示例），并将相应的 Visual Basic 或 C# 示例代码（如下所示）复制到该文件中。
从命令行提示符执行以下代码之一（具体取决于所选的语言)，对示例代码进行编译。
Vbc /reference:C:\Windows\Microsoft.NET\Framework\v2.0.50727\System.Data.dll,C:\Windows\Microsoft.NET\Framework\v2.0.50727\System.dll,C:\Windows\Microsoft.NET\Framework\v2.0.50727\System.Xml.dll /target:library Contacts.vb
Csc /reference:C:\Windows\Microsoft.NET\Framework\v2.0.50727\System.Data.dll /reference:C:\Windows\Microsoft.NET\Framework\v2.0.50727\System.dll /reference:C:\Windows\Microsoft.NET\Framework\v2.0.50727\System.XML.dll /target:library Contacts.cs
将 Transact-SQL 安装代码复制到一个文件中，并在示例目录中将其另存为 Install.sql。
如果该示例安装在 C:\MySample\ 之外的目录中，请按说明编辑文件 Install.sql 以指向该位置。
通过执行以下命令部署程序集和存储过程：
- sqlcmd -E -I -i install.sql
将 Transact-SQL 测试命令脚本复制到一个文件中，并在示例目录中将其另存为 test.sql。
使用以下命令执行测试脚本：
- sqlcmd -E -I -i test.sql
将 Transact-SQL 清除脚本复制到一个文件中，并在示例目录中将其另存为 cleanup.sql。
使用以下命令执行该脚本：
- sqlcmd -E -I -i cleanup.sql

示例代码

下面是此示例的代码列表。

using System;
using System.IO;
using System.Data;
using System.Data.SqlTypes;
using System.Xml;
using System.Collections.Generic;
using System.Globalization;
using System.Runtime.Serialization;
using Microsoft.SqlServer.Server;
using System.Data.SqlClient;
    /// <summary>
    /// Utility class for creating contact information.  A row in the contact table
    /// is inserted.  Additionally, rows in one or more other tables are inserted based on
    /// the information provided in the XML document passed to the CreateContact function.
    /// For individuals and employees, the contact record is one to one relationship with 
    /// the respective tables so those rows are created when the contact record is created.
    /// For stores and vendors, there is a one to many relationship for contacts, so a row is added to 
    /// either the Sales.StoreContact or Purchasing.VendorContact table (as appropriate), but 
    /// neither store or vendor rows are inserted into the database.
    /// 
    /// </summary>
    public sealed class ContactUtils
    {

        private ContactUtils()
        {
        }

   
        public static void CreateContact(SqlString contactData,
                                         out SqlInt32 contactId,
                                         out SqlInt32 customerId)
        {
            //TODO: When we can pass XML from T-SQL then contactData can be a SqlXmlReader
using (StringReader sr = new StringReader(contactData.Value))
{
XmlReader reader = XmlReader.Create(sr);
ContactCreator creator = null;

try
{
reader.MoveToContent();
EnsureEqual(reader.LocalName, "Contact");
reader.MoveToContent();
reader.ReadStartElement();

switch (reader.LocalName)
{
case "Individual": creator = new IndividualCreator(); break;
case "Store": creator = new StoreCreator(); break;
case "Vendor": creator = new VendorCreator(); break;
case "Employee": creator = new EmployeeCreator(); break;
default: break;
}

if (creator != null)
{
reader.ReadStartElement();
reader.MoveToContent();
creator.LoadDictionary(reader);
creator.Create();
contactId = creator.ContactId;
customerId = creator.CustomerId;
}
else
{
contactId = -1;
customerId = -1;

throw new AWUtilitiesContactParseException(
"Individual | Store | Vendor | Employee", reader.LocalName);
}
}
finally
{
reader.Close();
}
}
        }

        public static void EnsureEqual(String localName,
                                       String desiredLocalName)
        {
if (localName == null) throw new ArgumentNullException("localName");
            if (!localName.Equals(desiredLocalName))
            {
                throw new AWUtilitiesContactParseException(desiredLocalName,
                                                       localName);
            }
        }
    }

    /// <summary>
    ///Base class for all the contact creation classes.  Responsible for parsing the XML,
    ///providing the public API for all types of contacts, and for inserting the row 
    ///in the Person.Contact table.
    /// </summary>
  
    public abstract class ContactCreator
    {

        internal int parameterCount;
        internal int valueCount;

        internal Dictionary<String, String> contactDictionary = new Dictionary<
            String, String>();

        private static readonly String[] xmlColumns = new String[] {
"AdditionalContactInfo", "Demographics"
};

        private static readonly String[] nestedColumns = new String[] {
"Address"
};

        public int ContactId
        {
            get
            {
                String val;
                if (contactDictionary.TryGetValue("ContactID", out val))
                    return Int32.Parse(val, CultureInfo.InvariantCulture);
                else
                    return -1;
            }
            set
            {
                contactDictionary["ContactID"]
                    = value.ToString(CultureInfo.InvariantCulture);
            }
        }

        public int CustomerId
        {
            get
            {
                string val;

                if (contactDictionary.TryGetValue("CustomerID", out val))
                    return Int32.Parse(val, CultureInfo.InvariantCulture);
                else

                    //Not every contact is for a customer.  Return -1 in that case.
                    return -1;
            }
            set
            {
                contactDictionary["CustomerID"]
                    = value.ToString(CultureInfo.InvariantCulture);
            }
        }

        public void LoadDictionary(XmlReader reader)
        {
            while (reader.IsStartElement())
            {
                String key = reader.LocalName;
                String val;

                if (Array.IndexOf(xmlColumns, key) > -1)
                    val = reader.ReadInnerXml();
                else if (Array.IndexOf(nestedColumns, key) > -1)
                {
                    reader.ReadStartElement();
                    LoadDictionary(reader);
                    reader.ReadEndElement();
                    continue;
                }
                else
                    val = reader.ReadElementString();

                contactDictionary.Add(key, val);
            }
        }


        protected void ResetCounters(int valueForReset)
        {
            parameterCount = valueForReset;
            valueCount = valueForReset;
        }

        public String MaybeParameter(String name)
        {
            if (contactDictionary.ContainsKey(name))
            {
                if (parameterCount++ == 0)
                    return name;
                else
                    return ", " + name;
            }
            else
                return string.Empty;
        }

        public String MaybeValue(String name)
        {
            if (contactDictionary.ContainsKey(name))
            {
                if (valueCount++ == 0)
                    return "@" + name;
                else
                    return ", @" + name;
            }
            else
                return string.Empty;
        }

public static object TypeConvert(String valueToConvert, SqlDbType parameterType)
        {
if (valueToConvert == null) 
throw new ArgumentNullException("valueToConvert");
            switch (parameterType)
            {
                case SqlDbType.BigInt:
                    return Int64.Parse(valueToConvert,
                        CultureInfo.InvariantCulture);

                case SqlDbType.Int:
                    return Int32.Parse(valueToConvert,
                        CultureInfo.InvariantCulture);

                case SqlDbType.SmallInt:
                    return Int16.Parse(valueToConvert,
                        CultureInfo.InvariantCulture);

                case SqlDbType.TinyInt:
                    return Byte.Parse(valueToConvert,
                        CultureInfo.InvariantCulture);

                case SqlDbType.Bit:
                    {
                        if (valueToConvert.Equals("1") ||
                            valueToConvert.Equals("true")) return 1;
                        else
                            return 0;
                    }

                case SqlDbType.NVarChar:
                case SqlDbType.VarChar:
                case SqlDbType.NChar:
                case SqlDbType.NText:
                case SqlDbType.Text:
                case SqlDbType.Char:
                case SqlDbType.Xml:
                    return valueToConvert;

                case SqlDbType.DateTime:
                    return DateTime.Parse(valueToConvert,
                        CultureInfo.InvariantCulture);

                case SqlDbType.Money:
                    return Decimal.Parse(valueToConvert,
                        CultureInfo.InvariantCulture);

                default:
                    return "unknown conversion";
            }
        }

        public void MaybeAddCommandParameter(String keyName, String parameterName,
                                             SqlCommand command,
                                             SqlDbType parameterType,
                                             bool isRequired,
                                             String defaultValue)
        {
            if (isRequired || contactDictionary.ContainsKey(keyName))
            {
                SqlParameter param =
                             new SqlParameter("@" + parameterName, parameterType);
                String val = (contactDictionary.ContainsKey(keyName)) ?
                             contactDictionary[keyName] : defaultValue;

                param.Value = TypeConvert(val, parameterType);
                command.Parameters.Add(param);
            }
        }
        public void MaybeAddCommandParameter(String name, SqlCommand command,
                                             SqlDbType parameterType,
                                             bool isRequired,
                                             String defaultValue)
        {
            MaybeAddCommandParameter(name, name, command, parameterType,
                                     isRequired, defaultValue);
        }

        public void MaybeAddCommandParameter(String name, SqlCommand command,
                                             SqlDbType parameterType, int size,
                                             bool isRequired,
                                             String defaultValue)
        {
            if (isRequired || contactDictionary.ContainsKey(name))
            {
                MaybeAddCommandParameter(name, command, parameterType,
                                         isRequired, defaultValue);
                command.Parameters[command.Parameters.Count - 1].Size = size;
            }
        }

        public void MaybeAddCommandParameter(String keyName, String paramName, SqlCommand command,
                                             SqlDbType parameterType, int size,
                                             bool isRequired,
                                             String defaultValue)
        {
            if (isRequired || contactDictionary.ContainsKey(keyName))
            {
                MaybeAddCommandParameter(keyName, paramName, command, parameterType,
                                         isRequired, defaultValue);
                command.Parameters[command.Parameters.Count - 1].Size = size;
            }
        }

        public virtual void Create()
        {
            using (SqlConnection conn = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                ResetCounters(1);

                string parameters = String.Format(CultureInfo.InvariantCulture,
                    "NameStyle{0}, FirstName{1}, LastName{2}{3}{4}{5}, "
                    + "PasswordHash, PasswordSalt{6}",
                    MaybeParameter("Title"), MaybeParameter("MiddleName"),
                    MaybeParameter("Suffix"), MaybeParameter("EmailAddress"),
                    MaybeParameter("EmailPromotion"), MaybeParameter("Phone"),
                    MaybeParameter("AdditionalContactInfo"));
                string values = String.Format(CultureInfo.InvariantCulture,
                    "@NameStyle{0}, @FirstName{1}, @LastName{2}{3}{4}{5}, "
                    + "@PasswordHash, @PasswordSalt{6}",
                    MaybeValue("Title"), MaybeValue("MiddleName"),
                    MaybeValue("Suffix"), MaybeValue("EmailAddress"),
                    MaybeValue("EmailPromotion"), MaybeValue("Phone"),
                    MaybeValue("AdditionalContactInfo"));

                String text = String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO Person.Contact ({0}) VALUES ({1}); "
                    + "SELECT CAST(SCOPE_IDENTITY() as Int);",
                    parameters, values);
                command.CommandText = text;
                MaybeAddCommandParameter("NameStyle", command,
                    SqlDbType.Bit, true, "0");
                MaybeAddCommandParameter("Title", command,
                    SqlDbType.NVarChar, 8, false, null);
                MaybeAddCommandParameter("FirstName", command,
                    SqlDbType.NVarChar, 50, true, string.Empty);
                MaybeAddCommandParameter("MiddleName", command,
                    SqlDbType.NVarChar, 50, false, null);
                MaybeAddCommandParameter("LastName", command,
                    SqlDbType.NVarChar, 50, true, string.Empty);
                MaybeAddCommandParameter("Suffix", command,
                    SqlDbType.NVarChar, 10, false, null);
                MaybeAddCommandParameter("EmailAddress", command,
                    SqlDbType.NVarChar, 50, true, string.Empty);
                MaybeAddCommandParameter("EmailPromotion", command,
                    SqlDbType.Int, false, null);
                MaybeAddCommandParameter("Phone", command,
                    SqlDbType.NVarChar, 25, false, null);
                MaybeAddCommandParameter("PasswordHash", command,
                    SqlDbType.VarChar, 40, true, string.Empty);
                MaybeAddCommandParameter("PasswordSalt", command,
                    SqlDbType.VarChar, 10, true, string.Empty);
                MaybeAddCommandParameter("AdditionalContactInfo", command,
                    SqlDbType.Xml, false, null);
                conn.Open();
                this.ContactId = (int)command.ExecuteScalar();
            }
        }
    }



    /// <summary>
    ///A base class based on ContactCreator which is responsible for inserting information about
    ///a customer by inserting a row in the 
    ///Sales.Customer table.  Currently only used by the IndividualCreator class, but
    ///it might be useful if there was a variant made of the StoreCreator which actually inserted
    ///a Sales.Store row. 
    /// </summary>
  
    public abstract class CustomerCreator : ContactCreator
    {
        public override void Create()
        {
            base.Create();
            using (SqlConnection conn 
                = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                if (!contactDictionary.ContainsKey("CustomerType"))
                    contactDictionary["CustomerType"] = "I";
                ResetCounters(0);
                string parameters = String.Format(CultureInfo.InvariantCulture, 
                    "{0}{1}{2}", MaybeParameter("SalesPersonID"),
                    MaybeParameter("TerritoryID"),
                    //CustomerType is always present, but we
                    //need to get the commas right
                    MaybeParameter("CustomerType"));
                string values = String.Format(CultureInfo.InvariantCulture, 
                    "{0}{1}{2}", MaybeValue("SalesPersonID"),
                    MaybeValue("TerritoryID"), MaybeValue("CustomerType"));
                command.CommandText = String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO Sales.Customer ({0}) VALUES ({1}); "
                    + "SELECT CAST(SCOPE_IDENTITY() as Int);",
                    parameters, values);
                MaybeAddCommandParameter("SalesPersonID", command,
                    SqlDbType.Int, false, null);
                MaybeAddCommandParameter("TerritoryID", command,
                    SqlDbType.Int, false, null);
                MaybeAddCommandParameter("CustomerType", command,
                    SqlDbType.NChar, 1, true, "I");
                conn.Open();
                this.CustomerId = (int)command.ExecuteScalar();
            }
        }
    }

    /// <summary>
    ///Responsible for adding information about an individual purchasing by 
    ///inserting a row in the Sales.Individual table.
    /// </summary>
  
    public class IndividualCreator : CustomerCreator
    {
        public override void Create()
        {
            base.Create();
            using (SqlConnection conn
                = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                ResetCounters(2);
                String parameters = String.Format(CultureInfo.InvariantCulture,
                    "CustomerID, ContactID{0}", MaybeParameter("Demographics"));
                String values = String.Format(CultureInfo.InvariantCulture,
                    "@CustomerID, @ContactID{0}", MaybeValue("Demographics"));
                command.CommandText =
                    String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO Sales.Individual ({0}) VALUES ({1});",
                    parameters, values);
                MaybeAddCommandParameter("CustomerID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("ContactID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("Demographics", command,
                    SqlDbType.Xml, false, null);
                conn.Open();
                command.ExecuteNonQuery();
            }
        }
    }

    /// <summary>
    ///Responsible for relating a contact to a store by inserting a row in the 
    ///Sales.StoreContact table.
    /// </summary>
   
    public class StoreCreator : ContactCreator
    {
        public override void Create()
        {
            base.Create();
            using (SqlConnection conn 
                = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                command.CommandText =
                    String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO Sales.StoreContact (CustomerID, ContactID, "
                    + "ContactTypeID) VALUES (@CustomerID, @ContactID, @ContactTypeID);");
                MaybeAddCommandParameter("CustomerID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("ContactID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("ContactTypeID", command,
                    SqlDbType.TinyInt, true, string.Empty);
                conn.Open();
                command.ExecuteNonQuery();
            }
        }
    }

    /// <summary>
    ///Responsible for relating a contact to a vendor by inserting a row in the 
    ///Purchasing.VendorContact table.
    /// </summary>
    
    public class VendorCreator : ContactCreator
    {
        public override void Create()
        {
            base.Create();
            using (SqlConnection conn 
                = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                String parameters = "VendorID, ContactID, ContactTypeID";
                String values = String.Format(CultureInfo.InvariantCulture, 
                    "@VendorID, @ContactID, @ContactTypeID");

                command.CommandText =
                    String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO Purchasing.VendorContact ({0}) VALUES ({1});",
                    parameters, values);
                MaybeAddCommandParameter("VendorID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("ContactID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("ContactTypeID", command,
                    SqlDbType.TinyInt, true, string.Empty);
                conn.Open();
                command.ExecuteNonQuery();
            }
        }
    }

    /// <summary>
    ///Responsible for adding information about an employee by creating an address and then
    ///inserting a row in the HumanResources.Employee table.
    /// </summary>
   
    public class EmployeeCreator : ContactCreator
    {
        public override void Create()
        {
            base.Create();
            CreateAddress();
            int employeeID = -1;
            using (SqlConnection conn = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                ResetCounters(3);
                String parameters = String.Format(CultureInfo.InvariantCulture,
                    "NationalIDNumber, ContactID, LoginID{0}, Title, "
                    + "BirthDate, MaritalStatus, Gender, HireDate, "
                    + "SalariedFlag, VacationHours, SickLeaveHours",
                    MaybeParameter("ManagerID"));
                String values = String.Format(CultureInfo.InvariantCulture,
                    "@NationalIDNumber, @ContactID, @LoginID{0}, @Title, "
                    + "@BirthDate, @MaritalStatus, @Gender, @HireDate, "
                    + "@SalariedFlag, @VacationHours, @SickLeaveHours",
                    MaybeValue("ManagerID"));

                command.CommandText =
                    String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO HumanResources.Employee ({0}) VALUES ({1}); " 
                    + "SELECT CAST(SCOPE_IDENTITY() as Int);", 
                    parameters, values);
                MaybeAddCommandParameter("NationalIDNumber", command,
                    SqlDbType.NVarChar, 15, true, string.Empty);
                MaybeAddCommandParameter("ContactID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("LoginID", command,
                    SqlDbType.NVarChar, 256, true, string.Empty);
                MaybeAddCommandParameter("ManagerID", command,
                    SqlDbType.Int, false, null);
                MaybeAddCommandParameter("JobTitle", "Title", command,
                    SqlDbType.NVarChar, 50, true, string.Empty);
                MaybeAddCommandParameter("BirthDate", command,
                    SqlDbType.DateTime, true, string.Empty);
                MaybeAddCommandParameter("MaritalStatus", command,
                    SqlDbType.NChar, 1, true, string.Empty);
                MaybeAddCommandParameter("Gender", command,
                    SqlDbType.NChar, 1, true, string.Empty);
                MaybeAddCommandParameter("HireDate", command,
                    SqlDbType.DateTime, true, string.Empty);
                MaybeAddCommandParameter("SalariedFlag", command,
                    SqlDbType.Bit, true, "1");
                MaybeAddCommandParameter("VacationHours", command,
                    SqlDbType.SmallInt, true, "0");
                MaybeAddCommandParameter("SickLeaveHours", command,
                    SqlDbType.SmallInt, true, "0");
                conn.Open();
                employeeID = (int)command.ExecuteScalar();
            }
            CreateEmployeeAdddress(employeeID,
                int.Parse(contactDictionary["AddressID"],
                System.Globalization.CultureInfo.InvariantCulture));
            CreateEmployeeDepartmentHistory(employeeID,
                int.Parse(contactDictionary["DepartmentID"],
                System.Globalization.CultureInfo.InvariantCulture),
                int.Parse(contactDictionary["ShiftID"],
                System.Globalization.CultureInfo.InvariantCulture));

        }

        public void CreateAddress()
        {
            using (SqlConnection conn 
                = new SqlConnection("context connection=true"))
            {
                SqlCommand command = conn.CreateCommand();

                ResetCounters(4);

                String parameters = String.Format(CultureInfo.InvariantCulture,
                    "AddressLine1{0}, City, StateProvinceID, PostalCode",
                    MaybeParameter("AddressLine2"));
                String values = String.Format(CultureInfo.InvariantCulture,
                "@AddressLine1{0}, @City, @StateProvinceID, @PostalCode",
                    MaybeValue("AddressLine2"));

                command.CommandText =
                    String.Format(CultureInfo.InvariantCulture,
                    "INSERT INTO Person.Address ({0}) VALUES ({1}); "
                    + "SELECT CAST(SCOPE_IDENTITY() as Int);",
                    parameters, values);
                MaybeAddCommandParameter("AddressLine1", command,
                    SqlDbType.NVarChar, 60, true, string.Empty);
                MaybeAddCommandParameter("AddressLine2", command,
                    SqlDbType.NVarChar, 60, false, null);
                MaybeAddCommandParameter("City", command,
                    SqlDbType.NVarChar, 30, true, string.Empty);
                MaybeAddCommandParameter("StateProvinceID", command,
                    SqlDbType.Int, true, string.Empty);
                MaybeAddCommandParameter("PostalCode", command,
                    SqlDbType.NVarChar, 15, true, string.Empty);
                conn.Open();
                contactDictionary["AddressID"] = command.ExecuteScalar().ToString();
            }
        }

        public static void CreateEmployeeAdddress(int employeeId, int addressId)
        {
            using (SqlConnection conn 
                = new SqlConnection("context connection=true"))
            {
                SqlCommand cmd = conn.CreateCommand();
                cmd.CommandText = "INSERT INTO HumanResources.EmployeeAddress " 
                    + "(EmployeeID, AddressID) VALUES (@EmployeeID, @AddressID)";
                cmd.Parameters.AddWithValue("@EmployeeID", employeeId);
                cmd.Parameters.AddWithValue("@AddressID", addressId);
                conn.Open();
                cmd.ExecuteNonQuery();
            }
        }

        public static void CreateEmployeeDepartmentHistory(int employeeId, int departmentId, int shiftId)
        {
            using (SqlConnection conn 
                = new SqlConnection("context connection=true"))
            {
                SqlCommand cmd = conn.CreateCommand();
                cmd.CommandText = "INSERT INTO HumanResources.EmployeeDepartmentHistory " 
                    + "(EmployeeID, DepartmentID, ShiftID, StartDate) VALUES " 
                    + "(@EmployeeID, @DepartmentID, @ShiftID, @StartDate)";
                cmd.Parameters.AddWithValue("@EmployeeID", employeeId);
                cmd.Parameters.AddWithValue("@DepartmentID", departmentId);
                cmd.Parameters.AddWithValue("@ShiftID", shiftId);
                cmd.Parameters.AddWithValue("@StartDate", DateTime.Now);
                conn.Open();
                cmd.ExecuteNonQuery();
            }
        }
    }

    /// <summary>
    ///Used to indicate when parsing the xml document for creating a contact is 
    ///not in the proper form.
    /// </summary>
    [Serializable]
    public class AWUtilitiesContactParseException : Exception
    {
        private String expected = "Unknown";

        private String actual = "Unknown";

        public String Expected
        {
            get
            {
                return expected;
            }
            set
            {
                expected = value;
            }
        }

        public String Actual
        {
            get
            {
                return actual;
            }
            set
            {
                actual = value;
            }
        }

        public AWUtilitiesContactParseException()
        {
        }

        public AWUtilitiesContactParseException(String message)
            : base(message)
        {
        }

        public AWUtilitiesContactParseException(string message, Exception innerException)
            : base(message, innerException)
        {
        }

        protected AWUtilitiesContactParseException(SerializationInfo info, StreamingContext context)
            : base(info, context)
        {
        }

        public AWUtilitiesContactParseException(String expected, String actual)
        {
            this.Expected = expected;
            this.Actual = actual;
        }

        public override String ToString()
        {
            return String.Format(CultureInfo.CurrentUICulture,
                "Parsing error during contact creation, expected element {0}, found element {1}.",
                this.Expected, this.Actual);
        }

        [System.Security.Permissions.SecurityPermission(System.Security.Permissions.SecurityAction.Demand, SerializationFormatter = true)]
        public override void GetObjectData(SerializationInfo info, StreamingContext context)
        {
            // Use the method of the base class.
            base.GetObjectData(info, context);
        }
    }

VB.NET

      Imports System
Imports System.Data
Imports System.Data.Sql
Imports System.Data.SqlClient
Imports System.Data.SqlTypes
Imports System.IO
Imports System.Xml
Imports System.Collections
Imports System.Collections.Generic
Imports System.Globalization
Imports Microsoft.SqlServer.Server
Imports Microsoft.VisualBasic
Imports System.Diagnostics

Public NotInheritable Class ContactUtils
    Private Sub New()
    End Sub
   
    <Microsoft.SqlServer.Server.SqlProcedure()> _
    Public Shared Sub CreateContact(ByVal contactData As SqlString, ByRef contactId As SqlInt32, ByRef customerId As SqlInt32)
        ' TODO: When we can pass XML from T-SQL then contactData can be a SqlXmlReader
        Using sr As New StringReader(contactData.Value)
            Dim reader As XmlReader = XmlReader.Create(sr)

            reader.MoveToContent()
            EnsureEqual(reader.LocalName, "Contact")
            reader.MoveToContent()
            reader.ReadStartElement()

            Dim creator As ContactCreator = Nothing

            Select Case reader.LocalName
                Case "Individual"
                    creator = New IndividualCreator()

                Case "Store"
                    creator = New StoreCreator()

                Case "Vendor"
                    creator = New VendorCreator()

                Case "Employee"
                    creator = New EmployeeCreator()

                Case Else
            End Select

            If (creator IsNot Nothing) Then
                reader.ReadStartElement()
                reader.MoveToContent()
                creator.LoadDictionary(reader)
                reader.Close()
                creator.Create()
                contactId = creator.ContactID
                customerId = creator.CustomerID
            Else
                contactId = -1
                customerId = -1

                Throw New AWUtilsContactParseException("Individual | Store | Vendor | Employee", reader.LocalName)
            End If
        End Using
    End Sub

    Public Shared Sub EnsureEqual(ByVal localName As String, ByVal desiredLocalName As String)
        If localName Is Nothing Then
            Throw New ArgumentNullException("localName")
        End If
        If Not localName.Equals(desiredLocalName) Then
            Throw New AWUtilsContactParseException(desiredLocalName, localName)
        End If
    End Sub
End Class
<Serializable()> _
Public Class AWUtilsContactParseException
    Inherits ApplicationException
    Private _expected As String = "unknown"

    Private _actual As String = "unknown"

    Public Property Expected() As String
        Get
            Return _expected
        End Get
        Set(ByVal Value As String)
            _expected = Value
        End Set
    End Property

    Public Property Actual() As String
        Get
            Return _actual
        End Get
        Set(ByVal Value As String)
            _actual = Value
        End Set
    End Property

    Public Sub New()
    End Sub

    Public Sub New(ByVal expected As String, ByVal actual As String)
        Me.Expected = expected
        Me.Actual = actual
    End Sub

    Public Overrides Function ToString() As String
        Return String.Format(System.Globalization.CultureInfo.InvariantCulture, _
            "Parsing error during contact creation, expected element {0}, found element {1}.", _
            Me.Expected, Me.Actual)
    End Function
End Class
Public MustInherit Class CustomerCreator
    Inherits ContactCreator

    Protected Sub New()
    End Sub

    Public Overrides Sub Create()
        MyBase.Create()
        Using conn As New SqlConnection("context connection=true")
            Dim command As SqlCommand = conn.CreateCommand()

            If Not contactDictionary.ContainsKey("CustomerType") Then
                contactDictionary("CustomerType") = "I"
            End If

            ResetCounters(0)

            Dim parameters As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "{0}{1}{2}", _
                MaybeParameter("SalesPersonID"), _
                MaybeParameter("TerritoryID"), _
                MaybeParameter("CustomerType"))
            ' CustomerType is always present, but we need to get the commas right
            Dim values As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "{0}{1}{2}", _
                MaybeValue("SalesPersonID"), _
                MaybeValue("TerritoryID"), _
                MaybeValue("CustomerType"))

            command.CommandText = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "INSERT INTO Sales.Customer ({0}) VALUES ({1}); SELECT CAST(SCOPE_IDENTITY() as Int);", _
                parameters, values)
            MaybeAddCommandParameter("SalesPersonID", command, SqlDbType.Int, False, Nothing)
            MaybeAddCommandParameter("TerritoryID", command, SqlDbType.Int, False, Nothing)
            MaybeAddCommandParameter("CustomerType", command, SqlDbType.NChar, 1, True, "I")
            conn.Open()
            Me.CustomerID = CType(command.ExecuteScalar(), Integer)
        End Using
    End Sub
End Class
Public MustInherit Class ContactCreator
    Protected parameterCount As Integer

    Protected valueCount As Integer

    Protected contactDictionary As New Dictionary(Of String, String)()

    Private Shared ReadOnly xmlColumns() As String = {"AdditionalContactInfo", "Demographics"}
    Private Shared ReadOnly nestedColumns() As String = {"Address"}

    Protected Sub New()
    End Sub


    Public Property ContactID() As Integer
        Get
            Dim val As String = String.Empty

            If contactDictionary.TryGetValue("ContactID", val) Then
                Return Integer.Parse(val, CultureInfo.InvariantCulture)
            Else
                Return -1
            End If
        End Get
        Set(ByVal Value As Integer)
            contactDictionary("ContactID") = Value.ToString(CultureInfo.InvariantCulture)
        End Set
    End Property


    Public Property CustomerID() As Integer
        Get
            Dim val As String = String.Empty

            If contactDictionary.TryGetValue("CustomerID", val) Then
                Return Integer.Parse(val, CultureInfo.InvariantCulture)
            Else
                ' Not every contact is for a customer.  Return -1 in that case.
                Return -1
            End If
        End Get
        Set(ByVal Value As Integer)
            contactDictionary("CustomerID") _
                = Value.ToString(CultureInfo.InvariantCulture)
        End Set
    End Property

    Public Sub LoadDictionary(ByVal reader As XmlReader)
        While reader.IsStartElement()
            Dim key As String = reader.LocalName
            Dim val As String

            If Array.IndexOf(xmlColumns, key) > -1 Then
                val = reader.ReadInnerXml()
            ElseIf Array.IndexOf(nestedColumns, key) > -1 Then
                reader.ReadStartElement()
                LoadDictionary(reader)
                reader.ReadEndElement()
                GoTo ContinueWhile1
            Else
                val = reader.ReadElementString()
            End If

            contactDictionary.Add(key, val)

ContinueWhile1:
        End While
    End Sub

    Protected Sub ResetCounters(ByVal valueForReset As Integer)
        parameterCount = valueForReset
        valueCount = valueForReset
    End Sub

    Public Function MaybeParameter(ByVal name As String) As String
        If contactDictionary.ContainsKey(name) Then
            parameterCount = parameterCount + 1
            If parameterCount = 1 Then
                Return name
            Else
                Return ", " & name
            End If
        Else
            Return String.Empty
        End If
    End Function

    Public Function MaybeValue(ByVal name As String) As String
        If contactDictionary.ContainsKey(name) Then
            valueCount = valueCount + 1
            If valueCount = 1 Then
                Return "@" & name
            Else
                Return ", @" & name
            End If
        Else
            Return String.Empty
        End If
    End Function

    Public Shared Function TypeConvert(ByVal valueToConvert As String, ByVal parameterType As SqlDbType) As Object
        If valueToConvert Is Nothing Then
            Throw New ArgumentNullException("valueToConvert")
        End If
        Select Case parameterType
            Case SqlDbType.BigInt
                Return Int64.Parse(valueToConvert, CultureInfo.InvariantCulture)

            Case SqlDbType.Int
                Return Integer.Parse(valueToConvert, CultureInfo.InvariantCulture)

            Case SqlDbType.SmallInt
                Return Int16.Parse(valueToConvert, CultureInfo.InvariantCulture)

            Case SqlDbType.TinyInt
                Return Byte.Parse(valueToConvert, CultureInfo.InvariantCulture)

            Case SqlDbType.Bit
                If valueToConvert.Equals("1") OrElse valueToConvert.Equals("true") Then
                    Return 1
                Else
                    Return 0
                End If

            Case SqlDbType.NVarChar, SqlDbType.VarChar, SqlDbType.NChar, SqlDbType.NText, SqlDbType.Text, SqlDbType.Char, SqlDbType.Xml
                Return valueToConvert

            Case SqlDbType.DateTime
                Return DateTime.Parse(valueToConvert, CultureInfo.InvariantCulture)

            Case SqlDbType.Money
                Return Decimal.Parse(valueToConvert, CultureInfo.InvariantCulture)

            Case Else
                Return "unknown conversion"
        End Select
    End Function

    Public Overloads Sub MaybeAddCommandParameter(ByVal keyName As String, ByVal paramName As String, ByVal command As SqlCommand, ByVal parameterType As SqlDbType, ByVal isRequired As Boolean, ByVal defaultValue As String)
        If isRequired OrElse contactDictionary.ContainsKey(keyName) Then
            Dim param As New SqlParameter("@" & paramName, parameterType)
            Dim val As String

            If (contactDictionary.ContainsKey(keyName)) Then
                val = contactDictionary(keyName)
            Else
                val = defaultValue
            End If

            param.Value = TypeConvert(val, parameterType)
            command.Parameters.Add(param)
        End If
    End Sub

    Public Overloads Sub MaybeAddCommandParameter(ByVal name As String, ByVal command As SqlCommand, ByVal parameterType As SqlDbType, ByVal isRequired As Boolean, ByVal defaultValue As String)
        MaybeAddCommandParameter(name, name, command, parameterType, isRequired, defaultValue)
    End Sub

    Public Overloads Sub MaybeAddCommandParameter(ByVal name As String, ByVal command As SqlCommand, ByVal parameterType As SqlDbType, ByVal size As Integer, ByVal isRequired As Boolean, ByVal defaultValue As String)
        If isRequired OrElse contactDictionary.ContainsKey(name) Then
            MaybeAddCommandParameter(name, command, parameterType, isRequired, defaultValue)
            command.Parameters(command.Parameters.Count - 1).Size = size
        End If
    End Sub

    Public Overloads Sub MaybeAddCommandParameter(ByVal keyName As String, ByVal paramName As String, ByVal command As SqlCommand, ByVal parameterType As SqlDbType, ByVal size As Integer, ByVal isRequired As Boolean, ByVal defaultValue As String)
        If isRequired OrElse contactDictionary.ContainsKey(keyName) Then
            MaybeAddCommandParameter(keyName, paramName, command, parameterType, isRequired, defaultValue)
            command.Parameters(command.Parameters.Count - 1).Size = size
        End If
    End Sub


    Public Overridable Sub Create()
        Using conn As New SqlConnection("context connection=true")

            Dim command As SqlCommand = conn.CreateCommand()

            ResetCounters(1)

            Dim parameters As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "NameStyle{0}, FirstName{1}, LastName{2}{3}{4}{5}, PasswordHash, PasswordSalt{6}", _
                MaybeParameter("Title"), MaybeParameter("MiddleName"), _
                MaybeParameter("Suffix"), MaybeParameter("EmailAddress"), _
                MaybeParameter("EmailPromotion"), MaybeParameter("Phone"), _
                MaybeParameter("AdditionalContactInfo"))
            Dim values As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "@NameStyle{0}, @FirstName{1}, @LastName{2}{3}{4}{5}, @PasswordHash, @PasswordSalt{6}", _
                MaybeValue("Title"), MaybeValue("MiddleName"), MaybeValue("Suffix"), _
                MaybeValue("EmailAddress"), MaybeValue("EmailPromotion"), _
                MaybeValue("Phone"), MaybeValue("AdditionalContactInfo"))

            Dim formatText As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "INSERT INTO Person.Contact ({0}) VALUES ({1}); SELECT CAST(SCOPE_IDENTITY() AS Int);", _
                parameters, values)

            command.CommandText = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                formatText)
            MaybeAddCommandParameter("NameStyle", command, SqlDbType.Bit, True, "0")
            MaybeAddCommandParameter("Title", command, SqlDbType.NVarChar, 8, False, Nothing)
            MaybeAddCommandParameter("FirstName", command, SqlDbType.NVarChar, 50, True, String.Empty)
            MaybeAddCommandParameter("MiddleName", command, SqlDbType.NVarChar, 50, False, Nothing)
            MaybeAddCommandParameter("LastName", command, SqlDbType.NVarChar, 50, True, String.Empty)
            MaybeAddCommandParameter("Suffix", command, SqlDbType.NVarChar, 10, False, Nothing)
            MaybeAddCommandParameter("EmailAddress", command, SqlDbType.NVarChar, 50, True, String.Empty)
            MaybeAddCommandParameter("EmailPromotion", command, SqlDbType.Int, False, Nothing)
            MaybeAddCommandParameter("Phone", command, SqlDbType.NVarChar, 25, False, Nothing)
            MaybeAddCommandParameter("PasswordHash", command, SqlDbType.VarChar, 40, True, String.Empty)
            MaybeAddCommandParameter("PasswordSalt", command, SqlDbType.VarChar, 10, True, String.Empty)
            MaybeAddCommandParameter("AdditionalContactInfo", command, SqlDbType.Xml, False, Nothing)
            conn.Open()
            Me.ContactID = CType(command.ExecuteScalar(), Integer)
            Dim st As New StackTrace(True)
        End Using
    End Sub
End Class
Public Class EmployeeCreator
    Inherits ContactCreator

    Public Overrides Sub Create()
        MyBase.Create()
        CreateAddress()
        Dim employeeID As Integer = -1
        Using conn As New SqlConnection("context connection=true")

            Dim command As SqlCommand = conn.CreateCommand()

            ResetCounters(3)
            Dim parameters As String = String.Format(CultureInfo.InvariantCulture, _
                "NationalIDNumber, ContactID, LoginID{0}, Title, BirthDate, MaritalStatus, Gender, HireDate, SalariedFlag, VacationHours, SickLeaveHours", _
                MaybeParameter("ManagerID"))
            Dim values As String = String.Format(CultureInfo.InvariantCulture, _
                "@NationalIDNumber, @ContactID, @LoginID{0}, @Title, @BirthDate, @MaritalStatus, @Gender, @HireDate, @SalariedFlag, @VacationHours, @SickLeaveHours", _
                MaybeValue("ManagerID"))

            command.CommandText = String.Format(CultureInfo.InvariantCulture, _
                "INSERT INTO HumanResources.Employee ({0}) VALUES ({1}); SELECT CAST(SCOPE_IDENTITY() as Int);", _
                parameters, values)
            MaybeAddCommandParameter("NationalIDNumber", command, SqlDbType.NVarChar, 15, True, String.Empty)
            MaybeAddCommandParameter("ContactID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("LoginID", command, SqlDbType.NVarChar, 256, True, String.Empty)
            MaybeAddCommandParameter("ManagerID", command, SqlDbType.Int, False, Nothing)
            MaybeAddCommandParameter("JobTitle", "Title", command, SqlDbType.NVarChar, 50, True, String.Empty)
            MaybeAddCommandParameter("BirthDate", command, SqlDbType.DateTime, True, String.Empty)
            MaybeAddCommandParameter("MaritalStatus", command, SqlDbType.NChar, 1, True, String.Empty)
            MaybeAddCommandParameter("Gender", command, SqlDbType.NChar, 1, True, String.Empty)
            MaybeAddCommandParameter("HireDate", command, SqlDbType.DateTime, True, String.Empty)
            MaybeAddCommandParameter("SalariedFlag", command, SqlDbType.Bit, True, "1")
            MaybeAddCommandParameter("VacationHours", command, SqlDbType.SmallInt, True, "0")
            MaybeAddCommandParameter("SickLeaveHours", command, SqlDbType.SmallInt, True, "0")
            conn.Open()

            employeeID = CInt(command.ExecuteScalar())
        End Using

        CreateEmployeeAdddress(employeeID, Integer.Parse(contactDictionary("AddressID"), _
            System.Globalization.CultureInfo.InvariantCulture))
        CreateEmployeeDepartmentHistory(employeeID, Integer.Parse( _
            contactDictionary("DepartmentID"), _
            System.Globalization.CultureInfo.InvariantCulture), _
            Integer.Parse(contactDictionary("ShiftID"), _
            System.Globalization.CultureInfo.InvariantCulture))
    End Sub

    Public Sub CreateAddress()
        Using conn As New SqlConnection("context connection=true")
            Dim command As SqlCommand = conn.CreateCommand()

            ResetCounters(4)

            Dim parameters As String = String.Format(CultureInfo.InvariantCulture, _
                "AddressLine1{0}, City, StateProvinceID, PostalCode", _
                MaybeParameter("AddressLine2"))
            Dim values As String = String.Format(CultureInfo.InvariantCulture, _
                "@AddressLine1{0}, @City, @StateProvinceID, @PostalCode", _
                MaybeValue("AddressLine2"))

            command.CommandText = String.Format(CultureInfo.InvariantCulture, _
                "INSERT INTO Person.Address ({0}) VALUES ({1}); SELECT CAST(SCOPE_IDENTITY() as Int);", _
                parameters, values)
            MaybeAddCommandParameter("AddressLine1", command, SqlDbType.NVarChar, 60, True, String.Empty)
            MaybeAddCommandParameter("AddressLine2", command, SqlDbType.NVarChar, 60, False, Nothing)
            MaybeAddCommandParameter("City", command, SqlDbType.NVarChar, 30, True, String.Empty)
            MaybeAddCommandParameter("StateProvinceID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("PostalCode", command, SqlDbType.NVarChar, 15, True, String.Empty)
            conn.Open()

            contactDictionary("AddressID") = command.ExecuteScalar().ToString()
        End Using
    End Sub

   
    Public Shared Sub CreateEmployeeAdddress(ByVal employeeID As Integer, ByVal addressID As Integer)
        Using conn As New SqlConnection("context connection=true")

            Dim cmd As SqlCommand = conn.CreateCommand()
            cmd.CommandText = "INSERT INTO HumanResources.EmployeeAddress " + "(EmployeeID, AddressID) VALUES (@EmployeeID, @AddressID)"
            cmd.Parameters.AddWithValue("@EmployeeID", employeeID)
            cmd.Parameters.AddWithValue("@AddressID", addressID)
            conn.Open()
            cmd.ExecuteNonQuery()
        End Using
    End Sub

  
    Public Shared Sub CreateEmployeeDepartmentHistory(ByVal employeeID As Integer, ByVal departmentID As Integer, ByVal shiftID As Integer)
        Using conn As New SqlConnection("context connection=true")

            Dim cmd As SqlCommand = conn.CreateCommand()
            cmd.CommandText = "INSERT INTO HumanResources.EmployeeDepartmentHistory " + "(EmployeeID, DepartmentID, ShiftID, StartDate) VALUES " + "(@EmployeeID, @DepartmentID, @ShiftID, @StartDate)"
            cmd.Parameters.AddWithValue("@EmployeeID", employeeID)
            cmd.Parameters.AddWithValue("@DepartmentID", departmentID)
            cmd.Parameters.AddWithValue("@ShiftID", shiftID)
            cmd.Parameters.AddWithValue("@StartDate", DateTime.Now)
            conn.Open()
            cmd.ExecuteNonQuery()
        End Using
    End Sub
End Class
Public Class IndividualCreator
    Inherits CustomerCreator

    Public Overrides Sub Create()
        MyBase.Create()
        Using conn As New SqlConnection("context connection=true")
            Dim command As SqlCommand = conn.CreateCommand()

            ResetCounters(2)
            Dim parameters As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "CustomerID, ContactID{0}", MaybeParameter("Demographics"))
            Dim values As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "@CustomerID, @ContactID{0}", MaybeValue("Demographics"))
            command.CommandText = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "INSERT INTO Sales.Individual ({0}) VALUES ({1});", parameters, values)
            MaybeAddCommandParameter("CustomerID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("ContactID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("Demographics", command, SqlDbType.Xml, False, Nothing)
            conn.Open()
            command.ExecuteNonQuery()
        End Using
    End Sub
End Class
Public Class StoreCreator
    Inherits ContactCreator

    Public Overrides Sub Create()
        MyBase.Create()
        Using conn As New SqlConnection("context connection=true")

            Dim command As SqlCommand = conn.CreateCommand()

            command.CommandText = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "INSERT INTO Sales.StoreContact (CustomerID, ContactID, ContactTypeID) VALUES (@CustomerID, @ContactID, @ContactTypeID);")
            MaybeAddCommandParameter("CustomerID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("ContactID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("ContactTypeID", command, SqlDbType.TinyInt, True, String.Empty)
            conn.Open()
            command.ExecuteNonQuery()
        End Using
    End Sub
End Class
Public Class VendorCreator
    Inherits ContactCreator

    Public Overrides Sub Create()
        MyBase.Create()
        Using conn As New SqlConnection("context connection=true")

            Dim command As SqlCommand = conn.CreateCommand()

            Dim parameters As String = "VendorID, ContactID, ContactTypeID"
            Dim values As String = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "@VendorID, @ContactID, @ContactTypeID")

            command.CommandText = String.Format( _
                System.Globalization.CultureInfo.InvariantCulture, _
                "INSERT INTO Purchasing.VendorContact ({0}) VALUES ({1});", _
                parameters, values)
            MaybeAddCommandParameter("VendorID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("ContactID", command, SqlDbType.Int, True, String.Empty)
            MaybeAddCommandParameter("ContactTypeID", command, SqlDbType.TinyInt, True, String.Empty)
            conn.Open()
            command.ExecuteNonQuery()
        End Using
    End Sub

End Class

这是 Transact-SQL 安装脚本 (Install.sql)，该脚本在数据库中部署程序集并创建存储过程。

use AdventureWorks
GO

DECLARE @contactID Int;
DECLARE @customerID Int;

EXEC dbo.usp_CreateContact N'<Contact xmlns="https://schemas.microsoft.com/sqlserver/2004/07/adventure-works/ContactData"><Individual>
<Title>Dr.</Title>
<FirstName>Kim</FirstName>
<LastName>Smith</LastName>
<EmailAddress>kim@proseware.com</EmailAddress>
<PasswordHash>F1AF7A6028F2FEA29292C09603F1C209BB84B518</PasswordHash>
<PasswordSalt>2Hdr7Jc=</PasswordSalt>
<Demographics>
<IndividualSurvey xmlns="https://schemas.microsoft.com/sqlserver/2004/07/adventure-works/IndividualSurvey">
<TotalChildren>2</TotalChildren>
<NumberChildrenAtHome>1</NumberChildrenAtHome>
</IndividualSurvey>
</Demographics>
</Individual>
</Contact>', @contactID OUTPUT, @customerID OUTPUT;

PRINT 'Individual Contact ID = ' + CAST(@contactID as varchar(10));
PRINT 'Individual Customer ID = ' + CAST(@customerID as varchar(10));

EXEC dbo.usp_CreateContact N'
<Contact xmlns="https://schemas.microsoft.com/sqlserver/2004/07/adventure-works/ContactData"><Store>
<FirstName>Catherine</FirstName>
<LastName>Smith</LastName>
<EmailAddress>catherine@proseware.com</EmailAddress>
<PasswordHash>D584F3AC519BA083DD814023495F267E6A613F7C</PasswordHash>
<PasswordSalt>bseDC8g=</PasswordSalt>
<CustomerID>391</CustomerID>
<ContactTypeID>14</ContactTypeID>
</Store>
</Contact>', @contactID OUTPUT, @customerID OUTPUT;

PRINT 'Store Contact ID = ' + CAST(@contactID as varchar(10));
PRINT 'Store Customer ID = ' + CAST(@customerID as varchar(10));

EXEC dbo.usp_CreateContact N'
<Contact xmlns="https://schemas.microsoft.com/sqlserver/2004/07/adventure-works/ContactData"><Vendor>
<FirstName>Amy</FirstName>
<LastName>Smith</LastName>
<EmailAddress>amy@proseware.com</EmailAddress>
<PasswordHash>00753C6EEC3659B4A5C30AC048F258C610EBE248</PasswordHash>
<PasswordSalt>wyUl4hA=</PasswordSalt>
<VendorID>7</VendorID>
<ContactTypeID>17</ContactTypeID>
</Vendor>
</Contact>', @contactID OUTPUT, @customerID OUTPUT;

PRINT 'Vendor Contact ID = ' + CAST(@contactID as varchar(10));
PRINT 'Vendor Customer ID = ' + CAST(@customerID as varchar(10));

EXEC dbo.usp_CreateContact N'
<Contact xmlns="https://schemas.microsoft.com/sqlserver/2004/07/adventure-works/ContactData"><Employee>
<FirstName>Ramona</FirstName>
<LastName>Smith</LastName>
<EmailAddress>ramona@proseware.com</EmailAddress>
<PasswordHash>4BE320740C7461F79A3CE3E177EA03A9FE3DDD26</PasswordHash>
<PasswordSalt>Pfz9Qzg=</PasswordSalt>
<NationalIDNumber>739117</NationalIDNumber>
<LoginID>ramonas</LoginID>
<DepartmentID>11</DepartmentID>
<ManagerID>42</ManagerID>
<ShiftID>1</ShiftID>
<JobTitle>Information System Specialist</JobTitle>
<Address>
<AddressLine1>3 Penny Lane</AddressLine1>
<AddressLine2>Apartment 2A</AddressLine2>
<City>Seattle</City>
<StateProvinceID>79</StateProvinceID>
<PostalCode>98121</PostalCode>
</Address>
<BirthDate>1972-04-01T03:29:17-08:00</BirthDate>
<MaritalStatus>M</MaritalStatus>
<Gender>F</Gender>
<HireDate>1999-08-07T13:35:17-08:00</HireDate>
<SalariedFlag>true</SalariedFlag>
<VacationHours>12</VacationHours>
<SickLeaveHours>8</SickLeaveHours>
</Employee>
</Contact>', @contactID OUTPUT, @customerID OUTPUT;

PRINT 'Employee Contact ID = ' + CAST(@contactID as varchar(10));

PRINT 'Employee Customer ID = ' + CAST(@customerID as varchar(10));

下面的 Transact-SQL 从数据库中删除程序集、存储过程和插入的数据。

USE AdventureWorks
GO
--Individual
DECLARE @ContactID int;
DECLARE @customerID int;
SELECT  @ContactID = co.ContactID, @customerID = c.CustomerID 
FROM Sales.Customer AS c 
JOIN Sales.Individual AS i on c.CustomerID = i.CustomerID 
JOIN Person.Contact AS co on i.ContactID = co.ContactID 
WHERE co.EmailAddress='kim@proseware.com';
DELETE Sales.Individual WHERE ContactID = @ContactID;
DELETE Sales.Customer WHERE CustomerID = @customerID;
DELETE Person.Contact WHERE ContactID = @ContactID;
GO

-- Store Contact

DECLARE @ContactID int;
SELECT  @ContactID = co.ContactID 
FROM Person.Contact AS co 
WHERE co.EmailAddress='catherine@proseware.com';
DELETE Sales.StoreContact WHERE ContactID = @ContactID;
DELETE Person.Contact WHERE ContactID = @ContactID;
GO

-- Vendor Contact

DECLARE @ContactID int;
SELECT  @ContactID = co.ContactID FROM  Person.Contact AS co 
WHERE co.EmailAddress='amy@proseware.com';
DELETE Purchasing.VendorContact WHERE ContactID = @ContactID;
DELETE Person.Contact WHERE ContactID = @ContactID;
GO

-- Employee Contact

DECLARE @ContactID int;
DECLARE @EmployeeID int;
DECLARE @AddressID int;
SELECT  @ContactID = co.ContactID 
FROM  Person.Contact AS co 
WHERE co.EmailAddress='ramona@proseware.com';
SELECT @EmployeeID = e.EmployeeID
FROM HumanResources.Employee AS e
WHERE ContactID = @ContactID; 
SELECT @AddressID = ea.AddressID
FROM HumanResources.EmployeeAddress AS ea
WHERE EmployeeID = @EmployeeID;
DELETE HumanResources.EmployeeAddress 
WHERE EmployeeID = @EmployeeID AND AddressID = @AddressID;
DELETE Person.Address
WHERE AddressID = @AddressID;
DELETE HumanResources.EmployeeDepartmentHistory
WHERE EmployeeID = @EmployeeID;
DISABLE TRIGGER [HumanResources].[dEmployee] ON [HumanResources].[Employee];
DELETE HumanResources.Employee WHERE ContactID = @ContactID;
ENABLE TRIGGER [HumanResources].[dEmployee] ON [HumanResources].[Employee];
DELETE Person.Contact WHERE ContactID = @ContactID;
GO

IF EXISTS (SELECT * FROM sys.xml_schema_collections WHERE [name] = N'ContactDataSchemaCollection')
DROP XML SCHEMA COLLECTION Person.ContactDataSchemaCollection;
GO

IF EXISTS (SELECT * FROM sys.procedures WHERE [name] = N'usp_CreateContact')

DROP PROCEDURE [dbo].[usp_CreateContact];
GO

IF EXISTS (SELECT * FROM sys.assemblies WHERE [name] = N'Contacts') 
DROP ASSEMBLY Contacts;
GO

请参阅

概念

公共语言运行时 (CLR) 集成的使用方案和示例

通过

使用 CLR 和 XML 创建联系信息

先决条件

启用 CLR 集成

生成示例

按照以下说明创建和运行该示例：

示例代码

请参阅

概念

其他资源