单身数据库连接

Question

我想从数据库“细节”中检索值，因为我想用数据库创建一个连接，如果连接存在，请不要建立新连接并继续前一个连接。为此，我曾尝试与以下：

import MySQLdb 
import re 
import os 

class Find: 

    def __init__(self,addr): 
     self.addr = addr 


    dsn = { 
    'username': 'xyz', 
    'password': 'xyz', 
    'hostname': 'localhost', 
    'database': 'details' 
    } 
    the_database_connection = False 

    def connect(self,dsn): 
     '''This function saves the database connection, so if invoke this again, it gives you the same one, rather than making a second connection.''' 
     global the_database_connection 
     if not the_database_connection: 
      try: 
       the_database_connection = MySQLdb.connect(
        host=dsn['hostname'], 
        user=dsn['username'], 
        passwd=dsn['password'], 
        db=dsn['database']) 
      # so modifications take effect automatically 
       the_database_connection.autocommit(True) 
      except MySQLdb.Error, e: 
       print ("Couldn't connect to database. MySQL error %d: %s" %(e.args[0], e.args[1])) 
     return the_database_connection 
     x=conn.cursor() 
     sql = "select * from persons where address = %s" % addr 
     x.execute(sql) 
     rows = x.fetchall() 
     for row in rows: 
      print row 

if __name__ == "__main__": 
    a = Find(addr = "new street") 
    a.connect() 

但这种示值误差：a.connect需要2个参数是一个定义......我 如何界定上述DSN。

Answer 1

您正在尝试重新创建连接池。

不幸的是，您的解决方案不会按原样工作。只有当所有连接参数 - 主机，端口，数据库，用户名，密码完全相同时，才能使用相同的连接。在你的情况下，你会在任何情况下返回相同的连接，这是完全错误的 - 如果任何属性不同，你必须创建新的连接。

相反，只需使用现有的连接池库之一，如pysqlpool或DBUtils（我确信还有其他的）。

Answer 2

您没有根据需要提供a.connect函数的dsn信息。将dsn信息从课程中拉出并使其成为主要功能的一部分。然后将其作为a.connect的参数反馈回来。像这样：

import MySQLdb 
import re 
import os 

class Find: 

    def __init__(self,addr): 
     self.addr = addr 

    def connect(self,dsn): 
     '''This function saves the database connection, so if invoke this again, it  gives you the same one, rather than making a second connection.''' 
     global the_database_connection 
     if not the_database_connection: 
      try: 
       the_database_connection = MySQLdb.connect(
        host=dsn['hostname'], 
        user=dsn['username'], 
        passwd=dsn['password'], 
        db=dsn['database']) 
       # so modifications take effect automatically 
       the_database_connection.autocommit(True) 
      except MySQLdb.Error, e: 
       print ("Couldn't connect to database. MySQL error %d: %s" %(e.args[0], e.args[1])) 
     return the_database_connection 
     x=conn.cursor() 
     sql = "select * from persons where address = %s" % addr 
     x.execute(sql) 
     rows = x.fetchall() 
     for row in rows: 
      print row 

if __name__ == "__main__": 
    a = Find(addr = "new street") 
    dsn = { 
    'username': 'xyz', 
    'password': 'xyz', 
    'hostname': 'localhost', 
    'database': 'details' 
    } 
    the_database_connection = False 
    a.connect(dsn)