SqlCommand 之间的连接未关闭

Question

我以编程方式创建一个数据库，然后在数据库中创建一个表。创建了数据库，但没有创建表。

// Create Database
try
{
    using (SqlCommand cmd = new SqlCommand(connstr, sqlConn))
    {
        try
        {
            sqlConn.Open();
            cmd.ExecuteNonQuery();
            MessageBox.Show("DataBase is Created Successfully", "MyProgram", MessageBoxButton.OK, MessageBoxImage.Information);
        }
        catch (System.Exception ex)
        {
            MessageBox.Show(ex.ToString(), "MyProgram", MessageBoxButton.OK, MessageBoxImage.Information);
        }
        finally
        {
            if (sqlConn.State == ConnectionState.Open)
            {
                sqlConn.Close();
            }
        }
    }
}
catch(Exception ex)
{
    MessageBox.Show(ex.ToString());
}

// Create table
try
{
    using (SqlCommand cmd = new SqlCommand(
                    "CREATE TABLE dbo.MyTable ("
                    + "ID int IDENTITY(1,1) PRIMARY KEY,"
                    + "MyProduct nvarchar(100) NOT NULL,"
                    + "MyDateTime datetime NOT NULL);"
                    + "", sqlConn))
    {
        sqlConn.Open();
        cmd.Connection.Open();
        cmd.ExecuteNonQuery();
        cmd.Connection.Close();
    }
}
catch (Exception ex)
{

    MessageBox.Show(ex.ToString());
}

但我收到错误消息说我的连接没有关闭。

我尝试反复将 sqlConn.Close() 添加到每个 {block} 的末尾，但仍然出现相同的错误。创建数据库后如何正确关闭连接然后再次重新打开连接以创建表？

[编辑]

在回答输入之后，我已经重组了我的代码，我确信在不重复 Open() 的情况下包装属性。

    // Create Database
    try
        {
        using (SqlConnection sqlConn = new SqlConnection(sqlConnectionStr))
        {
            using (SqlCommand cmd = new SqlCommand(connstr, sqlConn))
            {
                try
                {
                    sqlConn.Open();
                    cmd.ExecuteNonQuery();
                    MessageBox.Show("DataBase is Created Successfully", "MyProgram", MessageBoxButton.OK, MessageBoxImage.Information);
                }
                catch (System.Exception ex)
                {
                    MessageBox.Show(ex.ToString(), "MyProgram", MessageBoxButton.OK, MessageBoxImage.Information);
                }
                finally
                {
                    if (sqlConn.State == ConnectionState.Open)
                    {
                        sqlConn.Close();
                    }
                }
            }
        }
    }
    catch(Exception ex)
    {
        MessageBox.Show("(1)\n" + ex.ToString());
    }

// Create Table
    try
    {
        using (SqlConnection sqlConn = new SqlConnection(sqlConnectionStr))
        {

            using (SqlCommand cmd = new SqlCommand("CREATE TABLE dbo.MyTable ("
                            + "ID int IDENTITY(1,1) PRIMARY KEY,"
                            + "MyProduct nvarchar(100) NOT NULL,"
                            + "MyDateTime datetime NOT NULL);"
                            + "", sqlConn))
            {
                sqlConn.Open();
                cmd.ExecuteNonQuery();
                sqlConn.Close();
            }
        }

    }
    catch (Exception ex)
    {
        MessageBox.Show("(2)\n" + ex.ToString());
    }

然后我收到错误数据库中已经有一个名为“MyTable”的对象。但是当我查看 SSMS 时，该表不存在。我现在很困惑。

Answer 1

当您创建表时，您尝试打开连接两次。 cmd.Connection 属性指向与sqlConn 相同的连接。删除其中一个。

using (SqlCommand cmd = new SqlCommand(
                "CREATE TABLE dbo.MyTable ("
                + "ID int IDENTITY(1,1) PRIMARY KEY,"
                + "MyProduct nvarchar(100) NOT NULL,"
                + "MyDateTime datetime NOT NULL);"
                + "", sqlConn))
{
    sqlConn.Open();
    cmd.Connection.Open();  // don't need this...
    cmd.ExecuteNonQuery();
    cmd.Connection.Close();
}

根据docs，这是预期行为。

无效操作异常

如果不指定数据源或服务器，则无法打开连接。
或
连接已打开。

Answer 2

我没有看到您关闭第二个查询的连接。您可以使用 SqlConnection 的 using 语句进行包装。

仅供参考：如果使用 using 语句，则无需显式关闭连接。

string cmdText = "SELECT * FROM SomeTable";
using (var conn = new SqlConnection(connectionString))
using (var cmd = new SqlCommand(cmdText, conn))
{
    conn.Open();
    cmd.ExecuteNonQuery();
    MessageBox.Show(...);
}

Answer 3

试试这个代码。也许会有帮助。

public void NewClass()
{
    try
    {
        string query = "if exists(SELECT db_id('{0}'),'TEST') ";
        query += "begin ";
        query += "print 'All Ready Exists' ";
        query += "end ";
        query += "else ";
        query += "begin ";
        query += "create database TEST ";
        query += "end ";

        lblno.Text = query+"<br>";
        con.Open();
        SqlCommand cmd = new SqlCommand(query, con);
        int ans = cmd.ExecuteNonQuery();
        cmd.Cancel(); cmd.Dispose();
        con.Close(); con.Dispose();

        string table = "if exists (select OBJECT_ID('test')) begin ";
        table += "print 'all ready' end ";
        table += "else begin ";
        table += "CREATE TABLE dbo.MyTable (ID int IDENTITY(1,1) PRIMARY KEY,MyProduct nvarchar(100) NOT NULL,MyDateTime datetime NOT NULL) ";
        table += "end ";

        con = new SqlConnection("Data Source=DESKTOP-0R1BJNQ\\HARDIKPATEL;Initial Catalog=" + dbnm + ";Integrated Security=True");
        con.Open();
        cmd = new SqlCommand(table, con);
        cmd.ExecuteNonQuery();
        cmd.Cancel(); cmd.Dispose();
        con.Close(); con.Dispose();

    }
    catch(Exception err)
    {
        lblmsg.Text = err.ToString();
    }
}