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

Remove duplicate tests

Browse source
This commit is contained in:
Noah Hilverling 2019-03-05 13:39:12 +01:00
parent ab08af7c3a
commit f33c680685
1 changed files with 0 additions and 88 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

88
mysql_test.go
View file

@ -254,94 +254,6 @@ func TestDBWrapper_SqlExec(t *testing.T) {
mockDb.AssertExpectations(t)
}
func TestDBWrapper_SqlExecQuiet(t *testing.T) {
mockDb := new(DbMock)
dbw := NewTestDBW(mockDb)
mockDb.On("Exec", "test", []interface{}(nil)).Return(SqlResultMock{}, errors.New("whoops")).Once()
mockDb.On("Exec", "test", []interface{}(nil)).Return(SqlResultMock{}, nil).Once()
mockDb.On("Ping").Return(errors.New("whoops")).Once()
var err error
done := make(chan bool)
dbw.CompareAndSetConnected(true)
go func() {
_, err = dbw.SqlExecQuiet("test", "test")
done <- true
}()
time.Sleep(time.Millisecond * 50)
dbw.CompareAndSetConnected(true)
dbw.ConnectionUpCondition.Broadcast()
<- done
assert.NoError(t, err)
mockDb.AssertExpectations(t)
}
func TestDBWrapper_SqlExecTx(t *testing.T) {
mockDb := new(DbMock)
dbw := NewTestDBW(mockDb)
mockTx := new(TransactionMock)
mockTx.On("Exec", "test", []interface{}(nil)).Return(SqlResultMock{}, errors.New("whoops")).Once()
mockTx.On("Exec", "test", []interface{}(nil)).Return(SqlResultMock{}, nil).Once()
mockDb.On("Ping").Return(errors.New("whoops")).Once()
var err error
done := make(chan bool)
dbw.CompareAndSetConnected(true)
go func() {
_, err = dbw.SqlExecTx(mockTx, "test", "test")
done <- true
}()
time.Sleep(time.Millisecond * 50)
dbw.CompareAndSetConnected(true)
dbw.ConnectionUpCondition.Broadcast()
<- done
assert.NoError(t, err)
mockTx.AssertExpectations(t)
mockDb.AssertExpectations(t)
}
func TestDBWrapper_SqlExecTxQuiet(t *testing.T) {
mockDb := new(DbMock)
dbw := NewTestDBW(mockDb)
mockTx := new(TransactionMock)
mockTx.On("Exec", "test", []interface{}(nil)).Return(SqlResultMock{}, errors.New("whoops")).Once()
mockTx.On("Exec", "test", []interface{}(nil)).Return(SqlResultMock{}, nil).Once()
mockDb.On("Ping").Return(errors.New("whoops")).Once()
var err error
done := make(chan bool)
dbw.CompareAndSetConnected(true)
go func() {
_, err = dbw.SqlExecTxQuiet(mockTx, "test", "test")
done <- true
}()
time.Sleep(time.Millisecond * 50)
dbw.CompareAndSetConnected(true)
dbw.ConnectionUpCondition.Broadcast()
<- done
assert.NoError(t, err)
mockTx.AssertExpectations(t)
mockDb.AssertExpectations(t)
}
func TestGetConnectionCheckInterval(t *testing.T) {
dbw := NewTestDBW(nil)