SQL Server存储过程-检查是否存在ANY记录，如果不存在则插入

本文关键字：如果 如果不 不存在 插入 记录 ANY 存储过程 Server 检查 存在 是否 | 更新日期: 2023-09-27 18:20:22

问题：

是否可以向SQL Server 2012发送一个调用，并指定一段时间的数组，以便数据库服务器可以检查这些元素是否存在，如果不存在，则将它们插入表中？

问题：

我面临的问题是，我有一个计划的作业（调用API），每次调用它都会返回大约400条记录。这个作业每分钟调用一次，最慢的是，对于每个结果，我都会检查数据库是否已经有记录，如果没有，那么我会执行INSERT。

示例：API返回400人。我希望能够在一次调用中向DB发送每个人的ID以及姓名等。然后DB应该检查ID是否存在（对于每个人），如果不存在，则执行INSERT。

反馈：

我还想听听这是否真的是一种好的做法，或者是否有更好的处理方法。

SQL Server存储过程-检查是否存在ANY记录，如果不存在则插入

根据我的理解，作业将结果返回给应用程序（C#），然后该应用程序为每条记录调用DB。

答案是肯定的，您可以在一个补丁中将多条记录（数据表）发送到sql server，然后sql server将处理所有这些数据。

首先，在SQL Server中，必须定义一个表数据类型，其格式将从应用程序发送到数据库。

CREATE TYPE YourDataType AS TABLE(
    [Col1] [int] NULL,              [Col2] [int] NULL,                  [Col3] [int] NULL,              [Col4] [nvarchar](255) NULL,
    [Col5] [nvarchar](255) NULL,    [Col6] [nvarchar](255) NULL,        [Col7] [nvarchar](255) NULL,    [Col8] [nvarchar](255) NULL,
    [Col9] [nvarchar](255) NULL,    [Col10] [nvarchar](255) NULL,       [Col11] [int] NULL,             [Col12] [nvarchar](255) NULL,
)
GO

然后创建将使用此数据类型的过程

CREATE PROCEDURE YourProcedureName (@TableVariable YourDataType READONLY, @ScalarParameter nvarchar(255))
AS
BEGIN
INSERT INTO YourTable WITH (ROWLOCK) (Col1,Col2,Col3,Col4,Col5,Col6,Col7,Col8,Col9,Col10,Col11,Col12 ) 
    SELECT  Col1,Col2,Col3,Col4,Col5,Col6,Col7,Col8,Col9,Col10,Col11,Col12 
    FROM @TableVariable t
        /*Left Join then where ID is null to make sure the record doesn't exists*/
        LEFT JOIN YourTable PR WITH (NOLOCK) 
                                ON  PR.ID = @ScalarParameter
                                AND PR.Col1 = t.Col1    
                                AND PR.Col2 = t.Col2
                                ......
        WHERE PR.ID IS NULL
END

最后，使用数据从应用程序调用此过程。这里我是用VB.Net写的，但你可以用C#重写：

    Dim connectionString As StringBuilder = New StringBuilder()
    connectionString.AppendFormat("Server={0};", ????)
    connectionString.AppendFormat("Database={0};", ???)
    connectionString.AppendFormat("User ID={0};", ????)
    connectionString.AppendFormat("Password={0}", ????)
    Dim InputTable As DataTable = New DataTable("YourDataType")
    InputTable = ds.Tables(0).Copy() 
    InputTable.TableName = "YourDataType"
    Try
        Using conn As New SqlClient.SqlConnection(connectionString.ToString())
            Using comm As New SqlClient.SqlCommand()
                Dim insertedRecords As Int32
                comm.Connection = conn
                comm.CommandText = "YourProcedureName"
                comm.CommandType = CommandType.StoredProcedure
                Dim TableVariable As SqlClient.SqlParameter = comm.Parameters.Add("@TableVariable", SqlDbType.Structured)
                TableVariable.Direction = ParameterDirection.Input
                TableVariable.Value = InputTable
                Dim ScalarVariable As SqlClient.SqlParameter = comm.Parameters.Add(@ScalarParameter, SqlDbType.VarChar)
                ScalarVariable.Direction = ParameterDirection.Input
                ScalarVariable.Value = ???
                conn.Open()
                insertedRecords = comm.ExecuteNonQuery()
                If (insertedRecords > 0) Then
                    _Changed = True
                End If
                conn.Close()
                comm.Dispose()
                conn.Dispose()
            End Using
        End Using
    Catch ex As Exception
        Return False
    End Try
    Return True

您需要一种方法来确定记录是否已经在表中。这需要进行某种比较。

一旦你有了它，你就可以构建这样的查询：

insert into t( . . .)
    select v.*
    from values ((v1), (v2), . . .) as v(vcol)
    where not exists (select 1 from v where v.vcol = t.<whatever>);
相关文章：