此类中的数据库连接是不是“可重用”？

Posted 2023-02-24

【中文标题】此类中的数据库连接是不是“可重用”？

【英文标题】：Is the database connection in this class "reusable"?此类中的数据库连接是否“可重用”？

【发布时间】：2011-11-21 12:58:55

【问题描述】：

我是 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 中完成了数百次，但现在，有了类和其他东西。我完全迷路了。

【参考方案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 方法中为您关闭该连接。

---

我改变的地方：

实现IDisposable接口 将方法从静态更改为类方法。 添加了打开关闭连接的新方法 将连接变量移至类级别范围 向构造函数添加了一个参数，可让您传入连接字符串（您应该将此连接字符串放入 Web.Config 中

---

编辑：

构造函数根据建议接收 connectionString。

---

【讨论】：

好主意。我已经在 :) 中添加了它

非常感谢您的回答！！ //马蒂亚斯

@Mattias 不客气。如果它解决了您的问题，请不要忘记接受答案。欢迎使用 Stack Overflow。

【参考方案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

这样连接就被正确处理了，因为 using 只是 try/finally 的语法糖

您需要做的是在同一个事务中执行 2 条 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();
    

差不多就是这个意思。

【讨论】：

事务和多语句！ +1

【参考方案3】：

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

所以是的 - 继续为单独的交易创建新的。