Not using connection pool anymore as that does not support transactions

gnewpg · Jan 14, 2013 · 099532b · 099532b
1 parent 102c5ef
commit 099532b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lib/database.js b/lib/database.js
@@ -38,7 +38,8 @@ pgQuery.prototype.handleError = function(err) {
 function getConnection(config, callback) {
 	var schema = config.schema || "public";
 
-	pg.connect(config, function(err, con) {
+	var con = new pg.Client(config);
+	con.connect(function(err) {
 		if(err)
 			return callback(err);
 

diff --git a/lib/keyring.js b/lib/keyring.js
@@ -55,7 +55,7 @@ function initialiseDatabase(dbConfig, callback) {
 				return callback(err);
 
 			structure._createStructure(con, queries, function(err) {
-				//con.end();
+				con.end();
 				callback(err);
 			});
 		});