싱글 톤 데이터베이스 연결

Question

DB에 하나의 연결 만 만들려는 경우 "세부 정보"데이터베이스에서 값을 가져 오려고합니다. 연결이 존재하면 새 연결을 만들지 않고 이전 연결을 계속 진행하십시오. 그것을 위해 나는 다음과 같이 시도 :

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 내가 위의 DSN을 정의 할 수있는 방법을 는 ...이 인수 한 정의입니다 걸립니다.

Answer 1

연결 풀을 다시 작성하려고합니다.

불행히도 귀하의 솔루션은 그대로 작동하지 않습니다. 호스트, 포트, 데이터베이스, 사용자 이름, 암호 등의 모든 연결 매개 변수가 정확히 동일 할 때만 동일한 연결을 사용할 수 있습니다. 귀하의 경우, 어떤 경우에도 동일한 연결을 반환하고 이것은 단순히 잘못된 것입니다 - 속성이 다른 경우 새 연결을 만들어야합니다.

대신 기존 연결 풀링 라이브러리 중 하나 (예 : pysqlpool 또는 DBUtils)를 사용하십시오 (다른 것들이있을 것입니다).

Answer 2

필요에 따라 dsn 정보를 a.connect 함수에 제공하지 않았습니다. dsn 정보를 클래스에서 빼내 주 기능의 일부로 만드십시오. 그런 다음 a.connect의 인수로 다시 피드하십시오. 그래서 같이 : 당신은 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)