如果将相同数量的值传递给存储过程，则会出错

Posted 2023-03-31

【中文标题】如果将相同数量的值传递给存储过程，则会出错

【英文标题】：Error thown if the same number of values are passed to the stored procedure

【发布时间】：2021-10-16 08:00:07

【问题描述】：

我有这个运行MERGE upsert 的存储过程。它使用表值参数来获取信息。然后我从我使用 Dapper ORM 调用存储过程的 ASP.NET 5 项目中调用它。

当数据库存储过程和模型传递具有相同数量的字段时，一切正常，但这意味着如果我需要更新一个数据库并更新了 ASP.NET 项目，数据库调用将开始抛出错误或如果我不得不降级 ASP.NET 项目的当前版本但不能降级数据库也会导致任何错误。

有谁知道能够解决这个问题的解决方案吗？

基本上，我正在寻找一种方法，让他们不那么强烈地依赖特定版本才能工作。

CREATE TYPE [dbo].ItemType AS TABLE
(
    [Id]                VARCHAR(36)    NOT NULL,
    [Name]              VARCHAR(100)   NULL,
    [FullName]          VARCHAR(100)   NULL,
    [Description]       VARCHAR(4095)  NULL,
    [QuantityOnHand]    DECIMAL(18, 5) NULL,
    [IsActive]          BIT            NULL,
    [TimeCreated]       DATETIME2      NULL,
    [TimeModified]      DATETIME2      NULL,
    [AverageCost]       DECIMAL(18, 5) NULL,
    [SellingPrice]      DECIMAL(18, 5) NULL,
    [ExtCaseText]       VARCHAR(255)   NULL,
    [ExtCaseValue]      INT            NULL ,
    [Barcode]           VARCHAR(50)    NULL,
    [Brand]             VARCHAR(450)   NULL,
    [PurchaseCost]      DECIMAL(18, 5) NULL,
    [OurBrand]          BIT            NULL,
    [Vendor]            VARCHAR(450)   NULL 
)

CREATE PROCEDURE [dbo].UpsertItem
    @UpdateRecords dbo.ItemType READONLY,
    @LastModifiedSync DATETIME2 OUTPUT
AS
BEGIN
    MERGE INTO 
        qbItems AS Target
    USING 
        @UpdateRecords AS Source ON Target.Id = Source.Id

    WHEN MATCHED THEN
        UPDATE  
            SET Target.Id = Source.Id,
                Target.[Name] = Source.[Name],
                Target.[FullName] = Source.[FullName],
                Target.[Description] = Source.[Description],
                Target.QuantityOnHand = Source.QuantityOnHand,
                Target.IsActive = Source.IsActive,
                Target.[TimeCreated] = Source.[TimeCreated],
                Target.TimeModified = Source.TimeModified,
                Target.AverageCost = Source.AverageCost,
                Target.SellingPrice = Source.SellingPrice,
                Target.ExtCaseText = Source.ExtCaseText,
                Target.ExtCaseValue = Source.ExtCaseValue,
                Target.Barcode = Source.Barcode,
                Target.Brand = Source.Brand,
                Target.OurBrand = Source.OurBrand,
                Target.Vendor = Source.Vendor,
                Target.PurchaseCost = Source.PurchaseCost
            
    WHEN NOT MATCHED THEN           
        INSERT (Id, [Name], [FullName], [Description],
                QuantityOnHand, IsActive, [TimeCreated], TimeModified,
                AverageCost, SellingPrice, ExtCaseText, ExtCaseValue,
                Barcode, Brand, OurBrand, Vendor, PurchaseCost)
        VALUES (Source.Id, Source.[Name], Source.[FullName], Source.[Description],
                Source.QuantityOnHand, Source.IsActive, Source.[TimeCreated], Source.TimeModified,       
                Source.AverageCost, Source.SellingPrice, Source.ExtCaseText, Source.ExtCaseValue,
                Source.Barcode, Source.Brand, Source.OurBrand, Source.Vendor, Source.PurchaseCost);

    SELECT @LastModifiedSync = [TimeModified] 
    FROM qbItems 
    ORDER BY TimeModified ASC;
END

调用过程的C#代码：

public bool Create(ref List<qbItem> items)

    // LastMod = new DateTime();
    if (items.Count <= 0) 
        return true;

    try
    
        var p = new DynamicParameters();
        p.Add("UpdateRecords", items.Where(x => x.FullName != null).OrderBy(x => x.TimeModified).ToDataTable().AsTableValuedParameter("ItemType"));
        p.Add("LastModifiedSync", dbType: DbType.DateTime, direction: ParameterDirection.Output);
        p.Add("affectedRows", dbType: DbType.Int32, direction: ParameterDirection.ReturnValue);

        using var connection = new SqlConnection(_dbConnection.DefaultConnection);

        var affectedRows = connection.Execute("[dbo].[UpsertItem]", p,
            commandType: CommandType.StoredProcedure);

            //LastMod = items.OrderByDescending(t => t.TimeModified).Select(x => x.TimeModified).First();

        return true;
    
    catch (Exception e)
    
        logger.LogError(e.ToString());
        return false;
    


public static DataTable ToDataTable<T>(this IEnumerable<T> data)

    PropertyDescriptorCollection props = TypeDescriptor.GetProperties(typeof(T));

    DataTable table = new DataTable();

    for (int i = 0; i < props.Count; i++)
    
        PropertyDescriptor prop = props[i];
        table.Columns.Add(prop.Name, prop.PropertyType);
    

    object[] values = new object[props.Count];

    foreach (T item in data)
    
        for (int i = 0; i < values.Length; i++)
        
            values[i] = props[i].GetValue(item);
        

        table.Rows.Add(values);
    

    return table;

请评论任何您可能需要帮助的进一步信息。

【参考方案1】：

让你的 C# 查询数据库中 ItemType 的定义并根据它调整数据表怎么样

select *
from information_schema.domains
where data_type = 'table type'

您可以使用它来告诉您有关 db 端类型的信息；可能列名和类型的列表就可以了

然后您可以像现在一样构建数据表，然后通过计算要添加和删除的列来调整它

 var incs = table.Columns.Cast<DataColumn>().Select(c => c.ColumnName);

 var indb = (query the info schema and make a list)

然后您可以确定要删除哪些列以及添加哪些列：

var toRemove = incs.Except(indb);
var toAdd = indb.Except(incs);

并相应地调整数据表

foreach(.. in toRemove)
  dt.Columns.Remove(..)

由于将 db 类型映射到 c# 类型，添加可能有点痛苦，但并非不可能