To write integration tests with some data access code for my application, I wrote an abstract class for use in integration tests .
It creates a new database instance using LocalDB , and then flushes it after completion.
However, for some reason, a team DROP DATABASEalways fails with the following exception:
Cannot drop database "Integration_DataAccess" because it is currently in use.
Why is this? Is there a better approach for using LocalDB to test the integration database?
The following is the code for my abstract data integration integration test class:
using System;
using ProjectName.DataAccess.EmailSubscription;
using Microsoft.SqlServer.Management.Common;
using Microsoft.SqlServer.Management.Smo;
using NUnit.Framework;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.IO;
namespace ProjectName.DataAccess.Tests.IntegrationTests
{
public abstract class IntegrationTestBase
{
private const string DatabaseConnNameEmpty = "DbDSNEmpty";
private const string DatabaseConnName = "DbDSN";
private const string DatabaseName = "Integration_DataAccess";
[TestFixtureSetUp]
public void SetupTempDatabase()
{
var connection =new SqlConnection(ConfigurationManager.ConnectionStrings[DatabaseConnNameEmpty].ConnectionString);
var server = new Server(new ServerConnection(connection));
server.ConnectionContext.ExecuteNonQuery( string.Format( "IF EXISTS(select * from sys.databases where name='{0}') DROP DATABASE [{0}]", DatabaseName));
server.ConnectionContext.ExecuteNonQuery(string.Format("CREATE DATABASE {0}", DatabaseName));
using (var sr = new StreamReader(@"IntegrationTests\DatabaseSetup.txt"))
{
var sql = sr.ReadToEnd();
ExecuteNonQuery(sql);
}
}
[TestFixtureTearDown]
public void RemoveTempDatabase()
{
ExecuteNonQuery(string.Format("DROP DATABASE [{0}]", DatabaseName));
}
#region private methods
protected static void ExecuteNonQuery(string sql)
{
var connection = new SqlConnection(ConnectionString());
var server = new Server(new ServerConnection(connection));
server.ConnectionContext.ExecuteNonQuery(sql);
connection.Close();
}
protected static string ConnectionString()
{
return ConfigurationManager.ConnectionStrings[DatabaseConnName].ConnectionString;
}
protected static DataTable Select(string sql)
{
using (var conn = new SqlConnection(ConnectionString()))
{
var adapter = new SqlDataAdapter(sql, conn);
var data = new DataTable();
adapter.Fill(data);
return data;
}
}
protected static int ExecuteScalar(string sql)
{
using (var conn = new SqlConnection(ConnectionString()))
{
var cmd = new SqlCommand(sql, conn);
conn.Open();
int result = (int)cmd.ExecuteScalar();
conn.Close();
return result;
}
}
#endregion
}
}
source
share