summaryrefslogtreecommitdiff
path: root/db_proxy.py
diff options
context:
space:
mode:
Diffstat (limited to 'db_proxy.py')
-rw-r--r--db_proxy.py7
1 files changed, 3 insertions, 4 deletions
diff --git a/db_proxy.py b/db_proxy.py
index 9e5273e..8cb3e55 100644
--- a/db_proxy.py
+++ b/db_proxy.py
@@ -12,10 +12,9 @@ __all__ = []
class DBThread(Thread):
- def __init__(self,conn_str):
+ def __init__(self,**kwargs):
Thread.__init__(self)
-# dbconn = ...("dbname='yvesf' user='dbuser' host='localhost' password='dbpass'")
- self.conn = pyPgSQL.PgSQL.connect(conn_str, client_encoding="utf-8", unicode_results=1)
+ self.conn = pyPgSQL.PgSQL.connect(client_encoding="utf-8", unicode_results=1,**kwargs)
self.queue = Queue.Queue()
self.running = True
def run(self):
@@ -61,7 +60,7 @@ if __name__ == "__main__":
logging.basicConfig(level=logging.DEBUG)
print "press ctrl-c to abort"
- db=DBThread("")
+ db=DBThread(database="omegle")
db.start()
try:
db.create_table()