如何从原始 table 定义继承参数大小?
How to inherit parameter size from original table definition?
使用 SqlDataAdapter 和 SqlCommandBuilder 为 sql 服务器创建的更新语句效率低下,如下所述。
这里是复制的示例代码:
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 中,以下查询正在发生:
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),而在原始 table dbo.test 中,列 V 定义为 VARCHAR(50)。
因为值 708 有 3 个数字,所以传递了 VARCHAR(3)。如果要传递 5 个字符长的常量字符串,则参数大小将作为 VARCHAR(5) 传递。
该行为是设计使然,解释如下:SqlParameter.Size Property 如下:
"If not explicitly set, the size is inferred from the actual size of
the specified parameter value."
我实际上正在寻找一种方法来防止这种情况发生。因此,作为参数传递的可变长度数据类型的每个组合都会强制生成一个执行计划,这会导致 Sql 服务器中数千个类似的执行计划被编译,消耗 CPU 时间并阻塞很多的 RAM 被缓存并且永远不会被重新使用。
如何在不完全重新设计此应用程序的核心代码的情况下影响此行为?
我想在这里做的是不仅要使用 CommandBuilder 从原始 table 中获取 TYPES,还要获取 SIZE,但似乎无法获取此信息。
我想我找到了答案,所以我将 post 放在这里(格式化代码的额外 space 会有所帮助)。答案似乎是 FillSchema
和处理 DataAdapter 的 RowUpdating
事件的组合。因此,正如我们在上面的评论中简要讨论的那样,使用 da.FillSchema(ds, SchemaType.Source);
来获取列大小。然后,为 DataAdapter 的 RowUpdating
事件添加一个处理程序,并在那里设置更新命令参数的列大小。像这样:
编辑:包括更完整的代码示例以供参考:
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;
}
}
这是我在探查器中看到的屏幕截图:
使用 SqlDataAdapter 和 SqlCommandBuilder 为 sql 服务器创建的更新语句效率低下,如下所述。
这里是复制的示例代码: 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 中,以下查询正在发生:
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),而在原始 table dbo.test 中,列 V 定义为 VARCHAR(50)。
因为值 708 有 3 个数字,所以传递了 VARCHAR(3)。如果要传递 5 个字符长的常量字符串,则参数大小将作为 VARCHAR(5) 传递。 该行为是设计使然,解释如下:SqlParameter.Size Property 如下:
"If not explicitly set, the size is inferred from the actual size of the specified parameter value."
我实际上正在寻找一种方法来防止这种情况发生。因此,作为参数传递的可变长度数据类型的每个组合都会强制生成一个执行计划,这会导致 Sql 服务器中数千个类似的执行计划被编译,消耗 CPU 时间并阻塞很多的 RAM 被缓存并且永远不会被重新使用。
如何在不完全重新设计此应用程序的核心代码的情况下影响此行为? 我想在这里做的是不仅要使用 CommandBuilder 从原始 table 中获取 TYPES,还要获取 SIZE,但似乎无法获取此信息。
我想我找到了答案,所以我将 post 放在这里(格式化代码的额外 space 会有所帮助)。答案似乎是 FillSchema
和处理 DataAdapter 的 RowUpdating
事件的组合。因此,正如我们在上面的评论中简要讨论的那样,使用 da.FillSchema(ds, SchemaType.Source);
来获取列大小。然后,为 DataAdapter 的 RowUpdating
事件添加一个处理程序,并在那里设置更新命令参数的列大小。像这样:
编辑:包括更完整的代码示例以供参考:
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;
}
}
这是我在探查器中看到的屏幕截图: