c# - 一种更好的方法来实现 INSERT 而无需多次访问数据库

Question

我有以下内容，我可以让它按我的意愿工作，但我认为我做错了，你能解释一下如何以更有效的方式完成吗？同时也在同一个方法中循环Categories并执行相同的操作。DistrictsInsert()

提前致谢。

    #region Methods
    public int Insert(List<District> Districts, List<Category> Categories)
    {
        StringBuilder sqlString = new StringBuilder("INSERT INTO Stores (name, image) VALUES (@Name, @Image);");

        using (SqlConnection sqlConnection = new
           SqlConnection(ConfigurationManager.ConnectionStrings["OahuDB"].ConnectionString))
        {
            SqlCommand sqlCommand = new SqlCommand(sqlString.ToString(), sqlConnection);
            sqlCommand.Parameters.AddWithValue("@Name", this.Name);
            sqlCommand.Parameters.AddWithValue("@Image", this.Image);

            sqlConnection.Open();
            int x = (int)sqlCommand.ExecuteScalar();

            sqlString.Clear();
            sqlCommand.Parameters.Clear();

            foreach (District item in Districts)
            {
                sqlString.AppendLine("INSERT INTO districts_has_stores (district_id, store_id) VALUES (@DistrictID, @StoreID);");
                sqlCommand.CommandText = sqlString.ToString();
                sqlCommand.Parameters.AddWithValue("@DistrictID", item.ID);
                sqlCommand.ExecuteNonQuery();
            }

            return x;
        }
    }

编辑

通过执行以下操作来实现上述目标是错误的吗？

            sqlString.Clear();
            sqlCommand.Parameters.Clear();
            sqlString.AppendLine("INSERT INTO districts_has_stores (district_id, store_id) VALUES (@DistrictID, @StoreID);");
            sqlCommand.CommandText = sqlString.ToString();
            sqlCommand.Parameters.AddWithValue("@StoreID", x);
            foreach (District item in Districts)
            {
                sqlCommand.Parameters.AddWithValue("@DistrictID", item.ID);
                sqlCommand.ExecuteNonQuery();
            } 
            sqlString.Clear();
            sqlCommand.Parameters.Clear();
            sqlString.AppendLine("INSERT INTO categories_has_stores (category_id, store_id) VALUES (@CategoryID, @StoreID);");
            sqlCommand.CommandText = sqlString.ToString();
            sqlCommand.Parameters.AddWithValue("@StoreID", x);
            foreach (Category item in Categories)
            {
                sqlCommand.Parameters.AddWithValue("@CategoryID", item.ID);
                sqlCommand.ExecuteNonQuery();
            }

score 4 · Accepted Answer

第一个明显的事情是将 sqlCommand 的不变部分移出循环

sqlCommand.Parameters.Clear(); 
sqlString.Clear();
sqlString.AppendLine("INSERT INTO districts_has_stores (district_id, store_id) VALUES (@DistrictID, @StoreID);"); 
sqlCommand.CommandText = sqlString.ToString(); 
sqlCommand.Parameters.AddWithValue("@DistrictID", 0);  // as dummy value
sqlCommand.Parameters.AddWithValue("@StoreID", x);  // invariant
foreach (District item in Districts) 
{ 
    sqlCommand.Parameters["@DistrictID"].Value = item.ID; 
    sqlCommand.ExecuteNonQuery(); 
}

但这并不能解决您的基本问题。如何避免多次访问数据库。
您可以像这样使用多个插入构建查询

sqlString.Clear();
sqlString.Append("INSERT INTO districts_has_stores (district_id, store_id) VALUES (");
foreach(District item in Districts)
{
    sqlString.Append(item.ID.ToString);
    sqlString.Append(", ")
    sqlString.Append(x.ToString()); 
    sqlString.Append("),"); 
}
sqlString.Length--;
sqlCommand.CommandText = sqlString.ToString()

但是字符串连接确实是一种不好的做法，我提出这个解决方案只是作为一个例子，我不想建议这种方法。

最后一种可能性是表值参数（仅来自 SqlServer 2008）。

首先，您需要为要传入的表创建一个 Sql 类型

CREATE TYPE dbo.DistrictsType AS TABLE
    ( DistrictID int, StoreID int )

和一个 StoredProcedure，它将插入传入的数据表中的数据

CREATE PROCEDURE usp_InsertDistricts 
(@tvpNewDistricts dbo.DistrictsType READONLY)
AS
BEGIN
    INSERT INTO dbo.Districts (DistrictID, StoreID)
    SELECT dt.DistrictID, dt.StoreID FROM @tvpNewDistricts AS dt;
END

然后，回到您的代码，您将区域传递到存储过程中

（可能您需要在 DataTable 中转换您的列表）

DataTable dtDistricts = ConvertListToDataTable(Districts);
SqlCommand insertCommand = new SqlCommand("usp_InsertDistricts", sqlConnection);
SqlParameter p1 = insertCommand.Parameters.AddWithValue("@tvpNewDistricts", dtDistricts);
p1.SqlDbType = SqlDbType.Structured;
p1.TypeName = "dbo.DistrictsType";
insertCommand.ExecuteNonQuery();

好吧，如果您回头看上面的链接，您会发现其他方法可以将数据一步传递到数据库后端......（滚动到最后，您还会发现一种不需要数据库上的存储过程）

score 2 · Accepted Answer

假设 Stores 有一个标识列，在 SQL Server 中，创建一个表类型和一个表值参数以利用它：

CREATE TYPE dbo.DistrictsTVP AS TABLE
(
  DistrictID INT -- PRIMARY KEY? I hope so.
);
GO

CREATE PROCEDURE dbo.InsertStoreAndDistricts
  @Name NVARCHAR(255),
  @Image <some data type???>,
  @Districts dbo.DistrictsTVP READONLY
AS
BEGIN
  SET NOCOUNT ON;

  DECLARE @StoreID INT;

  INSERT dbo.Stores(name, [image]) SELECT @Name, @Image;

  SET @StoreID = SCOPE_IDENTITY();

  INSERT dbo.district_has_stores(district_id, store_id)
    SELECT DistrictID, @StoreID
      FROM @Districts;
END
GO

然后在 C# 中，您可以直接传递您的 List 而无需任何循环：

  using (...)
  {
    SqlCommand cmd       = new SqlCommand("dbo.InsertStoreAndDistricts", sqlConnection);
    cmd.CommandType      = CommandType.StoredProcedure;
    SqlParameter tvparam = cmd.Parameters.AddWithValue("@Districts", Districts);
    tvparam.SqlDbType    = SqlDbType.Structured;

    // other params here - name and image

    cmd.ExecuteNonQuery();
  }

score 1 · Accepted Answer

最近在我的项目中，我在存储过程中使用 XML 作为数据类型，并且一次插入更新和删除，而不是多次访问数据库。

示例存储过程

ALTER PROCEDURE [dbo].[insertStore]
@XMLDATA xml,
@name varchar(50),
@image datatype
 AS
 Begin
  INSERT INTO Store
  (name
   ,image
  )
Select XMLDATA.item.value('@name[1]', 'varchar(10)') AS Name,   
XMLDATA.item.value('@image[1]', 'yourData type') AS Image
FROM @XMLDATA.nodes('//Stores/InsertList/Store') AS XMLDATA(item)
END

同样，您可以编写更新和删除。在 C# 中，您需要创建 xml

public  string GenerateXML(List<District> Districts)
 var xml = new StringBuilder();
 var insertxml = new StringBuilder();
 xml.Append("<Stores>");
 for (var i = 0; i < Districts.Count; i++)
        { var obj = Districts[i];
          insertxml.Append("<Store");
          insertxml.Append(" Name=\"" + obj.Name  + "\" ");
          insertxml.Append(" Image=\"" + obj.Image + "\" ");
          insertxml.Append(" />");
        }
xml.Append("<InsertList>");
xml.Append(insertxml.ToString());
xml.Append("</InsertList>");

SqlCommand cmd= new SqlCommand("insertStore",connectionString);
cmd.CommandType=CommandType.StoredProcedure;
SqlParameter param = new SqlParameter ();
param.ParameterName ="@XMLData";
param.value=xml;
paramter.Add(param);
cmd.ExecuteNonQuery();

score 0 · Accepted Answer

想想你的系统设计。您需要插入的数据来自哪里？如果它已经在数据库、另一个数据库或某种其他类型的数据存储中，您应该能够实现更批量的传输，只需在存储过程的循环中从一个数据库插入到另一个数据库。

如果数据来自用户，或者来自一些不兼容的数据存储，比如从某个第三方程序导出，那么您基本上必须意识到将其输入数据库将涉及到数据库的相当多的往返。您可以使用一些表或 XML 等，但这些实际上更接近于使用其他方法进行批量插入。

底线是 SQL 数据库被设计为一次插入一个。这在 99% 的情况下都可以，因为您永远不会要求使用 UI 的用户一次输入数千个内容。

score 0 · Accepted Answer

就个人而言，我会为插入创建一个存储过程并传入一个表值参数，这将允许你做

INSERT tbl (f1, f2, ... fN)
SELECT * FROM @TVP

http://msdn.microsoft.com/en-us/library/bb510489.aspx

除非您使用的是 SQL 2005，否则我将在我的存储过程中使用 XML 参数并序列化要插入的集合。

c# - 一种更好的方法来实现 INSERT 而无需多次访问数据库

编辑

5 回答 5

Related

Reference