Skip to content

Commit 48912c4

Browse files
authored
CI: fix ITs not always closing driver (#628)
1 parent 5b9235e commit 48912c4

File tree

5 files changed

+8
-20
lines changed

5 files changed

+8
-20
lines changed

neo4j/test-integration/dbserver/dbserver.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -118,6 +118,7 @@ func setServerVersion(ctx context.Context, server *DbServer, envVersion Version)
118118
// this is used when the TEST_NEO4J_VERSION environment variable is not set.
119119
func (s *DbServer) getVersionFromDB(ctx context.Context) (Version, error) {
120120
driver := s.Driver()
121+
defer func() { _ = driver.Close(ctx) }()
121122
session := driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeRead})
122123
defer session.Close(ctx)
123124

@@ -146,6 +147,7 @@ func (s *DbServer) getVersionFromDB(ctx context.Context) (Version, error) {
146147

147148
func (s DbServer) deleteData(ctx context.Context) {
148149
driver := s.Driver()
150+
defer func() { _ = driver.Close(ctx) }()
149151
session := driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeWrite})
150152
defer session.Close(ctx)
151153

neo4j/test-integration/routing_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ func TestRouting(outer *testing.T) {
7474

7575
driver := getDriver(server.URI())
7676
assertNil(t, err)
77+
defer func() { _ = driver.Close(ctx) }()
7778

7879
session = driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeWrite})
7980

neo4j/test-integration/session_test.go

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -50,19 +50,11 @@ func TestSession(outer *testing.T) {
5050
c.Log = log.ToConsole(log.DEBUG)
5151
})
5252
assertNotNil(inner, driver)
53+
defer func() { _ = driver.Close(ctx) }()
5354

5455
session = driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeRead})
5556
assertNotNil(inner, session)
56-
57-
defer func() {
58-
if session != nil {
59-
session.Close(ctx)
60-
}
61-
62-
if driver != nil {
63-
driver.Close(ctx)
64-
}
65-
}()
57+
defer func() { _ = session.Close(ctx) }()
6658

6759
inner.Run("when a query is executed, it should run and return summary with correct statement", func(t *testing.T) {
6860
stmt := "UNWIND [1, 2, 3, 4, 5] AS x RETURN x"

neo4j/test-integration/summary_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ func TestResultSummary(outer *testing.T) {
4444
config.Log = log.ToConsole(log.DEBUG)
4545
})
4646
assertNotNil(outer, driver)
47+
defer func() { _ = driver.Close(ctx) }()
4748

4849
outer.Run("from single-tenant Neo4j servers", func(inner *testing.T) {
4950
if isMultiTenant(server) {

neo4j/test-integration/types_test.go

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -41,18 +41,10 @@ func TestTypes(outer *testing.T) {
4141
var result neo4j.ResultWithContext
4242

4343
driver = server.Driver()
44+
defer func() { _ = driver.Close(ctx) }()
4445
session = driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeWrite})
4546
assertNotNil(outer, session)
46-
47-
defer func() {
48-
if session != nil {
49-
session.Close(ctx)
50-
}
51-
52-
if driver != nil {
53-
driver.Close(ctx)
54-
}
55-
}()
47+
defer func() { _ = session.Close(ctx) }()
5648

5749
outer.Run("should be able to send and receive boolean property", func(t *testing.T) {
5850
value := true

0 commit comments

Comments
 (0)