将表值参数传递给具有不同字段数的存储过程

Question

我有一个要求，我需要将表值参数传递给存储过程。客户端需要在不影响 C# 代码的情况下灵活地将字段添加到表值类型（即使它需要删除和重新创建所有相关的存储过程）。是否可以向 DataTable 添加比数据类型中的列更少的列？ 我们使用的是 Microsoft SQL Server 2008 R2。

我试过这个：

SQL：

CREATE TYPE [dbo].[MyDataType] As Table
(
    ID INT NULL,
    Name NVARCHAR(50) NULL
)

CREATE PROCEDURE [dbo].[MyProcedure]
(
    @myData As [dbo].[MyDataType] Readonly
)
AS
Begin
    Select * FROM @myData
End

C#：

DataTable myDataTable = new DataTable("MyDataType");
myDataTable.Columns.Add("Id", typeof(Int32));
myDataTable.Rows.Add(1);
myDataTable.Rows.Add(2);

SqlParameter parameter = new SqlParameter();
parameter.ParameterName = "@myData";
parameter.SqlDbType = System.Data.SqlDbType.Structured;
parameter.Value = myDataTable;
command.Parameters.Add(parameter); 

我收到以下异常：

A first chance exception of type 'System.Data.SqlClient.SqlException' occurred in System.Data.dll
Additional information: Trying to pass a table-valued parameter with 1 column(s) where the corresponding user-defined table type requires 2 column(s).

Answer 1

您必须传递一个数据表，其列数与数据库表列数相同。

DataTable myDataTable = new DataTable("MyDataType");
myDataTable.Columns.Add("ID", typeof(Int32));
myDataTable.Columns.Add("Name ", typeof(string));

Answer 2

我最终动态生成数据表如下：

   public static DataTable GetDataTableFromSchema(string userDefinedTableTypeName, SqlConnection connection)
    {
        var query = "SELECT SC.name, ST.name AS datatype FROM sys.columns SC " +
                    "INNER JOIN sys.types ST ON ST.system_type_id = SC.system_type_id AND ST.is_user_defined = 0 " +
                    "WHERE SC.object_id = " +
                    "   (SELECT type_table_object_id FROM sys.table_types WHERE name = '" + userDefinedTableTypeName + "');";

        var dataTable = new DataTable();

        using (var command = new SqlCommand(query, connection))
        {
            using (var sqlDataReader = command.ExecuteReader())
            {
                while (sqlDataReader.Read())
                {
                    var columnName = sqlDataReader["name"].ToString();
                    var sqlDbType = (SqlDbType) Enum.Parse(typeof (SqlDbType), sqlDataReader["datatype"].ToString(), true);
                    var clrType = GetClrType(sqlDbType);
                    dataTable.Columns.Add(columnName, clrType);
                }
            }                
        }


        return dataTable;
    }

Answer 3

第一步是通过查询您的 dataBase.INFORMATION_SCHEMA 来执行查询以获取列的名称和类型。

SELECT COLUMN_NAME,DATA_TYPE 
FROM yourDataBase.INFORMATION_SCHEMA.COLUMNS
WHERE  TABLE_NAME = 'yourTableName'

第二步是在循环语句中使用此结果来构建所需的数据表，并将其作为参数发送

Foreach (var item in ColumnsNameType)
{
   myDataTable.Columns.Add(item.COLUMN_NAME, typeof(item.COLUMN_NAME));
}

Answer 4

首先获取数据表的结构（你的表类型）

DECLARE @ret yourTableName
SELECT * FROM @ret

然后在 C# 中用你的数据填充它并使用它来调用你的存储过程