等待创建数据库完成

本文关键字：数据库 创建 等待 | 更新日期: 2023-09-27 18:33:33

我有这样的代码：

using (var sqlConnection = new SqlConnection(connectionString))
{
  sqlConnection.Open();
  using (var sqlCommand = new SqlCommand(scriptText, sqlConnection))
  {
    sqlCommand.ExecuteNonQuery();
  }
}
我

第一次调用它来创建数据库，然后我形成一个连接到这个数据库的连接字符串并尝试做一些工作（Open工作正常，并说连接实际上是为第二个连接打开的）。但是我收到"远程主机强行关闭了现有连接"，并且我可以看到sql日志"找不到数据库ID 9。数据库可能尚未激活或可能正在转换"。所以，实际上ExecuteNonQuery在工作完成之前就回来了。当然，我可以在情况发生变化之前发送垃圾邮件，但是有没有更好的方法来等待DB准备好工作？

等待创建数据库完成

这个完整的示例对我有用。

它创建数据库，创建一个表，在表中放置一行。

不知道你这边出了什么问题。 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
namespace GranadaCoder.PlaygroundConsole.SqlStuff
{
    public class SqlPlayground
    {
        public static void EntryPointStuff()
        {
            string databaseName = "MyFirstDatabaseABC";
            string connectionString = string.Empty;
            string commandText = string.Empty;
            int returnValue = 0;
            string msg = string.Empty;
            SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder();
            builder["Initial Catalog"] = "master";
            builder["integrated Security"] = true;
            builder["Server"] = @"MyMachine'MyInstance";
            connectionString = builder.ConnectionString;

            commandText = string.Format("IF EXISTS (Select * from sys.databases where name = N'{0}') DROP DATABASE [{0}]", databaseName);
            returnValue = RunACommand(connectionString, commandText);
            msg = string.Format("'{0}', {1}", returnValue, commandText);
            Console.WriteLine(msg);
            commandText = string.Format("IF NOT EXISTS (Select * from sys.databases where name = N'{0}') CREATE DATABASE [{0}]", databaseName);
            returnValue = RunACommand(connectionString, commandText);
            msg = string.Format("'{0}', {1}", returnValue, commandText);
            Console.WriteLine(msg);
            /* Change the Catalog */
            builder["Initial Catalog"] = databaseName;
            connectionString = builder.ConnectionString;

            commandText = "if exists (select * from dbo.sysobjects where id = object_id(N'[dbo].[CodeCategory]') and OBJECTPROPERTY(id, N'IsUserTable') = 1)    BEGIN       DROP TABLE [dbo].[CodeCategory]     END ";
            returnValue = RunACommand(connectionString, commandText);
            msg = string.Format("'{0}', {1}", returnValue, commandText);
            Console.WriteLine(msg);
            commandText = "CREATE TABLE [dbo].[CodeCategory] (    CodeCategoryKey           [smallint] not null     , CodeCategoryName      varchar(64) not null  ) ";
            returnValue = RunACommand(connectionString, commandText);
            msg = string.Format("'{0}', {1}", returnValue, commandText);
            Console.WriteLine(msg);

            commandText = "INSERT INTO [dbo].[CodeCategory] (     CodeCategoryKey       , CodeCategoryName    ) Select 1001 , 'MyFirstCodeCategory' ";
            returnValue = RunACommand(connectionString, commandText);
            msg = string.Format("'{0}', {1}", returnValue, commandText);
            Console.WriteLine(msg);
            commandText = "Select Count(*) from [dbo].[CodeCategory]";
            returnValue = RunACommand(connectionString, commandText);
            msg = string.Format("'{0}', {1}", returnValue, commandText);
            Console.WriteLine(msg);
        }


        private static int RunACommand(string connectionString, string scriptText)
        {
            int returnValue = 0;
            using (var sqlConnection = new SqlConnection(connectionString))
            {
                sqlConnection.Open();
                using (var sqlCommand = new SqlCommand(scriptText, sqlConnection))
                {
                    returnValue = sqlCommand.ExecuteNonQuery();
                }
                sqlConnection.Close();
            }
            return returnValue;
        }



    }
}

这对我有用（无一例外）：

    static void Main(string[] args)
    {
        try
        {
            SqlPlayground.EntryPointStuff();
            Console.WriteLine("Press Enter after deleting the database in SSMS manually with 'Close Existing Connections' checked.");
            Console.ReadLine();
            SqlPlayground.EntryPointStuff();

        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }

        Console.WriteLine("Pressing Enter To End");
        Console.ReadLine();
    }

在我的情况下，添加 Thread.Sleep（...） 有所帮助，但根本原因是失败的连接被缓存并由方法 SqlConnection.Open（） 使用。请参阅有关此情况的问题的答案。使用 SqlConnection.ClearAllPools（） 清除池会有所帮助。

为什么等待几秒钟也有帮助？似乎通过计时器自动清除池就足够了。

如果您在创建后立即执行其他操作（例如更新数据库架构），您可能会注意到此问题。等待几秒钟似乎可以解决问题。

//wait for database creation
Thread.Sleep(3000);
相关文章：