SQL Server 的 Upsert / Merge 代码生成 - C#/.NET

Question

为 SQL Server 生成“UPSERT”合并语句的最佳方法是什么？我正在寻找一种方法，只需放入 SQL Server 连接字符串，然后将一段代码指向单个 SQL Server 表。

是不是爬取INFORMATION_SCHEMA.COLUMNS和INFORMATION_SCHEMA.TABLES获取元数据，写一个小控制台app？其他建议？

我希望能够将生成的代码复制并粘贴到“const string sql”变量中，然后与 Dapper 之类的东西一起使用。

Answer 1

在 C# 中的 SQL Server 中更新插入的最快方法是批量插入临时表并从那里合并到生产表。

var tmpTable =
                "create table #myTable (a as int, b as nvarchar(200)";

var conString = "my_connection_string";

 using (var con = new SqlConnection(conString))
            {
                con.Open();

                //Create Temp Table
                var cmd = new SqlCommand(tmpTable, con);
                cmd.ExecuteNonQuery();

                //Build Data Set
                var dt = new DataTable();
                dt.Columns.Add(new DataColumn("A", typeof(int)));
                dt.Columns.Add(new DataColumn("B", typeof(string)));

                foreach (var myDataRow in myData)
                {
                    var row = dt.NewRow();

                    row["A"] = myDataRow.A;
                    row["B"] = myDataRow.B;
                    dt.Rows.Add(row);
                }

                //Write to temp table
                using (var bulk = new SqlBulkCopy(con))
                {
                    bulk.BulkCopyTimeout = 0;
                    bulk.DestinationTableName = "#myTable";
                    bulk.WriteToServer(dt);
                }

                //Do the upsert
                var mergeSql = "merge into myData as Target " +
                               "using #myTable as Source " +
                               "on " +
                               "Target.A=Source.A " +
                               "and Target.B = Source.B " +
                               "when matched then " +
                               "update set Target.A=Source.A, Target.B = Source.B, " +
                               "when not matched then " +
                               "insert (A,B) values (Source.A,Source.B);";

                cmd.CommandTimeout = 0;
                cmd.CommandText = mergeSql;
                cmd.ExecuteNonQuery();

                //Clean up the temp table
                cmd.CommandText = "drop table #myTable";
                cmd.ExecuteNonQuery();
            }
        }

我已经测试了几种方法，这是我遇到的最快的方法。我在生产环境中使用它每天插入数百万行而不会出现问题。