mysqlTxMock_test.go

package mysql

import (
	//"database/sql"
	"fmt"
	"testing"

	di "github.com/Ulbora/dbinterface"
)

var tx1m di.Transaction
var mdbtm MyDBMock
var dbitm di.Database

var idtx1m int64

func TestMyDbTxMock_Connect(t *testing.T) {

	mdbtm.Host = "localhost:3306"
	mdbtm.User = "admin"
	mdbtm.Password = "admin"
	mdbtm.Database = "testdb"
	mdbtm.MockConnectSuccess = true
	//dbitm = &mdbtm
	dbitm = mdbtm.GetNewDatabase()
	suc := dbitm.Connect()
	if !suc {
		fmt.Println("Could not connect: ")
	}

}

func TestMyDbTxMock_Insert(t *testing.T) {
	tx1m = dbitm.BeginTransaction()
	mdbtm.MockInsertSuccess1 = true
	mdbtm.MockInsertID1 = 1

	var q = "insert into test (name, address) values(?, ?)"
	var a []interface{}
	a = append(a, "test insert 1", "123 main st")

	suc, id := tx1m.Insert(q, a...)
	if !suc || id < 1 {
		t.Fail()
	} else {
		idtx1m = id
		fmt.Println("inserted id: ", id)
	}
	tx1m.Commit()
}

func TestMyDbTxMock_Insert2(t *testing.T) {
	tx1m = dbitm.BeginTransaction()
	//mdbtm.MockInsertSuccess1 = true
	//mdbtm.MockInsertID1 = 1
	mdbtm.MockInsertSuccess2 = true
	mdbtm.MockInsertID2 = 2

	var q = "insert into test (name, address) values(?, ?)"
	var a []interface{}
	a = append(a, "test insert 1", "123 main st")

	//tx1m.Insert(q, a...)
	suc, id := tx1m.Insert(q, a...)
	fmt.Println("inserted 2 suc: ", suc)
	fmt.Println("inserted 2 id: ", id)
	if !suc || id < 1 {
		t.Fail()
	} else {
		idtx1m = id
		fmt.Println("inserted id: ", id)
	}
	tx1m.Commit()
}

func TestMyDbTxMock_Insert3(t *testing.T) {
	tx1m = dbitm.BeginTransaction()
	//mdbtm.MockInsertSuccess1 = true
	//mdbtm.MockInsertID1 = 1
	mdbtm.MockInsertSuccess3 = true
	mdbtm.MockInsertID3 = 2

	var q = "insert into test (name, address) values(?, ?)"
	var a []interface{}
	a = append(a, "test insert 1", "123 main st")

	//tx1m.Insert(q, a...)
	suc, id := tx1m.Insert(q, a...)
	fmt.Println("inserted 2 suc: ", suc)
	fmt.Println("inserted 2 id: ", id)
	if !suc || id < 1 {
		t.Fail()
	} else {
		idtx1m = id
		fmt.Println("inserted id: ", id)
	}
	tx1m.Commit()
}

func TestMyDbTxMock_Insert4(t *testing.T) {
	tx1m = dbitm.BeginTransaction()
	//mdbtm.MockInsertSuccess1 = true
	//mdbtm.MockInsertID1 = 1
	mdbtm.MockInsertSuccess4 = true
	mdbtm.MockInsertID4 = 4

	var q = "insert into test (name, address) values(?, ?)"
	var a []interface{}
	a = append(a, "test insert 1", "123 main st")

	//tx1m.Insert(q, a...)
	suc, id := tx1m.Insert(q, a...)
	fmt.Println("inserted 4 suc: ", suc)
	fmt.Println("inserted 4 id: ", id)
	if !suc || id < 1 {
		t.Fail()
	} else {
		idtx1m = id
		fmt.Println("inserted id: ", id)
	}
	tx1m.Commit()
}

func TestMyDbTxMock_Insertfail(t *testing.T) {
	tx1m = dbitm.BeginTransaction()
	mdbtm.MockInsertSuccess2 = false
	var q = "insert into test (name, address) values(?, ?)"
	var a []interface{}
	//a = append(a, "test insert 1", "123 main st")

	suc, id := tx1m.Insert(q, a...)
	if suc {
		t.Fail()
	} else {
		fmt.Println("inserted id: ", id)
	}
	tx1m.Commit()
}

func TestMyDbTxMock_Update(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockUpdateSuccess1 = true
	var q = "update test set name = ? , address = ? where id = ? "
	var a []interface{}
	a = append(a, "test insert 2", "123456 main st", idtx1)
	suc := tx1xx.Update(q, a...)
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Update2(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	//mdbtm.MockUpdateSuccess1 = true
	mdbtm.MockUpdateSuccess3 = true
	var q = "update test set name = ? , address = ? where id = ? "
	var a []interface{}
	a = append(a, "test insert 2", "123456 main st", idtx1)
	tx1xx.Update(q, a...)
	suc := tx1xx.Update(q, a...)
	fmt.Println("update 2 suc: ", suc)
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Updatefail(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockUpdateSuccess2 = false
	var q = "update test11 set name = ? , address = ? where id = ? "
	var a []interface{}
	a = append(a, "test insert 2", "123456 main st", idtx1)
	suc := tx1xx.Update(q, a...)
	if suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Delete(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockDeleteSuccess1 = true
	var q = "delete from test where id = ? "
	var a []interface{}
	a = append(a, idtx1)
	suc := tx1xx.Delete(q, a...)
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Delete2(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockDeleteSuccess2 = true
	var q = "delete from test where id = ? "
	var a []interface{}
	a = append(a, idtx1)
	suc := tx1xx.Delete(q, a...)
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Delete3(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockDeleteSuccess3 = true
	var q = "delete from test where id = ? "
	var a []interface{}
	a = append(a, idtx1)
	suc := tx1xx.Delete(q, a...)
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}
func TestMyDbTxMock_Rollback(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockRollbackSuccess = true
	suc := tx1xx.Rollback()
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Deletefail(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockDeleteSuccess2 = false
	var q = "delete from test22 where id = ? "
	var a []interface{}
	a = append(a, idtx1)
	suc := tx1xx.Delete(q, a...)
	if suc {
		t.Fail()
	}
	tx1xx.Commit()
}

func TestMyDbTxMock_Commit(t *testing.T) {
	tx1xx := dbitm.BeginTransaction()
	mdbtm.MockCommitSuccess = true
	suc := tx1xx.Commit()
	if !suc {
		t.Fail()
	}
	tx1xx.Commit()
}