11// go mod init main
22// go run example.go
33package main
4+ 45import (
56 "fmt"
6- "github.com/neo4j/neo4j-go-driver/neo4j" //Go 1.8
7+ "github.com/neo4j/neo4j-go-driver/v4/neo4j"
8+ "io"
9+ "reflect"
710)
11+ 812func main () {
9- s , err := runQuery ("bolt://<HOST>:<BOLTPORT>" , "<USERNAME>" , "<PASSWORD>" )
13+ results , err := runQuery ("bolt://<HOST>:<BOLTPORT>" , "neo4j ""<USERNAME>" , "<PASSWORD>" )
1014 if err != nil {
1115 panic (err )
1216 }
13- fmt .Println (s )
14- }
15- func runQuery (uri , username , password string ) ([]string , error ) {
16- configForNeo4j4 := func (conf * neo4j.Config ) { conf .Encrypted = false }
17- driver , err := neo4j .NewDriver (uri , neo4j .BasicAuth (username , password , "" ), configForNeo4j4 )
18- if err != nil {
19- return nil , err
17+ for _ , result := range results {
18+ fmt .Println (result )
2019 }
21- defer driver .Close ()
22- sessionConfig := neo4j.SessionConfig {AccessMode : neo4j .AccessModeRead , DatabaseName : "neo4j" }
23- session , err := driver .NewSession (sessionConfig )
20+ }
21+ 22+ func runQuery (uri , database , username , password string ) (result []string , err error ) {
23+ driver , err := neo4j .NewDriver (uri , neo4j .BasicAuth (username , password , "" ))
2424 if err != nil {
2525 return nil , err
2626 }
27- defer session .Close ()
27+ defer func () {err = handleClose (driver , err )}()
28+ session := driver .NewSession (neo4j.SessionConfig {AccessMode : neo4j .AccessModeRead , DatabaseName : database })
29+ defer func () {err = handleClose (session , err )}()
2830 results , err := session .ReadTransaction (func (transaction neo4j.Transaction ) (interface {}, error ) {
2931 result , err := transaction .Run (
3032 `
@@ -40,7 +42,7 @@ func runQuery(uri, username, password string) ([]string, error) {
4042 for result .Next () {
4143 value , found := result .Record ().Get ("person" )
4244 if found {
43- arr = append (arr , value .(string ))
45+ arr = append (arr , value .(string ))
4446 }
4547 }
4648 if err = result .Err (); err != nil {
@@ -51,5 +53,17 @@ func runQuery(uri, username, password string) ([]string, error) {
5153 if err != nil {
5254 return nil , err
5355 }
54- return results .([]string ), err
55- }
56+ result = results .([]string )
57+ return result , err
58+ }
59+ 60+ func handleClose (closer io.Closer , previousError error ) error {
61+ err := closer .Close ()
62+ if err == nil {
63+ return previousError
64+ }
65+ if previousError == nil {
66+ return err
67+ }
68+ return fmt .Errorf ("%v closure error occurred:\n %s\n initial error was:\n %w" , reflect .TypeOf (closer ), err .Error (), previousError )
69+ }
0 commit comments