last-insert-id.js

require('../test')("Last insert id", function (conn, t) {
  if (conn.adapter.name == 'postgres') {
    t.skip("Last insert ID not supported by postgres")
    return t.end()
  }
  if (conn.adapter.name == 'mssql') {
    t.skip("Last insert ID not supported by mssql")
    return t.end()
  }
  t.plan(2)

  conn.query("DROP TABLE last_insert_id_test", function (err) {})
  if (conn.adapter.name == 'sqlite3') {
    conn.query("CREATE TABLE last_insert_id_test (id integer primary key autoincrement, a int)")
  }
  else if (conn.adapter.name == 'mysql') {
    conn.query("CREATE TABLE last_insert_id_test (id integer primary key auto_increment, a int)")
  }
  else {
    throw new Error("Unknown adapter: " + conn.adapter.name)
  }

  conn.query('INSERT INTO last_insert_id_test (a) VALUES (123)', function (err, res) {
    if (err) throw err
    t.equal(res.lastInsertId, 1)

    conn.query('INSERT INTO last_insert_id_test (a) VALUES (456)', function (err, res) {
      if (err) throw err
      t.equal(res.lastInsertId, 2)
    })
  })
})