From 90dc7facab0cc3534b66083c17453396762afe92 Mon Sep 17 00:00:00 2001
From: Tyson Clugg <tyson@clugg.net>
Date: Thu, 12 Mar 2015 16:50:38 +1100
Subject: [PATCH] Connect using psycopg2 directly rather than via
 django.db.connection.get_new_connection(...) which doesn't do what we want in
 Django 1.7

---
 dddp/postgres.py | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/dddp/postgres.py b/dddp/postgres.py
index 5cbbc14..1309e69 100644
--- a/dddp/postgres.py
+++ b/dddp/postgres.py
@@ -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()