ASP.NET 应用程序中的 SQL Server 连接 [关闭]

Question

我用asp.net 创建了一个web 应用程序，大致100 users 正在使用它。

但是，人们有时会收到连接仍处于打开状态的错误消息。表示没有正确关闭。

它出现在随机的地方，不是一个特定的地方，也没有其他错误。

我知道，当我在应用程序中出现错误并且它崩溃而我没有优雅地处理错误时，连接也会保持打开状态，基本上每个人都会因此而崩溃。这让我觉得每个人都使用相同的连接对象，是否有可能 2 个用户可能有完美的时机并同时使用 DB connection 调用函数导致错误？有没有办法确保每个人都使用自己的连接对象，比如把它放在他们的会话中或其他什么？

我希望你能理解我的意思，我不认为发布我的任何代码会有帮助，因为它发生在我项目中的随机位置。

它们使用System.Data.SqlClient 连接到SQL Server。

在产生错误的函数下方查找。该函数由 Page_Load 调用，它之前没有任何内容。

public static SqlConnection conn = new SqlConnection("Data Source=Server00\\SQLEXPRESS;Initial Catalog=r2;Integrated Security=true;Connect Timeout=0");

private void populateGameDrop()
{
    try
    {
        conn.Open();
        drop_game.Items.Clear();

        SqlCommand cmd = conn.CreateCommand();
        Access ac = (Access)Session["Access"];
        cmd.CommandText = "Select * from dbo.Games where " + ac.GameQuery;

        SqlDataReader r = cmd.ExecuteReader();

        while (r.Read())
        {
            drop_game.Items.Add(new ListItem(r["name"].ToString(), r["Abbr"].ToString()));
        }

        conn.Close();
    }
    catch (Exception exc)
    {
        conn.Close();
        Log.Error(exc.ToString());
        Session["Error"] = exc.ToString();
        Response.Redirect("~/YouBrokeIt.aspx");
    }

    populateServers();
    SetSplitScreen();
}

Answer 1

不要尝试共享 SqlConnection 对象。

试试这个：

private static string connString = "Data Source=Server00\\SQLEXPRESS;Initial Catalog=r2;Integrated Security=true;Connect Timeout=0";
private void populateGameDrop()
{
    try
    {
        using (var conn = new SqlConnection(connString))
        {
            conn.Open();
            drop_game.Items.Clear();
            using (var cmd = conn.CreateCommand())
            {
                Access ac = (Access)Session["Access"];
                //TODO
                //TODO - Introduce parameters to avoid SQL Injection risk
                //TODO
                cmd.CommandText = "Select name,Abbr from dbo.Games where " + ac.GameQuery;
                using(SqlDataReader r = cmd.ExecuteReader())
                {
                    while (r.Read())
                    {
                        drop_game.Items.Add(new ListItem(r["name"].ToString(),
                                            r["Abbr"].ToString()));
                    }
                }
            }
        }
    }
    catch (Exception exc)
    {
        Log.Error(exc.ToString());
        Session["Error"] = exc.ToString();
        Response.Redirect("~/YouBrokeIt.aspx");
    }
    populateServers();
    SetSplitScreen();
}

在幕后，.NET 使用了一个名为connection pooling 的概念，以便最大限度地减少与 SQL Server 的实际真实连接数。但是SqlConnection 对象并不是为多线程共享而设计的。

Answer 2

不要将数据库代码直接放在 ASPX 页面中。创建一个额外的层（即 DAL）允许您在不使用页面的情况下测试 DB 方法。

试试这样的。

//Don't embed database logic directly in the aspx files
public class GamesProvider
{        
    //Put the ConnectionString in you configuration file
    private string ConnectionString
    {
        get { return ConfigurationManager.ConnectionStrings["GameDB"].ConnectionString; }
    }

    public IEnumerable<Game> LoadGames(string x, string y)
    {
        var games = new List<Game>();

        const string queryString = "select name, Abbr from dbo.Games where x = @x and y = @y";

        using (var connection = new SqlConnection(ConnectionString))
        using (var command = new SqlCommand(queryString, connection))
        {
            command.Parameters.AddWithValue("@x", x);
            command.Parameters.AddWithValue("@y", y);
            using (var dateReader = command.ExecuteReader())
            {
                while (dateReader.Read())
                {
                    var game = new Game
                    {
                        Name = dateReader["name"].ToString(),
                        Abbr = dateReader["Abbr"].ToString(),
                    };
                    games.Add(game);
                }
            }
        }

        return games;
    }
}

//Use types
public class Game
{
    public string Name { get; set; }
    public string Abbr { get; set; }
}

Answer 3

您的SQL 连接不应是静态的，请使用以下内容创建它们

var connectionString = "YOUR CONNECTION STRING";
var queryString = "SQL QUERY";

using (SqlConnection connection = new SqlConnection(connectionString))
using (SqlCommand command = new SqlCommand(queryString, connection))
using (SqlDataReader dateReader = command.ExecuteReader()) {

}

非常重要

您应该使用参数化的SQL，您的代码对SQL 注入攻击是开放的。

请看Parameterize SQL query