diff --git a/ees/sql.go b/ees/sql.go index 64647c22f..10ea7a8b1 100644 --- a/ees/sql.go +++ b/ees/sql.go @@ -147,7 +147,9 @@ func (sqlEe *SQLEe) ExportEvent(_ *context.Context, req interface{}, _ string) e func (sqlEe *SQLEe) Close() (err error) { sqlEe.Lock() - err = sqlEe.sqldb.Close() + if sqlEe.sqldb != nil { + err = sqlEe.sqldb.Close() + } sqlEe.db = nil sqlEe.sqldb = nil sqlEe.Unlock()