cartodb/node-postgres
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modified connection info for invalid connection test to use localhost

Browse Source 
in order to avoid long timeouts in dns
This commit is contained in:
brianc 2010-12-24 20:01:11 -06:00
parent 509564f976
commit 28bbbf9087
1 changed files with 25 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
test/integration/client/api-tests.js
View File

@ -2,12 +2,17 @@ var helper = require(__dirname + '/../test-helper');
var pg = require(__dirname + '/../../../lib');
var connectionString = helper.connectionString(__filename);
var log = function() {
//console.log.apply(console, arguments);
}
var sink = new helper.Sink(2, function() {
var sink = new helper.Sink(4, 10000, function() {
log("ending connection pool: %s", connectionString);
pg.end(connectionString);
});
test('api', function() {
log("connecting to %s", connectionString)
pg.connect(connectionString, assert.calls(function(err, client) {
assert.equal(err, null, "Failed to connect: " + sys.inspect(err));
@ -19,20 +24,26 @@ test('api', function() {
test('simple query execution',assert.calls( function() {
client.query("SELECT * FROM band WHERE name = 'the beach boys'", function(err, result) {
log("executing simple query")
client.query("SELECT * FROM band WHERE name = 'the beach boys'", assert.calls(function(err, result) {
assert.length(result.rows, 1)
assert.equal(result.rows.pop().name, 'the beach boys')
});
log("simple query executed")
}));
}))
test('prepared statement execution',assert.calls( function() {
log("executing prepared statement 1")
client.query('SELECT * FROM band WHERE name = $1', ['dead black hearts'],assert.calls( function(err, result) {
log("Prepared statement 1 finished")
assert.length(result.rows, 1);
assert.equal(result.rows.pop().name, 'dead black hearts');
}))
log("executing prepared statement two")
client.query('SELECT * FROM band WHERE name LIKE $1 ORDER BY name', ['the %'], assert.calls(function(err, result) {
log("prepared statement two finished")
assert.length(result.rows, 2);
assert.equal(result.rows.pop().name, 'the flaming lips');
assert.equal(result.rows.pop().name, 'the beach boys');
@ -46,10 +57,12 @@ test('api', function() {
test('executing nested queries', function() {
pg.connect(connectionString, assert.calls(function(err, client) {
assert.isNull(err);
log("connected for nested queriese")
client.query('select now as now from NOW()', assert.calls(function(err, result) {
assert.equal(new Date().getYear(), result.rows[0].now.getYear())
client.query('select now as now_again FROM NOW()', assert.calls(function() {
client.query('select * FROM NOW()', assert.calls(function() {
log('all nested queries recieved')
assert.ok('all queries hit')
sink.add();
}))
@ -59,17 +72,23 @@ test('executing nested queries', function() {
})
test('raises error if cannot connect', function() {
var connectionString = "pg://asdf@seoiasfd:4884/ieieie";
var connectionString = "pg://sfalsdkf:asdf@localhost/ieieie";
log("trying to connect to invalid place for error")
pg.connect(connectionString, assert.calls(function(err, client) {
assert.ok(err, 'should have raised an error')
log("invalid connection supplied error to callback")
sink.add();
}))
})
test("query errors are handled and do not bubble if callbac is provded", function() {
test("query errors are handled and do not bubble if callback is provded", function() {
pg.connect(connectionString, assert.calls(function(err, client) {
assert.isNull(err)
log("checking for query error")
client.query("SELECT OISDJF FROM LEIWLISEJLSE", assert.calls(function(err, result) {
assert.ok(err);
}))
log("query error supplied error to callback")
sink.add();
}))
}))
})