type-parser-override-tests.js

var helper = require(__dirname + '/test-helper');

function testTypeParser(client, expectedResult, done) {
  var boolValue = true;
  client.query('CREATE TEMP TABLE parserOverrideTest(id bool)');
  client.query('INSERT INTO parserOverrideTest(id) VALUES ($1)', [boolValue]);
  client.query('SELECT * FROM parserOverrideTest', assert.success(function(result) {
    assert.equal(result.rows[0].id, expectedResult);
    helper.pg.end();
    done();
  }));
}

helper.pg.connect(helper.config, assert.success(function(client1, done1) {
  helper.pg.connect(helper.config, assert.success(function(client2, done2) {
    var boolTypeOID = 16;
    client1.setTypeParser(boolTypeOID, function(){
      return 'first client';
    });
    client2.setTypeParser(boolTypeOID, function(){
      return 'second client';
    });

    client1.setTypeParser(boolTypeOID, 'binary', function(){
      return 'first client binary';
    });
    client2.setTypeParser(boolTypeOID, 'binary', function(){
      return 'second client binary';
    });

    testTypeParser(client1, 'first client', done1);
    testTypeParser(client2, 'second client', done2);
  }));
}));