如何为 JSON Web API 数据编写存储过程

Answer 1

好吧，既然你已经有一个很好的数据设置解析系统，并且你已经有一个很好的类对象来表示现在是一个非常易于使用的类对象的 json？

那么我们需要并在这里询问的所有内容？

如何在表中插入一行数据？

以上是您唯一的问题。

所以你的代码（警告 - 空气代码如下）将有点像这样：

string strSQL
  = @"INSERT into [Tortoise_Street_Properties]
    (Pid, InLineAddress) VALUES(@Pid, @Address)";

 // replace TEST4 and properites with your conneciton string.
 using (SqlConnection conn = new SqlConnection(Properties.Settings.Default.TEST4))
 {
    using (SqlCommand cmdSQL = new SqlCommand(strSQL, conn))
    {
     cmdSQL.Parameters.Add("@Pid", SqlDbType.NVarChar).Value = data.attributes.Pid;
     cmdSQL.Parameters.Add("@Address", SqlDbType.NVarChar).Value = data.attributes.InLineAddress;

     conn.Open();
     cmdSQL.ExecuteNonQuery();
    }
 }

因此，您可以简单地勾画列，设置对象中的值，然后插入值。

我们真的不在乎您是否有 3 个变量 A、B、C，正在读取一个文本文件，或者您是否有那个复杂的 json 对象。

你的目标，你的问题，你的追求？

如何将一些数据插入数据库。这就是你的技能和目标。

编辑： 唯一的问题是某些数据是“重复的”，因此上面的简单插入代码显示了字段映射和将数据简单插入到表中？您可能有一个外部循环 - 特定数据数组上的每个循环。但是，请记住，对于那些重复数据，您有一个 EVEN 类类型，并且您希望使用为数组定义的该类。

您拥有该现有类的 STRONG 类型数据，现在您可以轻松地从该类中提取数据。简单地从该类中查找并获取您想要的数据，并按照上述使用简单的 SQL 插入语句。

另外，为了创建六个小插页？几乎不需要为每个例程创建一个存储过程 - 只需编写简单的 SQL 并按照上面的方法插入即可。如果您在代码中的多个位置需要它们，我只会编写一个巨大的小插入存储过程。为相当于简单的单行 SQL 插入的内容编写存储过程是世界贫困的公式 - 它只是不需要。

Answer 2

批量插入的最简单方法可能是将整个 JSON 字符串发送到 SQL Server 并使用 OPENJSON 解析它。

这是一个有点复杂的 JSON，因为它在其属性中引用了其他属性。

因此，最好先将included 数组值解析为表变量，然后将其连接回主数组。

• 不清楚你从哪里得到virtualtour，所以我把它省略了。
• 请注意数据类型，您当前的类型会留下您想要的。 latitude 不应该是 int，它应该是 decimal，price 不应该是 varchar。 ID 似乎都是uniqueidentifier。
• 如果属性名称完全匹配，则无需指定路径。
• 必须使用单独的OUTER APPLY OPENJSON 解析具有多个对象的嵌套数组。在这种情况下，除了 included 之外，您没有任何其他内容，我们将其单独解析为表变量。

CREATE OR ALTER PROC dbo.InsertJSON
  @json nvarchar(max)
AS

SET NOCOUNT, XACT_ABORT ON;

DECLARE @included TABLE (id uniqueidentifier PRIMARY KEY, attributes nvarchar(max));

INSERT @included (id, attributes)
SELECT j.id, j.attributes
FROM OPENJSON(@json, '$.included')
  WITH (
    id uniqueidentifier,
    attributes nvarchar(max) AS JSON  -- for whole JSON object
  ) j;


INSERT dbo.Tortoise_Street_Properties
  (Pid, inlineaddress, postcode, description, bedrooms, price, salestatus, brochure, longitude, latitude)
SELECT
  main.PId,
  main.inline_address,
  main.postcode,
  details.full_description,
  main.bedrooms,
  listing.price,
  main.sale_status,
  media.url,
  addr.longitude,
  addr.latitude
FROM OPENJSON(@json)
  WITH (
    Pid uniqueidentifier '$.id',
    inline_address varchar(255) '$.attributes.inline_address',
    postcode varchar(20) '$.attributes.postcode',
    bedrooms int '$.attributes.bedrooms',
    sale_status varchar(255) '$.attributes.sale_status',
    address uniqueidentifier '$.relationships.address.data.id',
    details uniqueidentifier '$.relationships.details.data.id',
    salesListing uniqueidentifier '$.relationships.salesListing.data.id',
    primaryImage uniqueidentifier '$.relationships.primaryImage.data.id'
  ) main

LEFT JOIN @included Iaddr ON Iaddr.id = main.address
OUTER APPLY OPENJSON(Iaddr.attributes)
  WITH (
    longitude decimal(9,6),
    latitude  decimal(9,6)
  ) addr

LEFT JOIN @included Idetails ON Idetails.id = main.details
OUTER APPLY OPENJSON(Idetails.attributes)
  WITH (
    full_description nvarchar(max)
  ) details

LEFT JOIN @included Ilisting ON Ilisting.id = main.salesListing
OUTER APPLY OPENJSON(Ilisting.attributes)
  WITH (
    price int
  ) listing

LEFT JOIN @included Imedia ON Imedia.id = main.primaryImage
OUTER APPLY OPENJSON(Imedia.attributes)
  WITH (
    url varchar(255)
  ) media
;

您的 C# 代码应如下所示

• 尽可能使用await。
• 以精确的SqlDbType 和精度/长度传递参数。

...
           if (response.IsSuccessStatusCode)
           {
               var properties = await response.Content.ReadAsStringAsync();
               await InsertJSON(properties);
           }
....

private static async Task InsertJSON(string json)
{
    using (var conn = new SqlConnection(YourConnString))
    using (var comm = new SqlCommand("dbo.InsertJSON", conn))
    {
        comm.CommandType = CommandType.StoredProcedure;
        comm.Parameters.Add("@json", SqlDbType.NVarChar, -1).Value = json;  // -1 means max
        await conn.OpenAsync();
        await comm.ExecuteNonQueryAsync();
    }
}