Подождите базы данных Создания закончить

Question

У меня есть такой код:

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

в первый раз, я называю его, чтобы создать базу данных, затем я формирую строку подключения к этой БД и попытаться сделать некоторые работы (Open работает нормально и говорит, что соединение действительно открыто для этого второго соединения). Но я получаю «существующее соединение было принудительно закрыто удаленным хостом», и я могу видеть журналы sql «Не удалось найти идентификатор базы данных 9. База данных еще не активирована или может быть в процессе перехода». Итак, на самом деле возврат ExecuteNonQuery перед выполнением задания. Конечно, я могу просто спамить его до тех пор, пока ситуация не изменится, но есть ли лучший способ подождать, когда БД будет готова к работе?

Answer 1

Этот полный образец работает для меня.

Создает базу данных, создает таблицу, помещает строку в таблицу.

Не уверен, что не так на вашем конце.

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(); 

    } 

Answer 2

Вы можете заметить эту проблему, если вы делаете еще коснуться сразу (например схему базы данных обновления.) После создания. Ожидание в течение нескольких секунд, похоже, решает проблему.

//wait for database creation 
Thread.Sleep(3000);