将C#中的10000条记录插入SQL Server

本文关键字：插入 SQL Server 记录 10000条 中的 | 更新日期: 2023-09-27 17:58:37

我有一个C#控制台程序

  • 从Input表（Keyid varchar(4), Address varchar(100), Name varchar(100)）中选择10000条记录。

  • 对于Input表中的每条记录，它调用一个API，该API返回需要保存在一个主表和一个明细表中的数据（如果人员在该地址工作，则状态为OK else NOT OK，还返回感兴趣的地址类型或住宅、商业等）。

Main表：

1001|JOE STILTON| 2 MAIN ST, SALEM,PA| OK|4/15/2014

Detail表格：

1001|PHARMACY
1001|COMMERCIAL

即Joe在一家药店工作，这家药店也是一家商业建筑。

现在，我调用API。然后我调用一个方法，

private static void insertTable(string keyid, DateTime updDate, string name, string address,string status)
{
     Int32 rowsAffected = 0;
     string connectionString = GetConnectionString();
     SqlConnection connection = new SqlConnection(connectionString);
     connection.Open();
     SqlCommand cmd = new SqlCommand("google.usp_InsertCompanyAddrComponents", connection);
     cmd.CommandType = CommandType.StoredProcedure;
     cmd.CommandTimeout = 90;
     cmd.Parameters.Add("@keyid", SqlDbType.VarChar);
     cmd.Parameters["@keyid"].Value = keyid;        
     cmd.Parameters.Add( new SqlParameter("@dateverified", updDate));
     cmd.Parameters.Add("@name", SqlDbType.VarChar);
     cmd.Parameters["@name"].Value = name;
     cmd.Parameters.Add("@address", SqlDbType.VarChar);
     cmd.Parameters["@address"].Value = address;
     cmd.Parameters.Add( new SqlParameter("@status", status));
     try
     {
         rowsAffected = cmd.ExecuteNonQuery();
     }
     catch (Exception ep)
     {
         Console.WriteLine(ep.Message);
     }
     connection.Close();
}

然后，我调用另一个类似的方法，插入到详细信息表中。

由于我必须一次为10000条记录执行此操作，因此有很多I/O。如何更改为执行批量插入？一次插入10000个？

谢谢R

将C#中的10000条记录插入SQL Server

您还可以了解SQL Server中的表类型。您可以在存储过程中传递两种表类型，并直接在那里执行所需的操作。

这是我的样品存储过程

CREATE PROCEDURE [dbo].[usp_AssociateTags]  
@Tags AS UDT_Tag READONLY  
AS  
SET XACT_ABORT ON  
BEGIN TRAN  
   --Insert into Tag Master  
   INSERT INTO dbo.TagMaster  
     (   
     Name  
     ,IsActive  
     )  
   VALUES  ( '', -- Name - varchar(50)  
       1  -- IsActive - bit  
     )  
   DECLARE @TagId AS INT  
   SET @TagId=SCOPE_IDENTITY()  
   INSERT INTO dbo.TagCollection  
           ( TagNumber, TagId )  
   SELECT TagNumber, @TagId  FROM @Tags t  
   WHERE NOT EXISTS(SELECT * FROM dbo.TagCollection WHERE TagNumber = t.TagNumber)  
COMMIT TRAN  
SET XACT_ABORT OFF

测试此存储过程的脚本

--DECLARE @hello as UDT_Tag  
--INSERT INTO @hello VALUES('vaibhav')  
--INSERT INTO @hello VALUES('Shantanu')  
--INSERT INTO @hello VALUES('Sam')  
--INSERT INTO @hello VALUES('Aakash')  
--EXEC usp_AssociateTags @hello  
--SELECT * FROM dbo.TagCollection

使用此过程的C#代码

SqlParameter Tags = new SqlParameter { ParameterName = "@Tags"
                  , Value = entity.Tags.ToDataTable() 
                  , Direction = ParameterDirection.Input
                  , SqlDbType = SqlDbType.Structured, TypeName="UDT_Tag" };
SqlHelper.ExecuteNonQuery(tran, CommandType.StoredProcedure
               , "usp_AssociateTags", Tags);

CodeProject

相关文章：