使用 C# 从 JSON 更新 SQL 表

如何解决使用 C# 从 JSON 更新 SQL 表

我正在调用一个输出 JSON 负载的网络服务，JSON 字符串具有 productName、packageId、webReferenceId。调用 Web 服务时，productName 作为查询字符串传递。我能够传递查询字符串并检索具有 productName、packageId、webReferenceId 的 JSON 负载，如下所示。

JSON：

{
    "product": [
        {           
            "product": "adc","pkgid": 1124245,"wrfid": 5387612
        }
    ]
}

使用以下 C# 代码检索 JSON 负载。

C#：

var jsondata = new WebClient();
string prdcode = jsondata.DownloadString(new Uri(url));

JavaScriptSerializer jss = new JavaScriptSerializer
{
    MaxJsonLength = Int32.MaxValue
};
Rootobject ro = jss.Deserialize<Rootobject>(prdcode);

现在，我必须使用 sql 输出中的 packageId、webReferenceId 更新 JSON 表。我正在将 JSON 结果读入 DataReader，但不确定如何UPDATE sql 表。

DataTable dt = new DataTable();
dt.Columns.Add(new DataColumn("packageId",typeof(int)));
dt.Columns.Add(new DataColumn("webReferenceId",typeof(int)));
DaTarow dr = dt.NewRow();

foreach (var product in ro.data)
{
    dr["packageId"] = product.pkgid;
    dr["webReferenceId"] = product.wrfid;
}

解决方法

执行此操作的“最佳”方法取决于您希望处理的行数。如果它只有几行，那么继续使用一系列参数化的 INSERT INTO... 命令插入它们。

对于更大的列表，尽管 SqlBulkCopy 对象将采用 DataTable 或 IDataReader 并将内容批量上传到您的表格。

// abstracting the setup for brevity - you can write these :)
var source = LoadDataTable();
var connection = GetSqlConnection();

// now the bulk copy:
using (var bulk = new SqlBulkCopy(connection))
{
    bulk.DestinationTableName = "your_table";
    bulk.WriteToServer(source);
}

这将尝试将行直接转储到表中。如果数据类型等有任何不同，那么插入将失败并显示一条错误消息（希望）可以解释发生了什么问题。

您必须确保源数据不违反任何约束，例如复制现有主键等，并且它与目标表的格式相匹配。

根据您的用例，将数据加载到临时表（临时表或其他）中，然后使用 MERGE 更新最终目标可能会有所帮助。这可以帮助处理主键违规等问题。它还允许您使用 SQL 服务器本身上的查询和存储过程执行一些 ETL 任务，而不是拉出大量数据，将其全部匹配并推回。>