-
-
Notifications
You must be signed in to change notification settings - Fork 1
/
neo.go
63 lines (48 loc) · 1.58 KB
/
neo.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package idp
import (
"strings"
"fmt"
"strconv"
"github.com/neo4j/neo4j-go-driver/neo4j"
)
func BeginReadTx(driver neo4j.Driver, configurers ...func(*neo4j.TransactionConfig)) (neo4j.Session, neo4j.Transaction, error) {
session, err := driver.Session(neo4j.AccessModeRead)
if err != nil {
return nil, nil, err
}
tx, err := session.BeginTransaction(configurers...)
if err != nil {
session.Close()
}
return session, tx, err
}
func BeginWriteTx(driver neo4j.Driver, configurers ...func(*neo4j.TransactionConfig)) (neo4j.Session, neo4j.Transaction, error) {
session, err := driver.Session(neo4j.AccessModeWrite)
if err != nil {
return nil, nil, err
}
tx, err := session.BeginTransaction(configurers...)
if err != nil {
session.Close()
}
return session, tx, err
}
func logCypher(query string, params map[string]interface{}) {
for i,e := range params {
switch t := e.(type) {
case bool:
query = strings.Replace(query, "$"+i, "\""+strconv.FormatBool(e.(bool))+"\"", -1)
case int:
query = strings.Replace(query, "$"+i, "\""+strconv.Itoa(e.(int))+"\"", -1)
case int64:
query = strings.Replace(query, "$"+i, "\""+strconv.FormatInt(e.(int64), 10)+"\"", -1)
case string:
query = strings.Replace(query, "$"+i, "\""+e.(string)+"\"", -1)
case []string:
query = strings.Replace(query, "$"+i, "["+strings.Join(e.([]string), ",")+"]", -1)
default:
panic(fmt.Sprintf("Unsupported type %T", t))
}
}
fmt.Printf("\n========== NEO4J DEBUGGING ==========\nCypher: %v", query)
}