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

test('api', function() {
  pg.connect(helper.args, assert.calls(function(err, client) {
    assert.equal(err, null, "Failed to connect");

    client.query('CREATE TEMP TABLE band(name varchar(100))');

    ['the flaming lips', 'wolf parade', 'radiohead', 'bright eyes', 'the beach boys', 'dead black hearts'].forEach(function(bandName) {
      var query = client.query("INSERT INTO band (name) VALUES ('"+ bandName +"')")
    });


    test('simple query execution',assert.calls( function() {
      client.query("SELECT * FROM band WHERE name = 'the beach boys'", function(err, result) {
        assert.length(result.rows, 1)
        assert.equal(result.rows.pop().name, 'the beach boys')
      });

    }))

    test('prepared statement execution',assert.calls( function() {
      client.query('SELECT * FROM band WHERE name = $1', ['dead black hearts'],assert.calls( function(err, result) {
        assert.length(result.rows, 1);
        assert.equal(result.rows.pop().name, 'dead black hearts');
      }))

      client.query('SELECT * FROM band WHERE name LIKE $1 ORDER BY name', ['the %'], assert.calls(function(err, result) {
        assert.length(result.rows, 2);
        assert.equal(result.rows.pop().name, 'the flaming lips');
        assert.equal(result.rows.pop().name, 'the beach boys');
      }))
    }))

  }))
})


test('executing nested queries', function() {
  pg.connect(helper.args, assert.calls(function(err, client) {
    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() {
          assert.ok('all queries hit')
        }))
      }))
    }))
  }))
})


test('raises error if cannot connect', function() {
  pg.connect({database:'asdlfkajsdf there is no way this is a real database, right?!'}, assert.calls(function(err, client) {
    assert.ok(err, 'should have raised an error')
  }))
})