SqlConnection/SqlCommand在Close和Dispose之后仍然使数据库保持在使用状态

3
我想在Xunit中创建一个临时数据库来进行集成测试,但是当我尝试删除临时数据库时,会出现如下错误:

无法删除数据库"TempDatabase_[数字]",因为它正在使用中。

仅仅关闭和释放命令和连接似乎并不能解决问题。

以下是我测试失败的简化版本:

using System;
using System.Data.SqlClient;
using Xunit;

namespace Test
{
    public class Test_Raw_Spec
    {
        [Fact]
        public void PerformWorkInTemporaryDatabase()
        {
            string connectionStringTemplate = "Data Source=SQLEXPRESS;Initial Catalog={0};Integrated Security=SSPI;Connection Timeout=10";
            int dbNum = (new Random()).Next() % 1000000;
            int tblNum = (new Random()).Next() % 1000000;

            string nameTempDb = $"TempDatabase_{dbNum}";
            string nameTempTable = $"TempTable_{tblNum}";

            var sqlConnection1 = new SqlConnection(string.Format(connectionStringTemplate, "master"));
            var sqlCommand1 = new SqlCommand($"CREATE DATABASE {nameTempDb}", sqlConnection1);
            sqlConnection1.Open();
            sqlCommand1.ExecuteNonQuery();
            sqlCommand1.Dispose();
            sqlConnection1.Close();
            sqlConnection1.Dispose();

            var sqlConnection2 = new SqlConnection(string.Format(connectionStringTemplate, nameTempDb));
            var sqlCommand2 = new SqlCommand($"CREATE TABLE {nameTempTable}(id int)", sqlConnection2);
            sqlConnection2.Open();
            sqlCommand2.ExecuteNonQuery();
            sqlCommand2.Dispose();
            sqlConnection2.Close();
            sqlConnection2.Dispose();

            var sqlConnection3 = new SqlConnection(string.Format(connectionStringTemplate, "master"));
            var sqlCommand3 = new SqlCommand($"DROP DATABASE {nameTempDb}", sqlConnection3);
            sqlConnection3.Open();
            sqlCommand3.ExecuteNonQuery();
            sqlCommand3.Dispose();
            sqlConnection3.Close();
            sqlConnection3.Dispose();
        }
    }
}
2个回答

6
这是由于连接池。当您关闭和处理连接时,它会被释放回池中,以便再次使用,而不是被销毁。重复创建和销毁连接是一个非常昂贵的过程,因此连接池被用来试图提高应用程序的整体性能。当连接被终止时(例如当池被循环使用或重新启动时,例如当您的应用程序启动或关闭时),连接将被销毁。
此外,您可以更有效地使用命令和连接。如果命令执行完成,您可以更改其文本。如果您不想这样做,至少可以重用连接。
private void Execute()
{
    using (var connection = new SqlConnection("."))
    {
        connection.Open();

        using (var command = connection.CreateCommand())
        {
            command.CommandText = "CREATE DATABASE [test]";
            command.ExecuteNonQuery();

            connection.ChangeDatabase("test");
            command.CommandText = "CREATE TABLE [dbo].[MyTable] (id int)";
            command.ExecuteNonQuery();
            
            // you must change your db context to drop the database
            connection.ChangeDatabase("master");
            command.CommandText = "DROP DATABASE [test]";
            command.ExecuteNonQuery();
        }
    }
}

连接池是在SqlClient库中实现的。每个唯一的连接字符串都会得到一个连接池,与开发人员使用'using'语句无关。 - World Wide DBA
1
是的,你说得对。我在发表评论后意识到了这一点,所以将其删除了... - coolblue2000
ALTER DATABASE [test] SET SINGLE_USER WITH ROLLBACK AFTER 5 将在5秒后强制关闭数据库中的所有其他连接(例如,池中的其他连接)。 - Richard
我发现你也可以在连接字符串中添加 Pooling=false,这最终也会清除连接池(请参见 https://dev59.com/c2w05IYBdhLWcg3w0VKa#22390350)。由于集成测试应该是所有测试的一个较小的子集,这对我来说也是一个可行的替代方案。 - VeeTheSecond

1

你尝试过在删除数据库之前等待一段时间吗?也许连接没有及时关闭。

另外,您不需要关闭连接,调用dispose就可以为您完成所有操作。最好使用using语句来实现。

using(var sqlConnection1 = new SqlConnection(string.Format(connectionStringTemplate, "master")))
{
//do your stuff here
}

这种方式无需担心关闭任何内容,因为它会在使用块的结尾自动关闭。
我也不建议打开大量连接。一个连接就足够了,因为打开连接是昂贵的。因此,创建一个(或两个,在您的情况下)然后为每个命令重复使用它。

在第2个和第3个连接之间添加120秒的延迟(System.Threading.Thread.Sleep(2 * 60 * 1000);)似乎没有帮助。我喜欢你的其他建议,并将在获得基准工作后实施它们。 - VeeTheSecond
在删除数据库之前尝试调用 sqlConnection2.ClearAllPools()。 - coolblue2000

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接