upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add SqlTransaction() Test

Browse source
This commit is contained in:
Noah Hilverling 2019-02-26 14:28:11 +01:00
parent 92e81ade15
commit 39e136f1a8
1 changed files with 17 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
mysql_test.go
View file

@ -155,6 +155,23 @@ func TestDBWrapper_SqlBegin(t *testing.T) {
mockDb.AssertExpectations(t)
}
func TestDBWrapper_SqlTransaction(t *testing.T) {
dbw, err := NewDBWrapper("mysql", "icingadb:icingadb@tcp(127.0.0.1:3306)/icingadb")
assert.NoError(t, err, "Is the MySQL server running?")
err = dbw.SqlTransaction(false, true, false, func(tx DbTransaction) error {
return nil
})
assert.NoError(t, err)
err = dbw.SqlTransaction(false, true, false, func(tx DbTransaction) error {
return errors.New("whoops")
})
assert.Error(t, err)
}
func TestDBWrapper_WithRetry(t *testing.T) {
mockDb := new(DbMock)
dbw := NewTestDBW(mockDb)