Hopiu/django-ddp
1
0
Fork 0
mirror of https://github.com/jazzband/django-ddp.git synced 2026-05-13 01:53:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Connect using psycopg2 directly rather than via django.db.connection.get_new_connection(...) which doesn't do what we want in Django 1.7

Browse source
This commit is contained in:
Tyson Clugg 2015-03-12 16:50:38 +11:00
parent 9ea4ba9b7c
commit 90dc7facab
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
dddp/postgres.py
View file

@ -14,7 +14,8 @@ import gevent.queue
import gevent.select
import psycopg2 # green
from geventwebsocket.logging import create_logger
import psycopg2.extras
import psycopg2
import psycopg2.extensions
class PostgresGreenlet(gevent.Greenlet):
@ -41,8 +42,10 @@ class PostgresGreenlet(gevent.Greenlet):
conn.allow_thread_sharing = True
self.connection = conn
self.conn_params = conn.get_connection_params()
self.conn_params['async'] = True
self.conn = conn.get_new_connection(self.conn_params)
self.conn_params.update(
async=True,
)
self.conn = psycopg2.connect(**self.conn_params)
self.poll() # wait for conneciton to start
self.cur = self.conn.cursor()