Skip to content

Commit ebf991b

Browse files
committed
Fix test failure
1 parent 9b2c6af commit ebf991b

File tree

3 files changed

+11
-3
lines changed

3 files changed

+11
-3
lines changed

neo4j/error.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,10 @@ func newDriverError(format string, args ...interface{}) gobolt.GenericError {
108108
return &driverError{message: fmt.Sprintf(format, args...)}
109109
}
110110

111+
func newSessionExpiredError(format string, args ...interface{}) error {
112+
return &sessionExpiredError{message: fmt.Sprintf(format, args...)}
113+
}
114+
111115
func newDatabaseError(classification, code, message string) gobolt.DatabaseError {
112116
return &databaseError{code: code, message: message, classification: classification}
113117
}

neo4j/runner.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -144,8 +144,12 @@ func handleRecordsPhase(runner *statementRunner, activeResult *neoResult) error
144144
}
145145

146146
func transformError(runner *statementRunner, err error) error {
147-
if gobolt.IsWriteError(err) && runner.accessMode == AccessModeRead {
148-
return &sessionExpiredError{"write queries cannot be performed in read access mode"}
147+
if gobolt.IsWriteError(err) {
148+
if runner.accessMode == AccessModeRead {
149+
return newDriverError("write queries cannot be performed in read access mode")
150+
}
151+
152+
return newSessionExpiredError("server at %s no longer accepts writes", runner.connection.RemoteAddress())
149153
}
150154

151155
return err

neo4j/test-integration/values_unsupported_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ var _ = Describe("Unsupported Types [V1]", func() {
7373
testSend := func(data interface{}) {
7474
result, err = session.Run("WITH $x RETURN 1", map[string]interface{}{"x": data})
7575
Expect(err).To(BeConnectorErrorWithCode(0x501))
76-
Expect(err).To(BeConnectorErrorWithDescription("unable to generate RUN message"))
76+
Expect(err).To(BeConnectorErrorWithDescription("unable to generate run message"))
7777
}
7878

7979
Context("Send", func() {

0 commit comments

Comments
 (0)