diff --git a/test/sizing.js b/test/sizing.js index 9e926877..b310b3d3 100644 --- a/test/sizing.js +++ b/test/sizing.js @@ -33,11 +33,17 @@ describe('pool size of 1', () => { it('can only send 1 query at a time', co.wrap(function * () { const pool = new Pool({ max: 1 }) - const queries = _.times(20, (i) => { - return pool.query('SELECT COUNT(*) as counts FROM pg_stat_activity') - }) + + // the query text column name changed in PostgreSQL 9.2 + const versionResult = yield pool.query('SHOW server_version_num') + const version = parseInt(versionResult.rows[0].server_version_num, 10) + const queryColumn = version < 90200 ? 'current_query' : 'query' + + const queryText = 'SELECT COUNT(*) as counts FROM pg_stat_activity WHERE ' + queryColumn + ' = $1' + const queries = _.times(20, () => + pool.query(queryText, [queryText])) const results = yield Promise.all(queries) - const counts = results.map(res => parseInt(res.rows[0].counts), 10) + const counts = results.map(res => parseInt(res.rows[0].counts, 10)) expect(counts).to.eql(_.times(20, i => 1)) return yield pool.end() }))