-1

我正在构建一个连接到 SQL 数据库的 Windows 窗体应用程序。在我的应用程序启动时，它会向数据库发送一些查询以比较值：

查询列表

这是生成查询的代码：

    private void CreateInsertQuery(DirectoryInfo source, string Printer)
    {
         foreach (FileInfo file in source.GetFiles())
        {
            queries.Add("EXECUTE sqlp_UpdateInsertFiles '"+ file.Name +"', '" + Printer + "'"); 
        }
         foreach (DirectoryInfo folder in source.GetDirectories())
        {
            queries.Add("EXECUTE sqlp_UpdateInsertFiles '" + folder.Name + "', '" + Printer + "'");
            CreateInsertQuery(folder, Printer); 
        }
    }

queries是一个公共列表。

这是将查询发送到数据库的代码：

   public bool InsertQueries()
    {
        con.Open(); 
        using(OleDbTransaction trans = con.BeginTransaction())
        {
            try
            {
                OleDbCommand cmd;
                foreach (string query in queries)
                {
                    try
                    {
                        cmd = new OleDbCommand(query, con, trans);
                        cmd.ExecuteNonQuery();
                    }
                    catch (Exception ex)
                    {
                        if (ex.HResult != -2147217873)
                        {
                            MessageBox.Show(ex.Message);
                        }
                    }
                }
                trans.Commit();
                con.Close();
                return true;
            }
            catch (Exception ex)
            {
                trans.Rollback();
                con.Close();
                return false;
            }
        }

    }

在我的 SQL 数据库中，我创建了一个在数据库接收到查询时调用的存储过程：

    AS
        BEGIN
            BEGIN TRANSACTION;
            SET NOCOUNT ON;
            BEGIN TRY
                IF EXISTS
                   (SELECT TOP 1 fName, Printer
                    FROM   dbo.FileTranslation
                    WHERE  fName = @fName AND Printer = @Printer)
                BEGIN
                    UPDATE dbo.FileTranslation
                        SET fName = @fName, Printer = @Printer
                END;
                ELSE
                BEGIN
                    INSERT INTO dbo.FileTranslation(fName, Printer) VALUES (@fName, @Printer);
                END;
            COMMIT TRANSACTION;
            
            END TRY
            BEGIN CATCH
                IF @@TRANCOUNT > 0
                BEGIN
                    ROLLBACK TRANSACTION;
                END
            END CATCH
        END;
GO

当我在一个空数据库上运行我的应用程序时，这些值将毫无问题地添加：

数据库的表：第一次启动.

我也没有出现任何错误。只有当我第二次启动我的应用程序时，前两个查询才不会在 IF EXISTS 上得到检查。因为它仍在将数据插入我的数据库，准确地说是 5 倍。

充满重复的数据库.

这很奇怪，因为只有 2 个查询包含数据，但每次都会执行。

4

1 回答 1

2

我假设该id列是一个 sql 标识列，对吗？因为前连续 7 个条目都是相同的，所以我认为您的应用程序是在多个线程上启动的，这些线程一开始是逐头执行的，但后来它们的执行可能会因为异常处理块的额外时间而出现分歧。这就是为什么只有第一条记录被相乘。

问题是您的存储过程不是线程安全的。dbo.FileTranslation并行执行时未在表上放置锁IF EXISTS(SELECT ...可能会导致多个执行存储过程发现所需记录不存在并继续INSERT分支的情况。

应用来自https://dba.stackexchange.com/questions/187405/sql-server-concurrent-inserts-and-deletes线程的答案，这可能对您有用：

...
IF EXISTS
   (SELECT TOP 1 fName, Printer
    FROM   dbo.FileTranslation WITH (UPDLOCK, SERIALIZABLE)
    WHERE  fName = @fName AND Printer = @Printer)
...

PS：与您的问题无关，但请注意@Lamu 对您处理的 SQL 注入和使用try...finally或using模式的评论conn！

于 2021-01-27T11:32:05.297 回答