db_test.go

// Copyright 2014 Square Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package squalor

import (
	"context"
	"database/sql"
	"database/sql/driver"
	"errors"
	"fmt"
	"math/rand"
	"reflect"
	"strconv"
	"strings"
	"testing"
	"time"

	"github.com/coopernurse/gorp"
	"github.com/opentracing/opentracing-go"
	"github.com/opentracing/opentracing-go/mocktracer"
)

const objectsDDL = `
CREATE TABLE objects (
  user_id     BIGINT         NOT NULL,
  object_id   VARBINARY(767) NOT NULL,
  value       BLOB           NULL,
  timestamp   BIGINT         NULL,
  PRIMARY KEY (user_id, object_id),
  INDEX (user_id, timestamp)
)`

const objectsDDLWithUnmappedColumns = `
CREATE TABLE objects (
  user_id     BIGINT         NOT NULL,
  object_id   VARBINARY(767) NOT NULL,
  value       BLOB           NULL,
  timestamp   BIGINT         NULL,
  unmapped    VARBINARY(767) NULL,
  PRIMARY KEY (user_id, object_id),
  INDEX (user_id, timestamp)
)`

const objectsDDLAddUnmappedColumns = `
ALTER TABLE objects ADD COLUMN (
  unmapped VARBINARY(767) NULL
)`

const objectsDDLWithMissingColumn = `
CREATE TABLE objects (
  user_id     BIGINT         NOT NULL,
  object_id   VARBINARY(767) NOT NULL,
  timestamp   BIGINT         NULL,
  PRIMARY KEY (user_id, object_id),
  INDEX (user_id, timestamp)
)`

const objectsDDLWithoutPrimaryKey = `
CREATE TABLE objects (
  user_id     BIGINT         NOT NULL,
  object_id   VARBINARY(767) NOT NULL,
  value       BLOB           NULL,
  timestamp   BIGINT         NULL,
  INDEX (user_id, timestamp)
)`

const usersDDL = `
CREATE TABLE users (
  id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY,
  name VARCHAR(255) NOT NULL,
  age  BIGINT       NULL
)`

func TestDB_WithoutUnmappedColumns(t *testing.T) {
	db := makeTestDB(t, objectsDDL)
	defer db.Close()

	testDB(db, t)
}

func TestDB_WithUnmappedColumnsIgnored(t *testing.T) {
	db := makeTestDB(t, objectsDDLWithUnmappedColumns)
	defer db.Close()

	testDB(db, t)
}

func testDB(db *DB, t *testing.T) {
	type BaseModel struct {
		UserID    int64  `db:"user_id"`
		ID        string `db:"object_id"`
		Timestamp *int64 `db:"timestamp"`
	}

	type Object struct {
		BaseModel
		Value []byte `db:"value"`
	}

	items, err := db.BindModel("objects", Object{})
	if err != nil {
		t.Fatal(err)
	}

	i := &Object{}
	if err := db.Get(i, 1, "bar"); err == nil {
		t.Fatal("Expected error, but found success")
	}

	// Insert.
	i.UserID = 1
	i.ID = "bar"
	i.Value = []byte("hello world")
	// Non-pointer should fail.
	if err := db.Insert(*i); err == nil {
		t.Fatal("Expected error, but found success")
	}
	// Pointer should succeed.
	if err := db.Insert(i); err != nil {
		t.Fatal(err)
	}
	// Duplicate entry should fail
	if err := db.Insert(i); err == nil {
		t.Fatal("Expected err, but found success")
	}
	j := &Object{}
	// Non-pointer should fail.
	if err := db.Get(*j, 1, "bar"); err == nil {
		t.Fatal("Expected error, but found success")
	}
	// Pointer should succeed.
	if err := db.Get(j, 1, "bar"); err != nil {
		t.Fatal(err)
	}
	if !reflect.DeepEqual(i, j) {
		t.Fatalf("Expected %+v, but got %+v", i, j)
	}
	if j.Timestamp != nil {
		t.Fatalf("Expected nil, but got %+v", j.Timestamp)
	}

	// Update.
	i.Value = nil
	timestamp := int64(42)
	i.Timestamp = &timestamp
	// Non-pointer should fail.
	if _, err := db.Update(*i); err == nil {
		t.Fatal("Expected error, but found success")
	}
	// Pointer should succeed.
	if n, err := db.Update(i); err != nil {
		t.Fatal(err)
	} else if n != 1 {
		t.Fatalf("Expected 1 update, but got %d", n)
	}

	if err := db.Get(j, 1, "bar"); err != nil {
		t.Fatal(err)
	}
	if !reflect.DeepEqual(i, j) {
		t.Fatalf("Expected %+v, but got %+v", i, j)
	}
	if j.Value != nil {
		t.Fatalf("Expected nil, but got %+v", j.Value)
	}
	if *j.Timestamp != 42 {
		t.Fatalf("Expected 42, but got %+v", *j.Timestamp)
	}

	// Upsert.
	i2 := &Object{}
	i2.UserID = 2
	i2.ID = "bar"
	i2.Value = []byte("greetings")

	i.Value = []byte("hello again")
	// Non-pointer should fail.
	if err := db.Upsert(*i, *i2); err == nil {
		t.Fatal("Expected error, but found success")
	}
	// Pointer should succeed.
	if err := db.Upsert(i, i2); err != nil {
		t.Fatal(err)
	}

	if err := db.Get(j, 1, "bar"); err != nil {
		t.Fatal(err)
	}
	if !reflect.DeepEqual(i, j) {
		t.Fatalf("Expected %+v, but got %+v", i, j)
	}

	// Replace.
	i.Value = []byte("goodbye again")
	i2.Value = []byte("fairwell")
	// Non-pointer should fail.
	if err := db.Replace(*i, *i2); err == nil {
		t.Fatal("Expected error, but found success")
	}
	// Pointer should succeed.
	if err := db.Replace(i, i2); err != nil {
		t.Fatal(err)
	}

	if err := db.Get(j, 1, "bar"); err != nil {
		t.Fatal(err)
	}
	if !reflect.DeepEqual(i, j) {
		t.Fatalf("Expected %+v, but got %+v", i, j)
	}

	{
		// Select into a slice of structs.
		var results []Object
		q := items.Select("*").Where(items.C("user_id").Eq(1))
		if err := db.Select(&results, q); err != nil {
			t.Fatal(err)
		} else if len(results) != 1 {
			t.Fatalf("Expected 1 result, but got %d", len(results))
		} else if !reflect.DeepEqual(*i, results[0]) {
			t.Fatalf("Expected %+v, but got %+v", *i, results[0])
		}
	}

	{
		// Select into a slice of pointers to structs.
		var results []*Object
		q := items.Select("*").Where(items.C("user_id").Eq(2))
		if err := db.Select(&results, q); err != nil {
			t.Fatal(err)
		} else if len(results) != 1 {
			t.Fatalf("Expected 1 result, but got %d", len(results))
		} else if !reflect.DeepEqual(i2, results[0]) {
			t.Fatalf("Expected %+v, but got %+v", i2, results[0])
		}
	}

	{
		// QueryRow.
		q := items.Select("*").Where(items.C("user_id").Eq(1))
		if err := db.QueryRow(q).StructScan(j); err != nil {
			t.Fatal(err)
		} else if !reflect.DeepEqual(i, j) {
			t.Fatalf("Expected %+v, but got %+v", i, j)
		}
	}

	{
		// QueryRow with no matches.
		q := items.Select("*").Where(items.C("user_id").Eq(3))
		if err := db.QueryRow(q).StructScan(j); err != sql.ErrNoRows {
			t.Fatal("Expected failure, but found success")
		}
	}

	// QueryRow with more than one match.
	if err := db.QueryRow(items.Select("*")).StructScan(j); err != nil {
		t.Fatalf("Expected success, but found %s", err)
	}

	{
		// Select into an unregistered struct.
		count := &struct {
			N int `db:"total"`
		}{}
		q := items.Select(items.C("user_id").Count().As("total"))
		if err := db.QueryRow(q).StructScan(count); err != nil {
			t.Fatal(err)
		} else if count.N != 2 {
			t.Fatalf("Expected count of %d, but got %d", 2, count.N)
		}
	}

	{
		// Select into an int.
		var count int
		q := items.Select(items.C("user_id").Count())
		if err := db.QueryRow(q).Scan(&count); err != nil {
			t.Fatal(err)
		} else if count != 2 {
			t.Fatalf("Expected count of %d, but got %d", 2, count)
		}
	}

	{
		// Select into non-struct slice.
		var userIDs []int64
		q := items.Select(items.C("user_id"))
		if err := db.Select(&userIDs, q); err != nil {
			t.Fatal(err)
		} else if len(userIDs) != 2 {
			t.Fatalf("Expected count of %d, but got %d", 2, len(userIDs))
		}
		expected := []int64{1, 2}
		if !reflect.DeepEqual(expected, userIDs) {
			t.Fatalf("Expected %+v, but %+v", expected, userIDs)
		}
	}

	{
		// Select into non-struct slice.
		var userIDs []*int64
		q := items.Select(items.C("user_id"))
		if err := db.Select(&userIDs, q); err != nil {
			t.Fatal(err)
		} else if len(userIDs) != 2 {
			t.Fatalf("Expected count of %d, but got %d", 2, len(userIDs))
		}
		vals := []int64{1, 2}
		expected := []*int64{&vals[0], &vals[1]}
		if !reflect.DeepEqual(expected, userIDs) {
			t.Fatalf("Expected %+v, but %+v", expected, userIDs)
		}
	}

	// Non-pointer should fail.
	if _, err := db.Delete(*i); err == nil {
		t.Fatal("Expected error, but found success")
	}
	// Pointer should succeed.
	if n, err := db.Delete(i); err != nil {
		t.Fatal(err)
	} else if n != 1 {
		t.Fatalf("Expected 1 delete, but got %d", n)
	}
	if err := db.Get(i, "foo", "bar"); err == nil {
		t.Fatal("Expected error, but found success")
	}
}

type User struct {
	ID   uint64 `db:"id"`
	Name string `db:"name"`
	Age  int    `db:"age"`
}

func TestDBAutoIncrement(t *testing.T) {
	db := makeTestDB(t, usersDDL)
	defer db.Close()

	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	// Auto-increment ids start at 1.
	e := &User{ID: 0, Name: "one"}
	if err := db.Insert(e); err != nil {
		t.Fatal(err)
	}
	if e.ID != 1 {
		t.Fatalf("Expected ID of 1, but got %d", e.ID)
	}

	// An auto-increment column can be manually specified.
	e.ID = 3
	e.Name = "three"
	if err := db.Insert(e); err != nil {
		t.Fatal(err)
	}
	if e.ID != 3 {
		t.Fatalf("Expected ID of 3, but got %d", e.ID)
	}

	// Insert multiple entries at once.
	e4 := &User{Name: "four"}
	e5 := &User{Name: "five"}
	e6 := &User{Name: "size"}
	if err := db.Insert(e4, e5, e6); err != nil {
		t.Fatal(err)
	}
	for i, e := range []*User{e4, e5, e6} {
		if e.ID != uint64(i+4) {
			t.Fatalf("Expected ID of %d, but got %d", i+4, e.ID)
		}
	}

	if n, err := db.Delete(e4, e5, e6); err != nil {
		t.Fatal(err)
	} else if n != 3 {
		t.Fatalf("Expected 3, but got %d", n)
	}

	// Insert multiple entries with auto-increment values at once.
	e7 := &User{ID: 7, Name: "seven"}
	e8 := &User{ID: 8, Name: "eight"}
	e9 := &User{ID: 9, Name: "nine"}
	if err := db.Insert(e7, e8, e9); err != nil {
		t.Fatal(err)
	}
	for i, e := range []*User{e7, e8, e9} {
		if e.ID != uint64(i+7) {
			t.Fatalf("Expected ID of %d, but got %d", i+7, e.ID)
		}
	}

	// Insert multiple entries with mismatching auto-increment value presence.
	e10 := &User{ID: 10, Name: "seven"}
	e11 := &User{Name: "eight"}
	if err := db.Insert(e10, e11); err == nil {
		t.Fatal("Expected error, but found success")
	}
}

func TestDBBatch(t *testing.T) {
	db := makeTestDB(t, objectsDDL, usersDDL)
	defer db.Close()

	if _, err := db.BindModel("objects", Object{}); err != nil {
		t.Fatal(err)
	}
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	i := &Object{UserID: 1, ID: "bar", Value: "insert"}
	e := &User{ID: 0, Name: "insert"}
	if err := db.Insert(i, e); err != nil {
		t.Fatal(err)
	}

	checkObjects := func() {
		i2 := &Object{}
		if err := db.Get(i2, 1, "bar"); err != nil {
			t.Fatal(err)
		} else if !reflect.DeepEqual(i, i2) {
			t.Fatalf("Expected %+v, but got %+v", i, i2)
		}
		e2 := &User{}
		if err := db.Get(e2, e.ID); err != nil {
			t.Fatal(err)
		} else if !reflect.DeepEqual(e, e2) {
			t.Fatalf("Expected %+v, but got %+v", e, e2)
		}
	}
	checkObjects()

	i.Value = "replace"
	e.Name = "replace"
	if err := db.Replace(i, e); err != nil {
		t.Fatal(err)
	}
	checkObjects()

	i.Value = "update"
	e.Name = "update"
	if count, err := db.Update(i, e); err != nil {
		t.Fatal(err)
	} else if count != 2 {
		t.Fatalf("Expected count of %d, but got %d", 2, count)
	}
	checkObjects()

	i.Value = "upsert"
	e.Name = "upsert"
	if err := db.Upsert(i, e); err != nil {
		t.Fatal(err)
	}
	checkObjects()

	if count, err := db.Delete(i, e); err != nil {
		t.Fatal(err)
	} else if count != 2 {
		t.Fatalf("Expected count of %d, but got %d", 2, count)
	}
	if err := db.Get(i, "foo", "bar"); err == nil {
		t.Fatal("Expected error, but found success")
	}
	if err := db.Get(e, e.ID); err == nil {
		t.Fatal("Expected error, but found success")
	}
}

type HookedObject struct {
	UserID      int64  `db:"user_id"`
	ID          string `db:"object_id"`
	Timestamp   int64  `db:"timestamp"`
	Value       string `db:"value"`
	preDelete   func(Executor) error
	postDelete  func(Executor) error
	postGet     func(Executor) error
	preInsert   func(Executor) error
	postInsert  func(Executor) error
	preReplace  func(Executor) error
	postReplace func(Executor) error
	preUpdate   func(Executor) error
	postUpdate  func(Executor) error
	preUpsert   func(Executor) error
	postUpsert  func(Executor) error
}

func (h *HookedObject) PreDelete(exec Executor) error {
	return h.preDelete(exec)
}
func (h *HookedObject) PostDelete(exec Executor) error {
	return h.postDelete(exec)
}
func (h *HookedObject) PostGet(exec Executor) error {
	return h.postGet(exec)
}
func (h *HookedObject) PreInsert(exec Executor) error {
	return h.preInsert(exec)
}
func (h *HookedObject) PostInsert(exec Executor) error {
	return h.postInsert(exec)
}
func (h *HookedObject) PreReplace(exec Executor) error {
	return h.preReplace(exec)
}
func (h *HookedObject) PostReplace(exec Executor) error {
	return h.postReplace(exec)
}
func (h *HookedObject) PreUpdate(exec Executor) error {
	return h.preUpdate(exec)
}
func (h *HookedObject) PostUpdate(exec Executor) error {
	return h.postUpdate(exec)
}
func (h *HookedObject) PreUpsert(exec Executor) error {
	return h.preUpsert(exec)
}
func (h *HookedObject) PostUpsert(exec Executor) error {
	return h.postUpsert(exec)
}

func TestDBHooks(t *testing.T) {
	db := makeTestDB(t, objectsDDL)
	defer db.Close()

	if _, err := db.BindModel("objects", HookedObject{}); err != nil {
		t.Fatal(err)
	}

	counts := map[string]int{}

	makeCountingHook := func(name string) func(Executor) error {
		return func(Executor) error {
			counts[name]++
			return nil
		}
	}

	checkAndClearCounts := func(expected map[string]int) {
		if !reflect.DeepEqual(expected, counts) {
			t.Errorf("Expected %+v, but got %+v", expected, counts)
		}
		for k := range counts {
			delete(counts, k)
		}
	}

	i := &HookedObject{
		UserID:      1,
		ID:          "bar",
		Value:       "hello world",
		preDelete:   makeCountingHook("preDelete"),
		postDelete:  makeCountingHook("postDelete"),
		postGet:     makeCountingHook("postGet"),
		preInsert:   makeCountingHook("preInsert"),
		postInsert:  makeCountingHook("postInsert"),
		preReplace:  makeCountingHook("preReplace"),
		postReplace: makeCountingHook("postReplace"),
		preUpdate:   makeCountingHook("preUpdate"),
		postUpdate:  makeCountingHook("postUpdate"),
		preUpsert:   makeCountingHook("preUpsert"),
		postUpsert:  makeCountingHook("postUpsert"),
	}

	if err := db.Insert(i); err != nil {
		t.Fatal(err)
	}
	checkAndClearCounts(map[string]int{
		"preInsert":  1,
		"postInsert": 1,
	})

	if err := db.Replace(i); err != nil {
		t.Fatal(err)
	}
	checkAndClearCounts(map[string]int{
		"preReplace":  1,
		"postReplace": 1,
	})

	if _, err := db.Update(i); err != nil {
		t.Fatal(err)
	}
	checkAndClearCounts(map[string]int{
		"preUpdate":  1,
		"postUpdate": 1,
	})

	if err := db.Upsert(i); err != nil {
		t.Fatal(err)
	}
	checkAndClearCounts(map[string]int{
		"preUpsert":  1,
		"postUpsert": 1,
	})

	if err := db.Get(i, 1, "bar"); err != nil {
		t.Fatal(err)
	}
	checkAndClearCounts(map[string]int{
		"postGet": 1,
	})

	if _, err := db.Delete(i); err != nil {
		t.Fatal(err)
	}
	checkAndClearCounts(map[string]int{
		"preDelete":  1,
		"postDelete": 1,
	})
}

func TestDBAllowStringQueries(t *testing.T) {
	db := makeTestDB(t, objectsDDL)
	defer db.Close()
	db.AllowStringQueries = false

	items, err := db.BindModel("objects", Object{})
	if err != nil {
		t.Fatal(err)
	}

	i := &Object{UserID: 1, ID: "bar", Value: "hello world"}
	if err := db.Insert(i); err != nil {
		t.Fatal(err)
	}

	// Programmatic queries should succeed.
	var results []Object
	if err := db.Select(&results, items.Select("*")); err != nil {
		t.Fatalf("Expected success, but got %s", err)
	}

	// String queries should fail.
	if err := db.Select(&results, "SELECT * FROM item"); err == nil {
		t.Fatal("Expected error, but found success")
	}
}

func TestBindModel_FailUnknownColumns(t *testing.T) {
	db := makeTestDB(t, objectsDDLWithUnmappedColumns)
	db.IgnoreUnmappedCols = false
	defer db.Close()

	defer func() {
		r := recover()
		if r == nil {
			t.Fatal("Expected to recover an error")
		}
		str := "field 'unmapped' has no mapping"
		if !strings.Contains(r.(error).Error(), str) {
			t.Fatalf("Expected error to contain \"%s\", but got \"%s\"", str, r)
		}
	}()

	db.BindModel("objects", Object{})
	t.Fatal("Expected panic. Should not reach here")
}

func TestBindModel_FailMissingColumn(t *testing.T) {
	db := makeTestDB(t, objectsDDLWithMissingColumn)
	db.IgnoreMissingCols = false
	defer db.Close()

	defer func() {
		r := recover()
		if r == nil {
			t.Fatal("Expected to recover an error")
		}
		str := "model fields 'value' have no corresponding db field"
		if !strings.Contains(r.(error).Error(), str) {
			t.Fatalf("Expected error to contain \"%s\", but got \"%s\"", str, r)
		}
	}()

	db.BindModel("objects", Object{})
	t.Fatal("Expected panic. Should not reach here")
}

func TestBindModel_DoNotFailMissingColumnWhenIgnored(t *testing.T) {
	db := makeTestDB(t, objectsDDLWithMissingColumn)
	db.IgnoreMissingCols = true
	defer db.Close()

	db.BindModel("objects", Object{})
}

func TestBindModel_FailNoPrimaryKey(t *testing.T) {
	db := makeTestDB(t, objectsDDLWithoutPrimaryKey)
	defer db.Close()

	_, err := db.BindModel("objects", Object{})
	str := "objects: table has no primary key"
	if err == nil {
		t.Fatal("Expected missing primary key error, but got nil")
	} else if err.Error() != str {
		t.Fatalf("Unexpected error `%s`, expected `%s`", err, str)
	}
}

func TestSelect_FailOnUnknownColumns(t *testing.T) {
	db := makeTestDB(t, objectsDDL)
	db.IgnoreUnmappedCols = false
	defer db.Close()

	items, err := db.BindModel("objects", Object{})
	if err != nil {
		t.Fatal(err)
	}

	i := &Object{UserID: 1, ID: "bar", Value: "hello world"}
	if err = db.Insert(i); err != nil {
		t.Fatal(err)
	}

	db.Exec(objectsDDLAddUnmappedColumns)

	var results []Object
	err = db.Select(&results, items.Select("*"))
	if err == nil {
		t.Fatalf("Expected error, but got %+v", results)
	}
	str := "unable to find mapping for column 'unmapped'"
	if !strings.Contains(err.Error(), str) {
		t.Fatalf("Expected error to contain \"%s\", but got \"%s\"", str, err)
	}
}

func TestStructScan_FailOnUnknownColumns(t *testing.T) {
	db := makeTestDB(t, objectsDDL)
	db.IgnoreUnmappedCols = false
	defer db.Close()

	items, err := db.BindModel("objects", Object{})
	if err != nil {
		t.Fatal(err)
	}

	i := &Object{UserID: 1, ID: "bar", Value: "hello world"}
	if err = db.Insert(i); err != nil {
		t.Fatal(err)
	}

	db.Exec(objectsDDLAddUnmappedColumns)

	j := &Object{}
	q := items.Select("*").Where(items.C("user_id").Eq(1))
	err = db.QueryRow(q).StructScan(j)
	if err == nil {
		t.Fatalf("Expected error, but got %+v", j)
	}
	str := "unable to find mapping for column 'unmapped'"
	if !strings.Contains(err.Error(), str) {
		t.Fatalf("Expected error to contain \"%s\", but got \"%s\"", str, err)
	}
}

func TestCommitHooks_Normal(t *testing.T) {
	db := makeTestDB(t, usersDDL)
	defer db.Close()

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}

	// Add hooks
	var pre, post int
	tx.AddPreCommitHook(func(*Tx) error { pre += 7; return nil })
	tx.AddPostCommitHook(func(error) { post += 11 })

	// Commit
	if err := tx.Commit(); err != nil {
		t.Fatal(err)
	}

	// Check
	if pre != 7 {
		t.Errorf("incorrect pre count: expecting %d, found %d", 7, pre)
	}
	if post != 11 {
		t.Errorf("incorrect post count: expecting %d, found %d", 11, post)
	}
}

func TestCommitHooks_NormalWithTransactionBlock(t *testing.T) {
	db := makeTestDB(t, usersDDL)

	defer db.Close()

	var pre, post int

	if err := db.Transaction(func(tx *Tx) error {
		tx.AddPreCommitHook(func(*Tx) error { pre += 7; return nil })
		tx.AddPostCommitHook(func(error) { post += 11 })

		return nil
	}); err != nil {
		t.Fatal(err)
	}

	if pre != 7 {
		t.Errorf("incorrect pre count: expecting %d, found %d", 7, pre)
	}

	if post != 11 {
		t.Errorf("incorrect post count: expecting %d, found %d", 11, post)
	}
}

func TestCommitHooks_PreFails(t *testing.T) {
	db := makeTestDB(t, usersDDL)
	defer db.Close()

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}

	// Add hooks
	tx.AddPreCommitHook(func(*Tx) error { return errors.New("oh no!") })

	// Commit
	err = tx.Commit()
	if err == nil {
		t.Fatal("expected Commit to fail, instead it succeeded")
	}
	if err.Error() != "oh no!" {
		t.Fatalf("expected err to be 'oh no!', was: %s", err)
	}
}

func TestCommitHooks_PreFailsWithTransactionBlock(t *testing.T) {
	db := makeTestDB(t, usersDDL)

	defer db.Close()

	expectedError := "oh no"

	if err := db.Transaction(func(tx *Tx) error {
		tx.AddPreCommitHook(func(*Tx) error { return errors.New("oh no") })

		return nil
	}); err == nil || err.Error() != expectedError {
		t.Fatalf("Expected err to be '%v', go: %v", expectedError, err)
	}
}

type TestLogger struct {
	t         *testing.T
	count     int
	lastQuery string
}

func (l *TestLogger) Log(ctx context.Context, query Serializer, exec Executor, executionTime time.Duration, err error) {
	if ctx.Value("user_id") != "123" {
		l.t.Fatalf("Expected context with user_id 123")
	}
	l.count++
	queryStr, _ := Serialize(query)
	l.lastQuery = queryStr
}

func TestWithContext(t *testing.T) {
	logger := &TestLogger{
		t:     t,
		count: 0,
	}

	db := makeTestDBWithOptions(t, []DBOption{SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	ctx := context.Background()
	ctx = context.WithValue(ctx, "user_id", "123")

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}

	// This should trigger a call to the TestLogger.
	tx.WithContext(ctx).Query("SELECT * from objects")

	if logger.count != 1 {
		t.Fatal("Expected one call to TestLogger.Log")
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}
}

func TestWithContextDoesNotMutate(t *testing.T) {
	ctx := context.Background()
	ctx = context.WithValue(ctx, "user_id", "123")

	db := makeTestDB(t, usersDDL)
	defer db.Close()

	if db.Context() == nil {
		t.Fatal("Expected default non-nil Context on DB")
	}

	dbWithContext := db.WithContext(ctx)
	if db.Context().Value("user_id") != nil {
		t.Fatal("Do not expect .WithContext() to mutate the DB instance")
	}
	if dbWithContext.Context().Value("user_id") != "123" {
		t.Fatal("Expect .WithContext() to return a new DB instance with the context")
	}

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}
	if tx.Context() == nil {
		t.Fatal("Expected default non-nil Context on TX")
	}

	txWithContext := tx.WithContext(ctx)
	if tx.Context().Value("user_id") != nil {
		t.Fatal("Do not expect .WithContext() to mutate the TX instance")
	}
	if txWithContext.Context().Value("user_id") != "123" {
		t.Fatal("Expect .WithContext() to return a new TX instance with the context")
	}
}

func TestWithPerconaDeadline(t *testing.T) {
	logger := &TestLogger{}
	db := makeTestDBWithOptions(t, []DBOption{QueryDeadlinePercona56, SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	now := time.Now()
	later := now.Add(time.Duration(10 * time.Second))

	ctx := context.Background()
	ctx = context.WithValue(ctx, "user_id", "123")

	var cancel func()
	ctx, cancel = context.WithDeadline(ctx, later)
	defer cancel()

	db = db.WithContext(ctx).(*DB)
	if dbDeadline, _ := db.Context().Deadline(); dbDeadline != later {
		t.Fatalf("Expected db.GetContext.Deadline() to return %v, got %v", later, dbDeadline)
	}

	// Test tx.Query
	logger.lastQuery = ""

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}
	if txDeadline, _ := tx.Context().Deadline(); txDeadline != later {
		t.Fatalf("Expected tx.GetContext.Deadline() to return %v, got %v", later, txDeadline)
	}

	tx.Query("SELECT * from objects")

	if !strings.HasPrefix(logger.lastQuery, "SET STATEMENT max_statement_time=") ||
		!strings.HasSuffix(logger.lastQuery, " FOR SELECT * from objects") {
		t.Fatalf("Expected %q, got %q", "SET STATEMENT max_statement_time=? FOR SELECT * from objects", logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}

	// Test db.Query
	logger.lastQuery = ""

	db.Query("SELECT * from objects")

	if !strings.HasPrefix(logger.lastQuery, "SET STATEMENT max_statement_time=") ||
		!strings.HasSuffix(logger.lastQuery, " FOR SELECT * from objects") {
		t.Fatalf("Expected %q, got %q", "SET STATEMENT max_statement_time=? FOR SELECT * from objects", logger.lastQuery)
	}

	// Test tx.QueryRow
	logger.lastQuery = ""

	tx, err = db.Begin()
	if err != nil {
		t.Fatal(err)
	}
	if txDeadline, _ := tx.Context().Deadline(); txDeadline != later {
		t.Fatalf("Expected tx.GetContext.Deadline() to return %v, got %v", later, txDeadline)
	}

	tx.QueryRow("SELECT * from objects LIMIT 1")

	if !strings.HasPrefix(logger.lastQuery, "SET STATEMENT max_statement_time=") ||
		!strings.HasSuffix(logger.lastQuery, " FOR SELECT * from objects LIMIT 1") {
		t.Fatalf("Expected %q, got %q", "SET STATEMENT max_statement_time=? FOR SELECT * from objects LIMIT 1", logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}

	// Test db.QueryRow
	logger.lastQuery = ""

	db.QueryRow("SELECT * from objects LIMIT 1")

	if !strings.HasPrefix(logger.lastQuery, "SET STATEMENT max_statement_time=") ||
		!strings.HasSuffix(logger.lastQuery, " FOR SELECT * from objects LIMIT 1") {
		t.Fatalf("Expected %q, got %q", "SET STATEMENT max_statement_time=? FOR SELECT * from objects LIMIT 1", logger.lastQuery)
	}

	// Test nested queries
	logger.lastQuery = ""

	db.QueryRow("(SELECT * FROM objects ORDER BY ID ASC LIMIT 1) UNION (SELECT * FROM objects ORDER BY id DESC LIMIT 1)")

	if !strings.HasPrefix(logger.lastQuery, "SET STATEMENT max_statement_time=") ||
		!strings.HasSuffix(logger.lastQuery, " (SELECT * FROM objects ORDER BY ID ASC LIMIT 1) UNION (SELECT * FROM objects ORDER BY id DESC LIMIT 1)") {
		t.Fatalf("Expected %q, got %q", "SET STATEMENT max_statement_time=? FOR (SELECT * FROM objects ORDER BY ID ASC LIMIT 1) UNION (SELECT * FROM objects ORDER BY id DESC LIMIT 1)", logger.lastQuery)
	}
}

func TestTransactionBlock(t *testing.T) {
	db := makeTestDB(t, usersDDL)

	defer db.Close()

	if err := db.Transaction(func(tx *Tx) error {
		_, err := tx.Exec("SELECT * from users")

		return err
	}); err != nil {
		t.Fatal(err)
	}

	expectedError := "Error 1146 (42S02): Table 'squalor_test.objects' doesn't exist"

	if err := db.Transaction(func(tx *Tx) error {
		_, err := tx.Exec("SELECT * from objects")

		return err
	}); err == nil || err.Error() != expectedError {
		t.Fatalf("Expected %v error, got: %v", expectedError, err)
	}
}

func TestTransactionBlockFailsOnDuplicatePrimaryKeyUpdate(t *testing.T) {
	db := makeTestDB(t, usersDDL)

	defer db.Close()

	if _, err := db.BindModel("users", &User{}); err != nil {
		t.Fatal(err.Error())
	}

	u1 := &User{Name: "Great Name", Age: 100}
	u2 := &User{Name: "Other Great Name", Age: 102}

	if err := db.Insert(u1, u2); err != nil {
		t.Fatal(err.Error())
	}

	expectedError := fmt.Sprintf("Error 1062 (23000): Duplicate entry '%v' for key 'users.PRIMARY'", u2.ID)

	if err := db.Transaction(func(tx *Tx) error {
		_, err := db.Exec(fmt.Sprintf("UPDATE `users` SET id = %v WHERE `id` = %v", u2.ID, u1.ID))

		return err
	}); err == nil || err.Error() != expectedError {
		t.Fatalf("Expected %v error, got: %v", expectedError, err)
	}
}

func TestTransactionBlockRecoversFromPanic(t *testing.T) {
	db := makeTestDB(t, usersDDL)

	defer db.Close()

	expectedError := "Something went wrong!"

	if err := db.Transaction(func(tx *Tx) error {
		panic("Something went wrong!")

		return nil
	}); err == nil || err.Error() != expectedError {
		t.Fatalf("Expected %v error, got: %v", expectedError, err)
	}
}

func TestWithMySql57Deadline(t *testing.T) {
	logger := &TestLogger{}
	db := makeTestDBWithOptions(t, []DBOption{QueryDeadlineMySQL57, SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	now := time.Now()
	later := now.Add(time.Duration(10 * time.Second))

	ctx := context.Background()
	ctx = context.WithValue(ctx, "user_id", "123")

	var cancel func()
	ctx, cancel = context.WithDeadline(ctx, later)
	defer cancel()

	db = db.WithContext(ctx).(*DB)
	if dbDeadline, _ := db.Context().Deadline(); dbDeadline != later {
		t.Fatalf("Expected db.GetContext.Deadline() to return %v, got %v", later, dbDeadline)
	}

	// Test tx.Query
	logger.lastQuery = ""

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}
	if txDeadline, _ := tx.Context().Deadline(); txDeadline != later {
		t.Fatalf("Expected tx.GetContext.Deadline() to return %v, got %v", later, txDeadline)
	}

	tx.Query("SELECT * from objects")

	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * from objects") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) */ * from objects", logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}

	// Test db.Query
	logger.lastQuery = ""

	db.Query("SELECT * from objects")
	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * from objects") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) */ * from objects", logger.lastQuery)
	}

	// Test tx.QueryRow
	logger.lastQuery = ""

	tx, err = db.Begin()
	if err != nil {
		t.Fatal(err)
	}
	if txDeadline, _ := tx.Context().Deadline(); txDeadline != later {
		t.Fatalf("Expected tx.GetContext.Deadline() to return %v, got %v", later, txDeadline)
	}

	tx.QueryRow("SELECT * from objects LIMIT 1")

	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * from objects LIMIT 1") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) */ * from objects LIMIT 1", logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}

	// Test db.QueryRow
	logger.lastQuery = ""

	db.QueryRow("SELECT * from objects LIMIT 1")

	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * from objects LIMIT 1") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) */ * from objects LIMIT 1", logger.lastQuery)
	}

	// Test nested queries
	logger.lastQuery = ""

	db.QueryRow("(SELECT * FROM objects ORDER BY ID ASC LIMIT 1) UNION (SELECT * FROM objects ORDER BY id DESC LIMIT 1)")

	if !strings.HasPrefix(logger.lastQuery, "(SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * FROM objects ORDER BY ID ASC LIMIT 1) UNION (SELECT * FROM objects ORDER BY id DESC LIMIT 1)") {
		t.Fatalf("Expected %q, got %q", "(SELECT /*+ MAX_EXECUTION_TIME(?) */ FROM objects ORDER BY ID ASC LIMIT 1) UNION (SELECT * FROM objects ORDER BY id DESC LIMIT 1)", logger.lastQuery)
	}

	// Test with white space
	logger.lastQuery = ""

	db.QueryRow(`
     SELECT * from objects LIMIT 1`)

	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * from objects LIMIT 1") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) */ * from objects LIMIT 1", logger.lastQuery)
	}

	// Test query that already has an optimizer hint
	logger.lastQuery = ""

	db.QueryRow(`SELECT /*+ NO_RANGE_OPTIMIZATION(objects) */ * from objects LIMIT 1`)

	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") NO_RANGE_OPTIMIZATION(objects) */ * from objects LIMIT 1") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) NO_RANGE_OPTIMIZATION(objects) */ * from objects LIMIT 1", logger.lastQuery)
	}
}

func TestWithMySql57DefaultDeadline(t *testing.T) {
	logger := &TestLogger{}
	db := makeTestDBWithOptions(t, []DBOption{QueryDeadlineMySQL57, QueryDeadlineDefault(time.Minute), SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	ctx := context.Background()
	ctx = context.WithValue(ctx, "user_id", "123")

	db = db.WithContext(ctx).(*DB)

	logger.lastQuery = ""

	db.Query("SELECT * from objects")
	if logger.lastQuery != "SELECT /*+ MAX_EXECUTION_TIME(60000) */ * from objects" {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(60000) */ * from objects", logger.lastQuery)
	}

	var cancel func()
	ctx, cancel = context.WithDeadline(ctx, time.Now().Add(10*time.Second))
	defer cancel()

	db = db.WithContext(ctx).(*DB)

	logger.lastQuery = ""

	db.Query("SELECT * from objects")
	if !strings.HasPrefix(logger.lastQuery, "SELECT /*+ MAX_EXECUTION_TIME(") ||
		!strings.HasSuffix(logger.lastQuery, ") */ * from objects") {
		t.Fatalf("Expected %q, got %q", "SELECT /*+ MAX_EXECUTION_TIME(9999) */ * from objects", logger.lastQuery)
	}

	lParen := strings.Index(logger.lastQuery, "(")
	rParen := strings.Index(logger.lastQuery, ")")
	millis, _ := strconv.Atoi(logger.lastQuery[lParen+1 : rParen])
	if millis > 10000 {
		t.Fatalf("Expected deadline <= 10000, got %d", millis)
	}
}

func TestWithoutDeadline(t *testing.T) {
	logger := &TestLogger{}
	db := makeTestDBWithOptions(t, []DBOption{SetQueryLogger(logger)}, usersDDL)
	db.deadlineQueryRewriter = func(db *DB, query string, deadline time.Duration) string {
		t.Fatal("DeadlineQueryRewriter should not be called")
		return ""
	}
	defer db.Close()

	ctx := context.Background()
	ctx = context.WithValue(ctx, "user_id", "123")

	db = db.WithContext(ctx).(*DB)
	if dbDeadline, ok := db.Context().Deadline(); ok {
		t.Fatalf("Unexpected db.GetContext.Deadline(): %v", dbDeadline)
	}

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}
	if txDeadline, ok := tx.Context().Deadline(); ok {
		t.Fatalf("Unexpected tx.GetContext.Deadline(): %v", txDeadline)
	}

	tx.Query("SELECT * from objects")

	if logger.lastQuery != "SELECT * from objects" {
		t.Fatalf("Expected %q, got %q", "SELECT * from objects", logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}
}

func TestWithContextInjectedComments(t *testing.T) {
	logger := &TestLogger{t: t}
	db := makeTestDBWithOptions(t, []DBOption{SetQueryLogger(logger)}, usersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	ctx := context.WithValue(context.Background(), "user_id", "123")
	commentCtx := context.WithValue(ctx, ContextKeyComments, []string{"baz", "bar"})

	logger.lastQuery = ""

	// Insert
	{
		if err := db.InsertContext(commentCtx, &User{}); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "INSERT /* baz */ /* bar */ INTO `users`") {
			t.Fatalf("Expected %q, got %q", "INSERT /* baz */ /* bar */ INTO `users`", logger.lastQuery)
		}
	}

	// Insert Ignore
	{
		if err := db.InsertIgnoreContext(commentCtx, &User{}); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "INSERT IGNORE /* baz */ /* bar */ INTO `users`") {
			t.Fatalf("Expected %q, got %q", "INSERT IGNORE /* baz */ /* bar */ INTO `users`", logger.lastQuery)
		}
	}

	// Delete
	{
		user := &User{}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		if _, err := db.DeleteContext(commentCtx, user); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "DELETE /* baz */ /* bar */ FROM `users`") {
			t.Fatalf("Expected %q, got %q", "DELETE /* baz */ /* bar */ INTO `users`", logger.lastQuery)
		}
	}

	// Get
	{
		user := &User{}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		if err := db.GetContext(commentCtx, &User{}, user.ID); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "SELECT /* baz */ /* bar */ `users`.`id`") {
			t.Fatalf("Expected %q, got %q", "SELECT /* baz */ /* bar */ `users`.`id`", logger.lastQuery)
		}
	}

	// Update
	{
		user := &User{}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		user = &User{Name: strconv.Itoa(rand.Int())}
		if _, err := db.UpdateContext(commentCtx, user); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "UPDATE /* baz */ /* bar */ `users`") {
			t.Fatalf("Expected %q, got %q", "UPDATE /* baz */ /* bar */ `users`", logger.lastQuery)
		}
	}

	// Upsert
	{
		user := &User{}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		user = &User{Name: strconv.Itoa(rand.Int())}
		if err := db.UpsertContext(commentCtx, user); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "INSERT /* baz */ /* bar */ INTO `users`") {
			t.Fatalf("Expected %q, got %q", "INSERT /* baz */ /* bar */ INTO `users`", logger.lastQuery)
		}
	}

	// Replace
	{
		user := &User{}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		user = &User{Name: strconv.Itoa(rand.Int())}
		if err := db.ReplaceContext(commentCtx, user); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, "REPLACE /* baz */ /* bar */ INTO `users`") {
			t.Fatalf("Expected %q, got %q", "REPLACE /* baz */ /* bar */ INTO `users`", logger.lastQuery)
		}
	}
}

func TestWithContextInjectedCommentsIgnored(t *testing.T) {
	logger := &TestLogger{t: t}
	db := makeTestDBWithOptions(t, []DBOption{SetQueryLogger(logger)}, usersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	ctx := context.WithValue(context.Background(), "user_id", "123")
	comment := "baz"
	commentCtx := context.WithValue(ctx, ContextKeyComments, []string{comment})

	logger.lastQuery = ""

	verifyNoComment := func(t *testing.T) {
		t.Helper()
		if strings.Contains(logger.lastQuery, comment) {
			t.Fatalf("Expected %q to not contain %q", logger.lastQuery, comment)
		}
	}

	// Select
	{
		user := &User{Name: strconv.Itoa(rand.Int())}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		var users []User
		if err := db.SelectContext(commentCtx, &users, "SELECT * FROM users WHERE name = ?", user.Name); err != nil {
			t.Fatal(err)
		}

		verifyNoComment(t)
	}

	// Exec
	{
		if _, err := db.ExecContext(commentCtx, "SELECT * FROM users WHERE name = ?", "foo"); err != nil {
			t.Fatal(err)
		}

		verifyNoComment(t)
	}

	// Query
	{
		if _, err := db.QueryContext(commentCtx, "SELECT name FROM users WHERE name = ?", "foo"); err != nil {
			t.Fatal(err)
		}

		verifyNoComment(t)
	}

	// Query Row
	{
		user := &User{Name: strconv.Itoa(rand.Int())}
		if err := db.InsertContext(ctx, user); err != nil {
			t.Fatal(err)
		}

		rowPtr := db.QueryRowContext(commentCtx, "SELECT name FROM users WHERE name = ?", user.Name)
		if rowPtr == nil {
			t.Fatal("there should be one row to read")
		}
		var name string
		if err := rowPtr.Scan(&name); err != nil {
			t.Fatal(err)
		}

		verifyNoComment(t)
	}
}

// Tests potentially dangerous comment input to ensure safe handling
func TestWithContextInjectedUnsafeComments(t *testing.T) {
	logger := &TestLogger{t: t}
	db := makeTestDBWithOptions(t, []DBOption{SetQueryLogger(logger)}, usersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	ctx := context.WithValue(context.Background(), "user_id", "123")

	logger.lastQuery = ""

	testCases := []struct {
		input    string
		expected string
	}{
		{"", "/*  */"},
		{"/*/", "/* /*\\/ */"},
		{"foo", "/* foo */"},
		{"/* foo */", "/* foo */"},
		{"/*foo*/", "/*foo*/"},
		{"'; foo */", "/* '; foo *\\/ */"},
		{"/* foo */ */", "/* foo *\\/ */"},
		{"-- foo", "/* -- foo */"},
		{"# foo", "/* # foo */"},
		{"米派", "/* 米派 */"},
	}
	for _, c := range testCases {
		commentCtx := context.WithValue(ctx, ContextKeyComments, []string{c.input})
		user := &User{}
		if err := db.InsertContext(commentCtx, user); err != nil {
			t.Fatal(err)
		}

		if !strings.HasPrefix(logger.lastQuery, fmt.Sprintf("INSERT %s INTO `users`", c.expected)) {
			t.Fatalf("Expected %q to contain %q", logger.lastQuery, c.expected)
		}

		// Make sure the insert succeeded as expected
		foundUser := &User{}
		if err := db.GetContext(commentCtx, foundUser, user.ID); err != nil {
			t.Fatal(err)
		}

		if user.ID != foundUser.ID {
			t.Fatalf("Expected to find user %d, got %d", user.ID, foundUser.ID)
		}
	}
}

func TestInsertContextValue(t *testing.T) {
	logger := &TestLogger{
		t:     t,
		count: 0,
	}

	db := makeTestDBWithOptions(t, []DBOption{SetQueryLogger(logger)}, usersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	ctx := context.WithValue(context.Background(), "user_id", "123")

	if err := db.InsertContext(ctx, &User{Name: "foo"}); err != nil {
		t.Fatal(err)
	}

	if logger.count != 1 {
		t.Fatal("Expected one call to TestLogger.Log")
	}
}

func TestOpenTracingIntegration(t *testing.T) {
	origTracer := opentracing.GlobalTracer()
	tracer := mocktracer.New()
	opentracing.SetGlobalTracer(tracer)
	defer opentracing.SetGlobalTracer(origTracer)

	dbOptions := []DBOption{
		SetOpentracingEnabled(true),
		SetStartSpanOptions(opentracing.Tag{Key: "service.name", Value: "my-service"}, opentracing.Tag{Key: "resource.name", Value: "my-resource"}),
	}
	db := makeTestDBWithOptions(t, dbOptions, usersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}

	ctx := context.WithValue(context.Background(), "user_id", "123")

	if err := db.InsertContext(ctx, &User{Name: "foo"}); err != nil {
		t.Fatal(err)
	}
	if len(tracer.FinishedSpans()) != 2 {
		t.Fatal("Expected 2 opentracing spans", tracer.FinishedSpans())
	}
	serviceVal, serviceOk := tracer.FinishedSpans()[0].Tags()["service.name"]
	if !serviceOk {
		t.Fatal("Expected service.name span tag", tracer.FinishedSpans()[0].Tags())
	}
	if serviceVal != "my-service" {
		t.Fatal("Expected 'service.name' tag value to be 'my-service'", serviceVal)
	}
	resourceVal, resourceOk := tracer.FinishedSpans()[0].Tags()["resource.name"]
	if !resourceOk {
		t.Fatal("Expected resource.name span tag", tracer.FinishedSpans()[0].Tags())
	}
	if resourceVal != "my-resource" {
		t.Fatal("Expected 'resource.name' tag value to be 'my-resource'", resourceVal)
	}
}

// Type alias, and a driver.Valuer. Ensuring that driver.Valuer has precedence.
type fooWhenValued string

func (_ *fooWhenValued) Value() (driver.Value, error) {
	return "foo", nil
}

var bar fooWhenValued = "bar"
var _ driver.Valuer = &bar

func TestDriverValuerAsArg(t *testing.T) {
	// Setup db, and insert one user named foo.
	db := makeTestDB(t, usersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}
	if err := db.Insert(&User{Name: "foo"}); err != nil {
		t.Fatal(err)
	}

	// Select
	var users []User
	if err := db.Select(&users, "SELECT * FROM users WHERE name = ?", &bar); err != nil {
		t.Fatal(err)
	}
	if len(users) != 1 {
		t.Fatalf("expected one user, found %d", len(users))
	}
	if users[0].Name != "foo" {
		t.Fatalf("expected name to be 'foo', found '%s'", users[0].Name)
	}
}

// countUsersByName returns a function which counts users by name, using plain
// old string type.
func countUsersByName(t *testing.T, db *DB) func(string) int {
	return func(name string) int {
		var c []int
		if err := db.Select(&c, "SELECT COUNT(*) FROM users WHERE name = ?", name); err != nil {
			t.Fatal(err)
		}
		return c[0]
	}
}

type someTypeAlias string

type someDoublyTypedAlias someTypeAlias

func TestTypeAlias_inArgs(t *testing.T) {
	db := makeTestDB(t, usersDDL)
	defer db.Close()

	if _, err := db.BindModel("users", User{}); err != nil {
		t.Fatal(err)
	}
	e := &User{ID: 0, Name: "foo"}
	if err := db.Insert(e); err != nil {
		t.Fatal(err)
	}

	count := countUsersByName(t, db)

	if count("foo") != 1 {
		t.Fatal("should start with one user, named 'foo'")
	}

	// Exec
	if _, err := db.Exec("UPDATE users SET name = ?", someTypeAlias("bar")); err != nil {
		t.Fatalf("failed querying with someTypeAlias: %s", err)
	}

	if count("bar") != 1 {
		t.Fatal("we should have renamed the user to 'bar'")
	}

	if _, err := db.Exec("UPDATE users SET name = ?", someDoublyTypedAlias("baz")); err != nil {
		t.Fatalf("failed querying with someTypeAlias: %s", err)
	}

	if count("baz") != 1 {
		t.Fatal("we should have renamed the user to 'baz'")
	}

	// Select
	var c []int
	if err := db.Select(&c, "SELECT COUNT(*) FROM users WHERE name = ?", someTypeAlias("baz")); err != nil {
		t.Fatal(err)
	}
	if c[0] != 1 {
		t.Fatal("we should have renamed the user to 'baz', and still find it")
	}

	// Query
	row, err := db.Query("SELECT name FROM users WHERE name = ?", someTypeAlias("baz"))
	if err != nil {
		t.Fatal(err)
	}
	if !row.Next() {
		t.Fatal("there should be one row to read")
	}
	var name string
	if err := row.Scan(&name); err != nil {
		t.Fatal(err)
	}
	if name != "baz" {
		t.Fatal("we should have renamed the user to 'baz', and still be able to query it")
	}
	if err := row.Close(); err != nil {
		t.Fatal(err)
	}

	// QueryRow
	rowPtr := db.QueryRow("SELECT name FROM users WHERE name = ?", someTypeAlias("baz"))
	if rowPtr == nil {
		t.Fatal("there should be one row to read")
	}
	if err := rowPtr.Scan(&name); err != nil {
		t.Fatal(err)
	}
	if name != "baz" {
		t.Fatal("we should have renamed the user to 'baz', and still be able to query it")
	}
}

type someAge int

type TypedUser struct {
	ID   uint64        `db:"id"`
	Name someTypeAlias `db:"name"`
	Age  someAge       `db:"age"`
}

func TestTypeAlias_inMappedStruct(t *testing.T) {
	db := makeTestDB(t, usersDDL)
	defer db.Close()

	if _, err := db.BindModel("users", TypedUser{}); err != nil {
		t.Fatal(err)
	}
	e := &TypedUser{
		ID:   0,
		Name: someTypeAlias("foo"),
		Age:  someAge(123),
	}
	if err := db.Insert(e); err != nil {
		t.Fatal(err)
	}

	count := countUsersByName(t, db)

	if count("foo") != 1 {
		t.Fatal("should start with one user, named 'foo'")
	}

	// Select
	var users []TypedUser
	if err := db.Select(&users, "SELECT * FROM users"); err != nil {
		t.Fatal(err)
	} else if len(users) != 1 {
		t.Fatal("should have one user, named 'foo'")
	}
	if string(users[0].Name) != "foo" {
		t.Fatalf("our user should be named 'foo', was '%s'", users[0].Name)
	}
	if int(users[0].Age) != 123 {
		t.Fatalf("our user should be aged 123 years, was %d", users[0].Age)
	}

	// Query
	rows, err := db.Query("SELECT * FROM users")
	if err != nil {
		t.Fatal(err)
	}
	if !rows.Next() {
		t.Fatal("should have one user, named 'foo'")
	}
	var queriedUser TypedUser
	if err := rows.StructScan(&queriedUser); err != nil {
		t.Fatal(err)
	}
	if string(queriedUser.Name) != "foo" {
		t.Fatalf("our user should be named 'foo', was '%s'", queriedUser.Name)
	}
	if int(queriedUser.Age) != 123 {
		t.Fatalf("our user should be aged 123 years, was %d", queriedUser.Age)
	}
	rows.Close()

	// QueryRow
	row := db.QueryRow("SELECT * FROM users")
	var queryRowUser TypedUser
	if err := row.StructScan(&queryRowUser); err != nil {
		t.Fatal(err)
	}
	if string(queryRowUser.Name) != "foo" {
		t.Fatalf("our user should be named 'foo' years, was '%s'", queryRowUser.Name)
	}
	if int(queryRowUser.Age) != 123 {
		t.Fatalf("our user should be aged 123 years, was %d", queryRowUser.Age)
	}

	// Get
	queriedUser.Age = 0
	queriedUser.Name = someTypeAlias("")
	if err := db.Get(&queriedUser, queriedUser.ID); err != nil {
		t.Fatal(err)
	}
	if string(queriedUser.Name) != "foo" {
		t.Fatalf("our user should be named 'foo', was '%s'", queriedUser.Name)
	}
	if int(queriedUser.Age) != 123 {
		t.Fatalf("our user should be aged 123 years, was %d", queriedUser.Age)
	}
}

const versionedUsersDDL = `
CREATE TABLE users (
  id   BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY,
  name VARCHAR(255) NOT NULL,
  ver  INT NOT NULL
)`

type VersionedUser struct {
	ID      uint64 `db:"id"`
	Name    string `db:"name"`
	Version int    `db:"ver,optlock"`
}

func TestVersionedUser_base(t *testing.T) {
	db := makeTestDB(t, versionedUsersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", VersionedUser{}); err != nil {
		t.Fatal(err)
	}

	// Insert
	u := &VersionedUser{
		Name:    "foo",
		Version: 1,
	}
	if err := db.Insert(u); err != nil {
		t.Fatal(err)
	}

	// Update
	u.Name = "bar"
	if count, err := db.Update(u); err != nil {
		t.Fatal(err)
	} else if count != 1 {
		t.Fatalf("expected one modified row, got %d", count)
	}

	// On update, we expect the in-memory representation of the version
	// to be incremented.
	if u.Version != 2 {
		t.Fatalf("expected in-memory version %d, was at version %d", 2, u.Version)
	}

	// And similarly, we expect the stored representation to be incremented.
	stored := &VersionedUser{}
	if err := db.Get(stored, u.ID); err != nil {
		t.Fatal(err)
	}
	if stored.Version != 2 {
		t.Fatalf("expected stored version %d, was at version %d", 2, stored.Version)
	}
}

func TestVersionedUser_concurrentModification(t *testing.T) {
	db := makeTestDB(t, versionedUsersDDL)
	defer db.Close()
	if _, err := db.BindModel("users", VersionedUser{}); err != nil {
		t.Fatal(err)
	}

	// Insert
	u := &VersionedUser{
		Name:    "foo",
		Version: 1,
	}
	if err := db.Insert(u); err != nil {
		t.Fatal(err)
	}

	// Concurrent modification
	if _, err := db.Exec("update users set ver = 456 where id = ?", u.ID); err != nil {
		t.Fatal(err)
	}

	// Meanwhile, we try to udate, and expect a failure
	u.Name = "bar"
	_, err := db.Update(u)
	if err == nil {
		t.Fatalf("expected a concurrent modification error, but no error occured")
	} else if err != ErrConcurrentModificationDetected {
		t.Fatalf("expected a concurrent modification error, but was '%s'", err)
	}
}

type Object struct {
	UserID    int64  `db:"user_id"`
	ID        string `db:"object_id"`
	Timestamp int64  `db:"timestamp"`
	Value     string `db:"value"`
}

func makeItems(n int) []interface{} {
	var items []interface{}
	for i := 0; i < n; i++ {
		d := &Object{
			UserID: 1,
			ID:     fmt.Sprintf("%08d", i),
			Value:  fmt.Sprintf("hello %d", i),
		}
		items = append(items, d)
	}
	return items
}

func mustInsertItems(b *testing.B, db benchDB, items []interface{}) {
	const batchSize = 100000
	for i := 0; i < len(items); i += batchSize {
		e := i + batchSize
		if e >= len(items) {
			e = len(items)
		}
		if err := db.Insert(items[i:e]...); err != nil {
			b.Fatal(err)
		}
	}
}

type benchTx interface {
	Commit() error
	Delete(list ...interface{}) (int64, error)
	Get(obj interface{}, keys ...interface{}) error
	Insert(list ...interface{}) error
	Replace(list ...interface{}) error
	Update(list ...interface{}) (int64, error)
	Upsert(list ...interface{}) error
}

type benchDB interface {
	Begin() (benchTx, error)
	Close() error
	Insert(list ...interface{}) error
}

func benchmarkGet(b *testing.B, batchSize int, db benchDB) {
	defer db.Close()

	items := makeItems(b.N)
	mustInsertItems(b, db, items)

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	for _, obj := range items {
		i := obj.(*Object)
		if err := tx.Get(i, i.UserID, i.ID); err != nil {
			b.Fatal(err)
		}
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
	b.StopTimer()
}

func benchmarkDelete(b *testing.B, batchSize int, db benchDB) {
	defer db.Close()

	items := makeItems(b.N)
	mustInsertItems(b, db, items)

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	for i := 0; i < len(items); i += batchSize {
		e := i + batchSize
		if e >= len(items) {
			e = len(items)
		}
		if _, err := tx.Delete(items[i:e]...); err != nil {
			b.Fatal(err)
		}
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
	b.StopTimer()
}

func benchmarkInsert(b *testing.B, batchSize int, db benchDB) {
	defer db.Close()

	items := makeItems(b.N)

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	for i := 0; i < len(items); i += batchSize {
		e := i + batchSize
		if e >= len(items) {
			e = len(items)
		}
		if err := tx.Insert(items[i:e]...); err != nil {
			b.Fatal(err)
		}
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
	b.StopTimer()
}

func benchmarkReplace(b *testing.B, batchSize int, db benchDB) {
	defer db.Close()

	items := makeItems(b.N)

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	for i := 0; i < len(items); i += batchSize {
		e := i + batchSize
		if e >= len(items) {
			e = len(items)
		}
		if err := tx.Replace(items[i:e]...); err != nil {
			b.Fatal(err)
		}
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
	b.StopTimer()
}

func benchmarkUpdate(b *testing.B, batchSize int, db benchDB) {
	defer db.Close()

	items := makeItems(b.N)
	mustInsertItems(b, db, items)

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	for i := 0; i < len(items); i += batchSize {
		e := i + batchSize
		if e >= len(items) {
			e = len(items)
		}
		if _, err := tx.Update(items[i:e]...); err != nil {
			b.Fatal(err)
		}
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
	b.StopTimer()
}

func benchmarkUpsert(b *testing.B, batchSize int, db benchDB) {
	defer db.Close()

	items := makeItems(b.N)

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	for i := 0; i < len(items); i += batchSize {
		e := i + batchSize
		if e >= len(items) {
			e = len(items)
		}
		if err := tx.Upsert(items[i:e]...); err != nil {
			b.Fatal(err)
		}
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
	b.StopTimer()
}

type gorpBenchDB struct {
	*gorp.DbMap
}

func (db *gorpBenchDB) Begin() (benchTx, error) {
	tx, err := db.DbMap.Begin()
	if err != nil {
		return nil, err
	}
	return &gorpBenchTx{tx}, nil
}

func (db *gorpBenchDB) Close() error {
	return db.Db.Close()
}

type gorpBenchTx struct {
	*gorp.Transaction
}

func (tx *gorpBenchTx) Get(obj interface{}, keys ...interface{}) error {
	_, err := tx.Transaction.Get(obj, keys...)
	return err
}

func (tx *gorpBenchTx) Replace(list ...interface{}) error {
	return errors.New("unimplemented")
}

func (tx *gorpBenchTx) Upsert(list ...interface{}) error {
	return errors.New("unimplemented")
}

func makeGorpBenchDB(b *testing.B) benchDB {
	db := makeTestDB(b, objectsDDL)
	gorpDB := &gorp.DbMap{
		Db: db.DB,
		Dialect: gorp.MySQLDialect{
			Engine:   "InnoDB",
			Encoding: "UTF8",
		},
	}
	gorpDB.AddTableWithName(Object{}, "objects").SetKeys(false, "user_id", "object_id")
	return &gorpBenchDB{gorpDB}
}

func BenchmarkGorpGet(b *testing.B) {
	benchmarkGet(b, b.N, makeGorpBenchDB(b))
}

func BenchmarkGorpDelete(b *testing.B) {
	benchmarkDelete(b, 100000, makeGorpBenchDB(b))
}

func BenchmarkGorpInsert(b *testing.B) {
	benchmarkInsert(b, 100000, makeGorpBenchDB(b))
}

func BenchmarkGorpUpdate(b *testing.B) {
	benchmarkUpdate(b, 100000, makeGorpBenchDB(b))
}

type squalorBenchDB struct {
	*DB
}

func (db *squalorBenchDB) Begin() (benchTx, error) {
	tx, err := db.DB.Begin()
	if err != nil {
		return nil, err
	}
	return tx, nil
}

func makeSqlutilBenchDB(b *testing.B) benchDB {
	db := makeTestDB(b, objectsDDL)
	if _, err := db.BindModel("objects", Object{}); err != nil {
		b.Fatal(err)
	}
	return &squalorBenchDB{db}
}

func BenchmarkDBGet1(b *testing.B) {
	benchmarkGet(b, 1, makeSqlutilBenchDB(b))
}

func BenchmarkDBGetN(b *testing.B) {
	db := makeSqlutilBenchDB(b)

	items := makeItems(b.N)
	mustInsertItems(b, db, items)

	model, err := db.(*squalorBenchDB).GetModel(Object{})
	if err != nil {
		b.Fatal(err)
	}

	b.ResetTimer()
	tx, err := db.Begin()
	if err != nil {
		b.Fatal(err)
	}
	ids := make([]RawVal, len(items))
	vals := make(ValExprs, len(items))
	for i, obj := range items {
		ids[i].Val = obj.(*Object).ID
		vals[i] = &ids[i]
	}
	q := model.Select("*").
		Where(model.C("user_id").Eq(1).And(model.C("object_id").InTuple(ValTuple{vals})))
	var results []Object
	if err := tx.(*Tx).Select(&results, q); err != nil {
		b.Fatal(err)
	} else if len(results) != len(items) {
		b.Fatalf("Expected %d results, but got %d", len(items), len(results))
	}
	if err := tx.Commit(); err != nil {
		b.Fatal(err)
	}
}

func BenchmarkDBDelete1(b *testing.B) {
	benchmarkDelete(b, 1, makeSqlutilBenchDB(b))
}

func BenchmarkDBDeleteN(b *testing.B) {
	benchmarkDelete(b, 100000, makeSqlutilBenchDB(b))
}

func BenchmarkDBInsert1(b *testing.B) {
	benchmarkInsert(b, 1, makeSqlutilBenchDB(b))
}

func BenchmarkDBInsertN(b *testing.B) {
	benchmarkInsert(b, 100000, makeSqlutilBenchDB(b))
}

func BenchmarkDBReplace1(b *testing.B) {
	benchmarkReplace(b, 1, makeSqlutilBenchDB(b))
}

func BenchmarkDBReplaceN(b *testing.B) {
	benchmarkReplace(b, 100000, makeSqlutilBenchDB(b))
}

func BenchmarkDBUpdate1(b *testing.B) {
	benchmarkUpdate(b, 1, makeSqlutilBenchDB(b))
}

func BenchmarkDBUpdateN(b *testing.B) {
	benchmarkUpdate(b, 100000, makeSqlutilBenchDB(b))
}

func BenchmarkDBUpsert1(b *testing.B) {
	benchmarkUpsert(b, 1, makeSqlutilBenchDB(b))
}

func BenchmarkDBUpsertN(b *testing.B) {
	benchmarkUpsert(b, 100000, makeSqlutilBenchDB(b))
}

func TestWithContextQueryRewriter(t *testing.T) {
	logger := &TestLogger{}
	contextInfo := func(ctx context.Context) string {
		return "test"
	}
	db := makeTestDBWithOptions(t, []DBOption{ContextInfoRewriter(contextInfo), SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	ctx := context.WithValue(context.Background(), "user_id", "123")
	db = db.WithContext(ctx).(*DB)

	// Test tx.Query
	logger.lastQuery = ""

	tx, err := db.Begin()
	if err != nil {
		t.Fatal(err)
	}

	q := "SELECT * from objects LIMIT 1"

	tx.Query(q)

	expected := "/* test */ " + q
	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}

	// Test db.Query
	logger.lastQuery = ""

	db.Query(q)
	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}

	// Test tx.QueryRow
	logger.lastQuery = ""

	tx, err = db.Begin()
	if err != nil {
		t.Fatal(err)
	}

	tx.QueryRow(q)

	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}

	err = tx.Commit()
	if err != nil {
		t.Fatal(err)
	}

	// Test db.QueryRow
	logger.lastQuery = ""

	db.QueryRow(q)

	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", "/* test */ "+q, logger.lastQuery)
	}

	// Test with white space
	logger.lastQuery = ""

	db.QueryRow(`
     ` + q)

	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}

	db.Close()
	badContextInfo := func(ctx context.Context) string {
		return "*/ DROP TABLE users; /*"
	}
	db = makeTestDBWithOptions(t, []DBOption{ContextInfoRewriter(badContextInfo), SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	db = db.WithContext(ctx).(*DB)

	db.QueryRow(q)

	expected = q
	// The malicious info string was not inserted!
	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}

	db.Close()
	badContextInfo = func(ctx context.Context) string {
		return "+ BKA(t1)"
	}
	db = makeTestDBWithOptions(t, []DBOption{ContextInfoRewriter(badContextInfo), SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	db = db.WithContext(ctx).(*DB)

	db.QueryRow(q)

	// The malicious info string was not inserted!
	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}

	db.Close()
	badContextInfo = func(ctx context.Context) string {
		return "! STRAIGHT_JOIN"
	}
	db = makeTestDBWithOptions(t, []DBOption{ContextInfoRewriter(badContextInfo), SetQueryLogger(logger)}, usersDDL)
	defer db.Close()

	db = db.WithContext(ctx).(*DB)

	db.QueryRow(q)

	// The malicious info string was not inserted!
	if logger.lastQuery != expected {
		t.Fatalf("Expected %q, got %q", expected, logger.lastQuery)
	}
}