带有 CLR UDT 的 SQLBulkCopy 给出“在程序集 'MyType' 中找不到类型 'MyNamespace.MyType' 的方法 'Read'”

Question

我在 SQL Server 2012 中编写了一个 SQL Server CLR 用户定义类型 (UDT)。我已经能够通过 SQL 测试脚本访问它，并将它用作局部变量，在表中定义它，并且通过 Visual Studio 和 SQL Server Management Studio 对其进行了测试。

我们有一个服务，它以一种相当通用的方式使用 SQLBulkCopy 来拾取放置在目录中的文件，然后将它们的内容插入到适当的表中。当我将我的 UDT 作为其中一个表中的列添加时，我收到来自 WriteToServer( DataTable ) 调用的错误。

UDT 列作为 System.String 传递，希望在 SQL Server 中调用 UDT 的 Parse() 方法以将其转换为内部类型。我还尝试在此客户端程序中声明 UDT 类，并将数据直接作为 UDT 类型传递。

在任何一种情况下，我都会收到此错误消息（经过编辑以删除我的专有名称）

在程序集“MyType”中找不到类型“MyNamespace.MyType”的方法“Read”

我已经查看了尽可能多的关于此错误消息的类似问题，它们通常指的是 CREATE 语句的格式。此外，它们通常指的是 CLR 函数，而不是 CLR 类型，它们略有不同。这是我的：

创建类型 [dbo].[MyType]
外部名称 [MyType].[MyNamespace.MyType]

我怀疑这可能不是问题，而是与 SQLBulkCopy 如何与 SQLCLR UDT 交互有关。对于这种特殊的组合，很难找到任何深入的解释。

编辑 #1 - 这是自定义序列化。

[Serializable]  
[Microsoft.SqlServer.Server.SqlUserDefinedType( Format.UserDefined, MaxByteSize = -1 )]  
public struct MyType: INullable, IBinarySerialize  

编辑 #2 - 授予执行权限

GRANT EXECUTE 
ON TYPE :: MyType
TO PUBLIC 

编辑 #3 - 调整测试代码

CREATE TABLE [dbo].[TestMyType]
(
    [SourceMachine]       [varchar](32)  NULL,
    [Output]              MyType NULL
)

更新者

try
{
    DataTable dataTable = new DataTable( "[TestMyType]" );
    dataTable.Columns.Add( "SourceMachine", typeof( System.String ) );
    dataTable.Columns.Add( "Output", typeof( MyNamespace.MyType ) );

    dataTable.Rows.Add( "Ron1", MyNamespace.MyType.Parse( "This is string 1" ) );
    dataTable.Rows.Add( "Ron2", MyNamespace.MyType.Parse( "This is string 2" ) );
    dataTable.Rows.Add( "Ron3", MyNamespace.MyType.Parse( "This is string 3" ) );

    SqlBulkCopy sqlBulkCopy = new SqlBulkCopy( conn );
    sqlBulkCopy.DestinationTableName = "[TestMyType]";
    sqlBulkCopy.WriteToServer( dataTable );
}
catch ( Exception ex)
{
    System.Diagnostics.Debug.WriteLine(ex.Message);                            
    throw;
}

这给出了与上面显示的相同的错误消息。

编辑 #4 - 从问题中消除 SqlBulkCopy
我使用参数化的 INSERT 重新创建了该问题。我将它设置为将 UDT 对象从客户端传递到服务器作为直接使用 UDT 实例的参数。

string sInsert = "INSERT INTO TestMyType VALUES (?, ?)";
SqlCommand command = new SqlCommand(sInsert, conn);
SqlParameter parm1 = new SqlParameter("SourceMachine", "This is Machine 01");
SqlParameter parm2 = new SqlParameter("Output", MyNamespace.MyType.Parse( "This is INSERT 01" ) );
parm2.UdtTypeName = "MyType";
command.Parameters.Add(parm1);
command.Parameters.Add(parm2);
int nResult = command.ExecuteNonQuery();

给予

A first chance exception of type 'System.Data.SqlClient.SqlException'
    occurred in System.Data.dll
Additional information: Could not find method 'Read' for 
    type 'MyNamespace.MyType' in assembly 'MyType'

Answer 1

SqlBulkCopy 应该能够很好地处理 SQLCLR UDT（用户定义类型）。我已经成功使用了DbDataReader 和DataTable 方法。

这对我有用：

C# 代码（我将“客户端”设为 SQLCLR 存储过程）

using System;
using System.Data.SqlTypes;
using System.Data.SqlClient;
using Microsoft.SqlServer.Server;

public class xtra
{

    [SqlProcedure]
    public static void BcpTest(SqlInt32 TheID, SqlString TheConnectionString)
    {
        System.Data.DataTable _DataTable = new System.Data.DataTable();
        _DataTable.Columns.Add("ID", typeof(Int32));
        _DataTable.Columns.Add("SomeDate", typeof(DateTime));
        _DataTable.Columns.Add("SomeData", typeof(Type_HashTable));

        Type_HashTable _Bob = Type_HashTable.Parse(@"testKey=testVal");
        _DataTable.Rows.Add(TheID.Value, DateTime.Now, _Bob);

        _DataTable.Rows.Add(TheID.Value + 1, DateTime.Now,
           Type_HashTable.Parse(@"testKey2=testVal2"));

        SqlBulkCopy _BulkCopy = new SqlBulkCopy(TheConnectionString.Value);
        _BulkCopy.DestinationTableName = "dbo.BulkCopyUDT";

        try
        {
            _BulkCopy.WriteToServer(_DataTable);
        }
        finally
        {
            _BulkCopy.Close();
        }
    }
}

T-SQL 代码

-- DROP TABLE dbo.BulkCopyUDT;
CREATE TABLE dbo.BulkCopyUDT
(
  ID INT NOT NULL CONSTRAINT [PK_BulkCopyUDT] PRIMARY KEY,
  SomeDate DATETIME,
  SomeData [SQL#].[Type_HashTable]
);
GO

GRANT INSERT, SELECT ON dbo.BulkCopyUDT TO [Public];
GRANT EXECUTE ON TYPE::SQL#.Type_HashTable TO [Public];
GO

CREATE PROCEDURE dbo.SqlBulkCopy_Test
(
    @TheID INT,
    @TheConnectionString NVARCHAR(4000) = 
        N'Data Source=(local); Integrated Security=true; Initial Catalog=my_database;'
)
AS EXTERNAL NAME [my_assembly].[xtra].[BcpTest];
GO

ALTER ASSEMBLY [my_assembly] WITH PERMISSION_SET = EXTERNAL_ACCESS;
GO

测试

EXEC dbo.SqlBulkCopy_Test 1;

SELECT *, SomeData.ToString() FROM dbo.BulkCopyUDT;

EXEC dbo.SqlBulkCopy_Test 3,
       N'Data Source=(local); User=test; Password=test; Initial Catalog=my_database;';

SELECT *, SomeData.ToString() FROM dbo.BulkCopyUDT;

---

我还通过控制台应用程序使用SqlBulkCopy 和参数化的临时查询来完成这项工作：

using System;
using System.Data;
using System.Data.SqlClient;

namespace SqlBulkCopyUDT
{
    class Program
    {
        static void Main(string[] args)
        {
            int _TheID = Int32.Parse(args[0]);

            string _TheConnectionString = 
              @"Data Source=(local); Integrated Security=true; Initial Catalog=my_database;";
            if (args.Length > 1)
            {
                _TheConnectionString = args[1];
            }

            //DataTable _DataTable = new DataTable();
            //_DataTable.Columns.Add("ID", typeof(Int32));
            //_DataTable.Columns.Add("SomeDate", typeof(DateTime));
            //_DataTable.Columns.Add("SomeData", typeof(Type_HashTable));

            //Type_HashTable _Bob = Type_HashTable.Parse(@"testKey=testVal");
            //_DataTable.Rows.Add(_TheID, DateTime.Now, _Bob);

            //_DataTable.Rows.Add(_TheID + 1, DateTime.Now,
            //   Type_HashTable.Parse(@"testKey2=testVal2"));

            //SqlBulkCopy _BulkCopy = new SqlBulkCopy(_TheConnectionString);
            //_BulkCopy.DestinationTableName = "dbo.BulkCopyUDT";

            //try
            //{
            //    _BulkCopy.WriteToServer(_DataTable);
            //}
            //finally
            //{
            //    _BulkCopy.Close();
            //}

            using (SqlConnection _Connection = new SqlConnection(_TheConnectionString))
            {
                using (SqlCommand _Command = _Connection.CreateCommand())
                {
                    _Command.CommandType = CommandType.Text;
                    _Command.CommandText =
                        @"INSERT INTO dbo.BulkCopyUDT (ID, SomeDate, SomeData)
                         VALUES (@MyID, GETDATE(), @MyData);";

                    SqlParameter _ParamMyID = new SqlParameter("@MyID", SqlDbType.Int);
                    _ParamMyID.Value = _TheID;
                    _Command.Parameters.Add(_ParamMyID);

                    SqlParameter _ParamMyData = new SqlParameter("@MyData", SqlDbType.Udt);
                    _ParamMyData.UdtTypeName = "SQL#.Type_HashTable";
                    _ParamMyData.Value = Type_HashTable.Parse(@"testKey3=testVal3");
                    _Command.Parameters.Add(_ParamMyData);

                    _Connection.Open();
                    _Command.ExecuteNonQuery();
                }
            }
        }
    }
}

---

附：如果将数据直接发送到 UDT 列，则它需要采用二进制形式，因为这是 SqlBulkCopy 传输它的唯一方式，根据 source code。

Answer 2

我在 UDT 中的两个方法上使用了显式接口表示法，就像这样。

void IBinarySerialize.Read( BinaryReader r )
{
}

void IBinarySerialize.Write( BinaryWriter w )
{
}

但它们必须像这样定义：

public void Read( BinaryReader r )
{
}

public void Write( BinaryWriter w )
{
}

差异足以阻止 SQL Server 在 SqlBulkCopy 期间识别在 UDT 上使用的正确方法，并在传递完整的 MyType 对象时进行参数化 INSERT。

当我使用 Visual Studio 添加实现 IBinarySerialize 接口的存根例程时，问题就开始了。我右键单击struct 定义顶部的接口名称并选择“显式实现接口”。我应该选择“实现接口”来生成没有限定符的方法存根。