使用没有主键的 SQLAdapter 和 SQLCommandBuilder
Posted
技术标签:
【中文标题】使用没有主键的 SQLAdapter 和 SQLCommandBuilder【英文标题】：Using SQLAdapter and SQLCommandBuilder without a Primary Key 【发布时间】：2021-09-08 15:03:03 【问题描述】：我正在探索使用SqlCommandBuilder 和Adapter.Update() 将DataGridView 与SQL 数据库表同步。
我想使用SqlCommandBuilder.GetUpdateCommand() 自动生成 SQL 更新语句，但是它失败了
“Dynamic SQL generation for the UpdateCommand is not supported against a SelectCommand that does not return any key column information”。这是有道理的，因为我的表没有主键。
我无法在源表上设置主键，但我确实有一个标识列。
我想向命令生成器指定要用作主键的列。 DataTable类上有这样一个特性，但是对SqlCommandBuilder好像没有影响。
我尝试了以下方法：
// Add Primary Key to help command builder identify unique rows
Table.PrimaryKey = new DataColumn[] Table.Columns["ComponentID"] ;
但似乎此信息不会传播到SqlDataAdapter 和SqlCommandBuilder，因为我仍然收到错误消息。
这是我尝试过的顺序：
// get data
Adapter.Fill(Table);
// specify primary key column
Table.PrimaryKey = new DataColumn[] Table.Columns["ComponentID"] ;
cmdBuilder = new SqlCommandBuilder(Adapter);
cmdBuilder.GetUpdateCommand() // <-- Error here
这里有什么解决方案，还是我必须指定更新和插入语句？
【问题讨论】：
I cannot set the primary key on the source table, but I do have an identity column. 为什么？为什么表有 IDENTITY 列却没有主键？这才是真正的问题。这不是that's how it is，缺少主节点是一个主要 问题。无论如何，创建 SqlCommandBuilder 是为了生成对 DataTables 和那些 require 主键的查询。 DbDataAdapter 不是由它填充的表配置的，因此在表上设置 PK 不会影响适配器
@PanagiotisKanavos 正如我的问题中提到的，我无法修改表格。这是令人遗憾的，但这通常是一个限制，因此进一步讨论它是无关紧要的。不过，感谢您澄清有关 DbDataAdapter 的那一点。
也许写自己的更新命令比使用构建器更容易，不是吗？
@CetinBasoz 如果我有许多不同的表要从中提取，那么可扩展性不是很好。我可以编写自己的 SqlCommandBuilder 类，如果没有更好的选择我也可以。
我没有准备好一些代码。我会做一个 .Fill(dataTable) 并将该表发送到“我的构建器”方法，连同键列名称的名称作为参数。该方法可以使用该 dataTable 来找出列名和类型以生成更新命令，例如：Update myTable set CustomerId = @ p1, companyName = @ p2, ... where keyColumn = @ pN。然后根据数据类型设置参数集合。 （我有另一种语言的代码，它正在工作）
【参考方案1】：
因此，正如@PanagiotisKanavos 所指出的，SqlCommandBuilder 不支持没有主键的表，即使您在 DataTable 对象中设置它也是如此。
因此，我别无选择，只能编写自己的命令生成器。
要使用它，您需要提供：
要使用的 SqlConnection 数据库（如果未在连接中提供） SQLAdapter，已经设置了 Select 命令（有一个构造函数）你如何使用它：
string selectQuery = "SELECT * FROM [dbCache].[dbo].[Component] ORDER BY [ComponentType] DESC";
// Initialize the SqlDataAdapter object by specifying a Select command
// that retrieves data from the table.
Adapter = new SqlDataAdapter(selectQuery, Connection)
FillLoadOption = LoadOption.PreserveChanges,
MissingSchemaAction = MissingSchemaAction.AddWithKey
;
// build all sql commands
Adapter = SQLCommandBuilder.BuildAll(Adapter, Connection);
接下来，完整的类代码：
public static class SQLCommandBuilder
public enum CommandType
Update = 0,
Insert = 1,
Delete = 2
/// <summary>
/// Build and add the insert, update and delete commands to the given SqlAdapter
/// </summary>
/// <param name="adapter"></param>
/// <param name="connection"></param>
/// <param name="database"></param>
/// <param name="idColumns"></param>
/// <returns>the modified adapter</returns>
public static SqlDataAdapter BuildAll(
SqlDataAdapter adapter, SqlConnection connection, string database = null, string[] idColumns = null
)
DataTable data = new DataTable();
// fill datatable with select data
adapter.Fill(data);
if (database == null)
if (string.IsNullOrEmpty(connection.Database))
throw new ArgumentException(
"Could not determine database from connection object. Please specify it manually"
);
// get database from connection
database = connection.Database;
// get table name
string table = data.TableName;
// get all column names
string[] allColumns = data.Columns.Cast<DataColumn>()
.Select(col => col.ColumnName).ToArray();
// only get id columns if the user has not manually specified them
if (idColumns == null)
// get id columns from the table. This includes any unique or auto-incrementing column
idColumns = data.Columns.Cast<DataColumn>()
.Where(col => col.AutoIncrement || col.Unique)
.Select(col => col.ColumnName)
.ToArray();
// if no id columns found
if (idColumns.Length == 0)
// throw an error
throw new Exception("No ID columns found in the table!");
else
// if the specfified columns don't exist
if (idColumns.All(id => allColumns.Contains(id, StringComparer.CurrentCultureIgnoreCase)))
// throw an error
throw new ArgumentException("Provided ID columns do not exist in the table!");
// generate all commands
adapter.InsertCommand =
BuildCommand(CommandType.Insert, connection, database, table, allColumns, idColumns);
adapter.UpdateCommand =
BuildCommand(CommandType.Update, connection, database, table, allColumns, idColumns);
adapter.DeleteCommand =
BuildCommand(CommandType.Delete, connection, database, table, allColumns, idColumns);
// return the modified adapter
return adapter;
/// <summary>
/// Build a command of the given type using the provided parameters
/// </summary>
/// <param name="cmdtype"></param>
/// <param name="connection"></param>
/// <param name="database"></param>
/// <param name="table"></param>
/// <param name="allColumns"></param>
/// <param name="idColumns"></param>
/// <returns></returns>
public static SqlCommand BuildCommand(
CommandType cmdtype, SqlConnection connection, string database, string table,
string[] allColumns, string[] idColumns
)
if (allColumns == null || allColumns.Length == 0)
throw new ArgumentNullException("allColumns", "allColumns cannot be null or empty!");
if (idColumns == null || idColumns.Length == 0)
throw new ArgumentNullException("idColumns", "idColumns cannot be null or empty!");
string strCommand = null;
switch (cmdtype)
case CommandType.Insert:
// get columns to set values for. Id columns not included because they should
// be set by the table
string[] insertCols = allColumns.Except(idColumns).ToArray();
strCommand =
"INSERT INTO [" + database + "].[dbo].[" + table + "]\n" +
"([" + string.Join("], [", insertCols) + "])\n" +
"VALUES (@" + string.Join(", @", insertCols.Select(s => s.Replace(" ", ""))) + ")";
break;
case CommandType.Update:
// compare each id column to a paremeterized variable of the same name prefixed with "old"
string[] idCompsOld = idColumns
.Select(col => "[" + col + "] = @old" + col.Replace(" ", ""))
.ToArray();
// create a setting statement. Don't set id columns, as they should never be modifiable
string[] setStatement = allColumns.Except(idColumns)
.Select(col => "[" + col + "] = @" + col.Replace(" ", ""))
.ToArray();
strCommand =
"UPDATE [" + database + "].[dbo].[" + table + "]\n" +
"SET " + string.Join(", ", setStatement) + "\n" +
"WHERE " + string.Join(" AND ", idCompsOld);
break;
case CommandType.Delete:
// compare each id column to a paremeterized variable of the same name
string[] idComps = idColumns
.Select(col => "[" + col + "] = @" + col.Replace(" ", ""))
.ToArray();
strCommand =
"DELETE FROM [" + database + "].[dbo].[" + table + "]\n" +
"WHERE " + string.Join(" AND ", idComps);
break;
SqlCommand command = new SqlCommand(strCommand, connection);
// cycle through all columns
for( int i = 0; i < allColumns.Length; i++)
string col = allColumns[i];
// create a parameter for that column
SqlParameter para = new SqlParameter()
ParameterName = "@" + col.Replace(" ", ""),
SourceColumn = col
;
// add the paramter to the command
command.Parameters.Add(para);
// in the special case of the update statement, extra parameters are needed for the
// old values
if (cmdtype == CommandType.Update)
// create a parameter for that column
para = new SqlParameter()
ParameterName = "@old" + col.Replace(" ", ""),
SourceColumn = col,
SourceVersion = DataRowVersion.Original
;
// add the paramter to the command
command.Parameters.Add(para);
return command;
使用以下代码打印命令：
// Display the Update, Insert, and Delete commands that were automatically generated
// by the SQLCommandBuilder.
Console.WriteLine("Update command : ");
Console.WriteLine(Adapter.UpdateCommand.CommandText);
Console.WriteLine();
Console.WriteLine("Insert command : ");
Console.WriteLine(Adapter.InsertCommand.CommandText);
Console.WriteLine();
Console.WriteLine("Delete command : ");
Console.WriteLine(Adapter.DeleteCommand.CommandText);
Console.WriteLine();
我明白了：
Update command :
UPDATE [dbCache].[dbo].[Component]
SET [ComponentType] = @ComponentType, [Drawings] = @Drawings, [StatusNo] = @StatusNo
WHERE [ComponentlD] = @oldComponentlD
Insert command :
INSERT INTO [dbCache].[dbo].[Component]
([ComponentType], [Drawings], [StatusNo])
VALUES (@ComponentType, @Drawings, @StatusNo)
Delete command :
DELETE FROM [dbCache].[dbo].[Component]
WHERE [ComponentlD] = @ComponentlD
我已经测试了插入、更新和删除语句，它们似乎都可以工作！
【讨论】：
我的意思是这样的:) @CetinBasoz 更新了我的解决方案，实际上只需要用户的 SqlAdapter 和 SqlConnection 。只要设置了选择查询，它就会自行确定其他所有内容。 太棒了 :) BTW 适配器已经有连接信息（至少在 SelectCommand 中）。 @CetinBasoz 是这样吗？在那种情况下，这是我可以删除的另一个论点！我稍后会更新这个 我不确定，但应该有，检查 adapter.SelectCommand.Connection。或者应该存在类似的东西。是的，它有。刚刚检查过。以上是关于使用没有主键的 SQLAdapter 和 SQLCommandBuilder的主要内容，如果未能解决你的问题，请参考以下文章