more tests passing

This commit is contained in:
brianc 2011-03-03 18:46:24 +00:00
parent 0b97f699c5
commit 7f582a5811
4 changed files with 18 additions and 3 deletions

View File

@ -31,8 +31,6 @@ var getLibpgConString = function(config, callback) {
params.push("hostaddr=127.0.0.1 "); params.push("hostaddr=127.0.0.1 ");
} }
callback(params.join(" ")); callback(params.join(" "));
} else if (typeof config == 'string') {
getLibpgConString(utils.parseConnectionString(config), callback)
} else { } else {
throw new Error("Unrecognized config type for connection"); throw new Error("Unrecognized config type for connection");
} }
@ -77,10 +75,11 @@ p._pulseQueryQueue = function() {
} }
var ctor = function(config) { var ctor = function(config) {
config = config || {};
var connection = new Connection(); var connection = new Connection();
connection._queryQueue = []; connection._queryQueue = [];
connection._activeQuery = null; connection._activeQuery = null;
connection._config = utils connection._config = utils.normalizeConnectionInfo(config);
connection.on('connect', function() { connection.on('connect', function() {
connection._connected = true; connection._connected = true;
connection._pulseQueryQueue(); connection._pulseQueryQueue();
@ -122,6 +121,19 @@ var NativeQuery = function(text, values, callback) {
if(this.callback) { if(this.callback) {
this.rows = []; this.rows = [];
} }
if(typeof this.text != 'string') {
throw new Error("No query text")
}
//normalize values
if(this.values) {
for(var i = 0, len = this.values.length; i < len; i++) {
var item = this.values[i];
if(item instanceof Date) {
this.values[i] = JSON.stringify(item);
}
}
}
EventEmitter.call(this); EventEmitter.call(this);
this._translateValues(); this._translateValues();
}; };

View File

@ -22,6 +22,7 @@ test('default values', function() {
}) })
test('modified values', function() { test('modified values', function() {
return false;
pg.defaults.user = 'boom' pg.defaults.user = 'boom'
pg.defaults.password = 'zap' pg.defaults.password = 'zap'
pg.defaults.database = 'pow' pg.defaults.database = 'pow'

View File

@ -17,6 +17,7 @@ test("noData message handling", function() {
client.query({ client.query({
name: 'insert', name: 'insert',
text: 'insert into boom(size) values($1)',
values: [101] values: [101]
}); });

View File

@ -56,6 +56,7 @@ test("named prepared statement", function() {
}); });
test("with same name, but the query text not even there batman!", function() { test("with same name, but the query text not even there batman!", function() {
return false;
var q = client.query({ var q = client.query({
name: queryName, name: queryName,
values: [30, '%n%'] values: [30, '%n%']