0

使用SqlDataAdapter和SqlCommandBuilder为sql server创建的更新语句效率低下,如下所述。如何从原始表定义继承参数大小?

这里是再现示例代码: SQL服务器:

Create database TestDB; 
GO 
USE [TestDB] 
CREATE TABLE [dbo].[test](
    [i] [int] NOT NULL, 
    [v] [varchar](50) NULL, 
    [c] [char](10) NULL, 
CONSTRAINT [pk1] PRIMARY KEY CLUSTERED ([i] ASC) WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] 
) ON [PRIMARY] 
GO 
insert into dbo.Test (i,v,c) values (10,'A','B'); 
GO 

C#控制台应用程序演示代码:

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

namespace CmdBuildTest 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      SqlConnection cn = new SqlConnection(); 
      cn.ConnectionString = @"Server=localhost\sql2016;Database=testDB;Trusted_Connection=True;";    
      SqlDataAdapter da = new SqlDataAdapter("Select * From dbo.test", cn); 

      //da.FillSchema(ds, SchemaType.Mapped);   
      SqlCommandBuilder cb = new SqlCommandBuilder(da); 
      cb.ConflictOption = ConflictOption.OverwriteChanges; 
      //cb.RefreshSchema(); 
      DataSet ds = new DataSet(); 
      da.Fill(ds); 
      ds.Tables[0].Rows[0]["v"] = DateTime.UtcNow.Millisecond.ToString(); 
      SqlCommand u = cb.GetUpdateCommand(true); 
      Console.WriteLine("Update Command: " + u.CommandText); 

      foreach (SqlParameter par in u.Parameters) 
      { 
       Console.WriteLine(" Name=" + par.ParameterName + "|Type=" + par.SqlDbType.ToString() + " |Size=" + par.Size.ToString()); 
      }   
      da.UpdateCommand = u; //I am not sure if this is required, but I am careful.    
      //Execute Changes/Update Statement : 
      da.Update(ds); 
      Console.ReadLine(); 
      //Sample result in Profiler: 
      /* 
       exec sp_executesql N'UPDATE [dbo].[test] SET [v] = @v WHERE (([i] = @Original_i))',N'@v varchar(3),@Original_i int',@v = '603',@Original_i = 1 
      */ 
     } 

    } 
} 

Console.WriteLine命令显示创建下列SQL UPDATE语句:

UPDATE [dbo].[test] SET [i] = @i, [v] = @v, [c] = @c WHERE (([i] = @Original_i)) 

在Sql Profiler中,以下查询是getti毫无遗漏NG:

exec sp_executesql N'UPDATE [dbo].[test] SET [v] = @v 
WHERE (([i] = @Original_i))',N'@v varchar(3),@Original_i int',@v='708',@Original_i=1 

现在你可以看到,参数@v被定义为VARCHAR(3),而在原始表dbo.test列V被定义为VARCHAR(50)。

由于值708有3个数字,所以传递VARCHAR(3)。如果要传递一个长度为5个字符的常量字符串,则参数大小将作为VARCHAR(5)传递。 的行为是设计说明:这里:SqlParameter.Size Property如下:“如果没有明确设定,大小从 指定参数值的实际大小推断”

我正在寻找一种方法来防止这种情况。正因为如此,所有通过参数传递的变长数据类型的组合都会强制生成一个执行计划,这导致Sql Server中数千个类似的执行计划正在被编译,这些执行计划需要CPU时间并阻止大量RAM被缓存, -用过的。

如何在不完全重新设计此应用程序的核心代码的情况下影响此行为? 我想在这里做的是不仅从原始表使用CommandBuilder,而且SIZE获得TYPES,但似乎不可能获得此信息。

+0

使用的SqlDataAdapter的'FillSchema'方法将为您提供色谱柱的大小,但在我的测试中这并没有帮助。即使将这些“MaxLength”值映射回更新命令的参数,查询计划仍然会显示“varchar”列的长度被推断。 – wablab

+0

是的,这也正是我的发现,同时我也采取了这种方法,但dataadapter的UPDATE方法“销毁”所有事先准备好的东西...... – Magier

回答

1

我想我找到了答案,所以我会在这里发布(格式化代码的额外空间将有所帮助)。答案似乎是FillSchema和处理DataAdapter的RowUpdating事件的组合。因此,正如我们在上面的评论中简要讨论的那样,使用da.FillSchema(ds, SchemaType.Source);来获取列大小。然后,为DataAdapter的RowUpdating事件添加一个处理程序,并在那里为update命令的参数设置列大小。事情是这样的:

编辑:包括参考一个更完整的代码示例:

public static void Main(string[] args) 
{ 
    var cn = new SqlConnection("Data Source=.; Initial Catalog=TestDB; Integrated Security=SSPI"); 
    var da = new SqlDataAdapter("SELECT * FROM dbo.test", cn); 
    var cb = new SqlCommandBuilder(da); 
    cb.ConflictOption = System.Data.ConflictOption.OverwriteChanges; 

    var ds = new DataSet(); 
    da.Fill(ds); 
    da.FillSchema(ds, SchemaType.Source); 

    ds.Tables[0].Rows[0]["v"] = DateTime.UtcNow.Millisecond.ToString(); 
    da.RowUpdating += new SqlRowUpdatingEventHandler(da_RowUpdating); 
    da.Update(ds); 
} 

static void da_RowUpdating(object sender, SqlRowUpdatingEventArgs e) 
{ 
    foreach (var p in e.Command.Parameters.Cast<SqlParameter>()) 
    { 
     p.Size = e.Row.Table.Columns[p.SourceColumn].MaxLength; 
    } 
} 

下面是我在profiler中看到的截图: enter image description here

+0

我会尝试这个ob周四,并给你反馈。谢谢。 – Magier

+0

我试过你的建议。它基本上完全一样,我也已经尝试使用\t par.Size = ds.Tables [0] .Columns [par.SourceColumn] .MaxLength;在主要方法。这一点以及您的解决方案成功调整了所有参数大小。但不幸的是,dataadapter.Update方法仍然改变了所有这一切,它终结于SQL Server中执行的最终sp_executesql命令中灵活的,依赖于数据的数据类型大小的不希望的结果。所以,不幸的是,它不能解决问题。 – Magier

+0

奇怪。它似乎在为我的目的而努力。我在上面的答案中更新了代码,以提供我正在做的更完整的参考。也许你可以发现我们做得不同的事情,或者别人可以尝试重现结果。 – wablab