带有 CLR UDT 的 SQLBulkCopy 给出 "Could not find method 'Read' for type 'MyNamespace.MyType' in assembly 'MyType'"

Question

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

我们有一项服务以相当普遍的方式使用 SQLBulkCopy 来提取目录中的文件，然后将它们的内容插入适当的 table。当我将我的 UDT 作为其中一个 table 的列添加时，我从 WriteToServer( DataTable ) 调用中收到一个错误。

UDT 列作为 System.String 传递，希望在 SQL 服务器中调用 UDT 的 Parse() 方法以将其转换为内部类型。我也试过在这个客户端程序中声明 UDT class，并直接将数据作为 UDT 类型传递。

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

Could not find method 'Read' for type 'MyNamespace.MyType' in assembly 'MyType'

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

CREATE TYPE [dbo].[MyType]
EXTERNAL NAME [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# 代码（我将 "client" 设为 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();
                }
            }
        }
    }
}

P.S。如果将数据直接发送到 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 服务器在 SqlBulkCopy 和传递完整 MyType 对象时参数化 INSERT 期间识别要在 UDT 上使用的正确方法。

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

带有 CLR UDT 的 SQLBulkCopy 给出 "Could not find method 'Read' for type 'MyNamespace.MyType' in assembly 'MyType'"

SQLBulkCopy with CLR UDT gives "Could not find method 'Read' for type 'MyNamespace.MyType' in assembly 'MyType'"

sql-server

sqlclr

sqlbulkcopy

user-defined-types

sql-server-2012