这个类的数据库连接是“可重用的”吗？

Question

我是asp.net的新手，所以这可能是一个非常基本的问题，但我想不出来。

我在互联网上找到了一些连接到数据库的代码。我创建了一个命名空间和一些类，以便在不同的项目中使用相同的代码。

代码和我的类如下所示：

namespace databaseFunctions
{
    public class databaseConnection
    {
private static string databaseConnectionString()
        {
            return "DRIVER={MySQL ODBC 5.1 Driver}; ........";
        }

        public static DataTable getFromDatabase(string SQL)
        {
            DataTable rt = new DataTable();
            DataSet ds = new DataSet();
            OdbcDataAdapter da = new OdbcDataAdapter();
            OdbcConnection con = new OdbcConnection(databaseConnectionString());
            OdbcCommand cmd = new OdbcCommand(SQL, con);
            da.SelectCommand = cmd;
            da.Fill(ds);
            try
            {
                rt = ds.Tables[0];
            }
            catch
            {   
                rt = null;
            }
            return rt;
        }

        public static Boolean insertIntoDatabase(string SQL)
        {

            OdbcDataAdapter da = new OdbcDataAdapter();
            OdbcConnection con = new OdbcConnection(databaseConnectionString());
            OdbcCommand cmd = new OdbcCommand(SQL, con);
            con.Open();
            try
            {
                cmd.ExecuteNonQuery();
                return true;
            }
            catch
            {
                return false;
            }

        }

}

从数据库中获取数据或将数据插入到某个数据库中都没有问题。但。当我试图从mysql数据库获取last_insert_id()时。我只得了个零。

这就是为什么我认为我从互联网上复制并创建的这段代码，每次调用"getFromDatabase(SQL)“时都会创建一个新的连接。

有没有人可以帮助我修复这个类getFromDatabase()，使数据库连接保持活动状态，直到我告诉程序放弃连接？

我猜应该是“新的OdbcConnection”应该改变吧？是否可以检查是否已经有活动的连接？我在经典的asp中已经做过几百次了，但现在，用的是类和其他东西。我完全迷路了。

Answer 1

您面临的问题是，您已经将自己编码到了一个“每个操作都有新连接”的角落。你真正想要的，并且被认为是最佳实践的，是“每批动作都有新的连接”。

在这种情况下，我建议在需要时打开连接，在释放时关闭连接。我们要做的是将odbc适配器移动到一个更大的作用域变量，以便可以在类中访问它。

namespace databaseFunctions
{
    public class databaseConnection:IDisposable
    {
        private OdbcConnection con;
        private string connectionString;

        public databaseConnection(string connectionString){
            this.connectionString = connectionString;
        }


        public void OpenConnection(){
            if (con == null || con.IsClosed ){ // we make sure we're only opening connection once.
                con = new OdbcConnection(this.connectionString);
            }
        }
        public void CloseConnection(){
            if (con != null && con.IsOpen){ // I'm making stuff up here
                con.Close();
            }
        }

        public DataTable getFromDatabase(string SQL)
        {
            OpenConnection();

            DataTable rt = new DataTable();
            DataSet ds = new DataSet();
            OdbcCommand cmd = new OdbcCommand(SQL, con);
            da.SelectCommand = cmd;
            da.Fill(ds);
            try
            {
                rt = ds.Tables[0];
            }
            catch
            {   
                rt = null;
            }
            return rt;
        }

        public Boolean insertIntoDatabase(string SQL)
        {
            OpenConnection();

            OdbcCommand cmd = new OdbcCommand(SQL, con);
            con.Open();
            try
            {
                cmd.ExecuteNonQuery();
                return true;
            }
            catch
            {
                return false;
            }

        }


        // Implementing IDisposable method
        public void Dispose(){
            CloseConenction();
        }
    }
}

现在，下一次使用您的类时，请执行以下操作

using (DatabaseConnection db = new DatabaseConnection()){
    db.InsertIntoDatabase(...);
    db.GetLastInsertID();
    db.GetFromDatabase(...);
}

在该代码块的末尾，因为它是IDisposeable，所以它将在dispose方法中为您关闭该连接。

我改变了一些事情：

• implemented IDisposable interface
• 将方法从静态更改为类方法。
• 将打开关闭连接变量的新方法添加到类级作用域
  • 向允许您传递连接字符串的构造函数添加了参数(您应该将此连接字符串放入Web.Config中<代码>H213<代码>F214

编辑：

• 构造函数根据建议接受connectionString。

Answer 2

是的，您发布的代码在每次调用方法时都会创建一个新的数据库连接，但这不是问题。问题是它没有正确地处理连接。处理此类事件的方法如下：

using (OdbcConnection con = new OdbcConnection("yourconnectionsstring"))
{
   con.open();
   OdbcCommand command = new OdbcCommand("command_text",con);
   command.ExecuteQuery(); //or what ever you need to do
}

这样就可以正确地处理连接，因为使用只是try/finally的语法糖

您需要做的是在同一事务中执行这两个sql语句，即在第一个sql语句中插入记录，并在结束事务之前在下一次插入时检索最后插入的id。例如：

 using (OdbcConnection con = new OdbcConnection("yourconnectionsstring"))
    {
       con.open();
       OdbcTransaction tran = con.BeginTransaction()
       OdbcCommand command = new OdbcCommand("first_sql_statement_here",con);
       command.ExecuteNonQuery(); 
       command.CommandText = "select last_insert_id();";
       int result =command.ExecuteScalar(); 
       tran.commit();
    }

这几乎就是我们的想法。

Answer 3

您应该让连接池处理您的连接；这意味着您将尽可能快地Close()每个连接，并且只在最后可能的时刻创建一个新的连接。

所以是的-继续为单独的事务创建新的事务。