程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> C語言 >> C >> C語言基礎知識 >> 解析為何要關閉數據庫連接,可不可以不關閉的問題詳解

解析為何要關閉數據庫連接,可不可以不關閉的問題詳解

編輯:C語言基礎知識

首先要說明的是連接數是有限制的:

代碼如下:
代碼如下:

for (int i = 0; i < 10000; i++)
{
    SqlConnection conn = new SqlConnection(@"Data Source=.\SQLEXPRESS;
                AttachDbFilename=""E:\DB\NORTHWND.mdf"";
                Integrated Security=True;Connect Timeout=30;User Instance=True");

    conn.Open();
    Console.WriteLine("打開了{0}個連接", i);
}

運行結果如下:

image

過一會就會提示打開連接超時了:

clip_image002

可以看到數據庫連接時有限制的,如果連接不關閉,而且使用的人比較多,那麼系統很快就down掉了。

但是有時候由於某些原因應用程序可能只是幾個人使用,所以就有人設計了:

在應用程序啟動的時候打開數據庫連接,在應用程序關閉的時候關閉數據庫連接

那麼使用這種方式有什麼問題呢?

首先假設有一張表Nums,表定義如下:

image

Main代碼如下:
代碼如下:

SqlConnection conn = new SqlConnection(@"Data Source=.\SQLEXPRESS;
                    AttachDbFilename=""E:\DB\NORTHWND.mdf"";
                    Integrated Security=True;Connect Timeout=30;User Instance=True");
conn.Open();
Parallel.For(1, 9999, (id) =>
{
    ExecuteCommand(conn, id);
});

就是從1到9999開始執行ExecuteCommand

ExecuteCommand代碼如下:
代碼如下:

private static void ExecuteCommand(SqlConnection conn, int id)
{
    Console.WriteLine("正在執行." + id);

    Thread.Sleep(100);

    SqlCommand cmd = new SqlCommand(
       string.Format("Insert into Nums values('{0}') ", id), conn);

    cmd.ExecuteNonQuery();
}

運行:

clip_image002[5]

可以看到ExecuteNonQuery方法拋出了異常,原因是連接處於關閉狀態。

可是我們的連接一直都是open著的啊,並沒有調用close,dispose之類的方法啊

於是在ExecuteCommand前面增加判斷條件:

if (conn.State != System.Data.ConnectionState.Open)
    conn.Open();再次運行:

clip_image002[7]

可以看到還是會出現連接已關閉的問題。你知道什麼原因嗎?

這裡是由於多線程環境引起的。所以需要加鎖。
代碼如下:

private static object syncObj = new object();
private static void ExecuteCommand(SqlConnection conn, int id)
{
    lock (syncObj)
    {
        if (conn.State != System.Data.ConnectionState.Open)
            conn.Open();
        Console.WriteLine("正在執行.." + id);
        Thread.Sleep(100);
        SqlCommand cmd = new SqlCommand(
           string.Format("Insert into Nums values('{0}') ", id), conn);
        cmd.ExecuteNonQuery();
    }
}

再次運行:可以發現基本沒問題了.

修改Parallel.For的最大值上限,要測試下是否可以長期執行了。
代碼如下:

Parallel.For(1, Int32.MaxValue, (id) =>
            {
                ExecuteCommand(conn, id);
            });

一天測試下來,沒出現任何問題。

結論:對於某些只有幾個人使用的應用程序,可以不關閉數據庫連接,但是在寫代碼的時候最好要加上連接是否打開的判斷。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved