-
Notifications
You must be signed in to change notification settings - Fork 2
/
bolt_neo4j_demo.py
92 lines (68 loc) · 3.23 KB
/
bolt_neo4j_demo.py
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import asyncio
import argparse
import logging
from asyncbolt import connect, protocol
class Neo4jBoltClientProtocol(protocol.BoltClientProtocol):
def __init__(self, loop, *, username=None, password=None):
super().__init__(loop=loop)
self.username = username
self.password = password
def get_init_params(self):
return 'AsyncBolt/1.0', {"scheme": "basic", "principal": self.username, "credentials": self.password}
FORMAT = '%(message)s'
logging.basicConfig(level=logging.DEBUG, format=FORMAT)
logger = logging.getLogger(__name__)
log_debug = logger.debug
async def go(loop, username, password):
log_debug("\nRunning the examples from the Bolt documentation...\n")
client = await connect(
loop=loop, host='localhost', port=7687,
protocol_class=Neo4jBoltClientProtocol, username=username, password=password)
try:
start = loop.time()
log_debug("Running a Cypher query...\n")
async for msg in client.run("RETURN 1 AS num", {}):
log_debug('Client received message: \n\n{}\n'.format(msg))
log_debug("Pipelining...\n")
client.pipeline("RETURN 1 AS num", {})
client.pipeline("RETURN 1 AS num", {})
async for msg in client.run():
log_debug('Client received message: \n\n{}\n'.format(msg))
log_debug("Error handling with Reset...\n")
try:
async for msg in client.run("This will cause a syntax error", {}):
print(msg)
except Exception as e:
log_debug('Client raised exception: \n\n{}\n'.format(e))
log_debug("Accessing basic result metadata...\n")
async for msg in client.run("CREATE ()", {}, get_eof=True):
log_debug('Client received message: \n\n{}\n'.format(msg))
log_debug("Explaining and profiling a query...\n")
async for msg in client.run("EXPLAIN RETURN 1 AS num", {}, get_eof=True):
log_debug('Client received message: \n\n{}\n'.format(msg))
log_debug("Accessing notifications...\n")
async for msg in client.run("EXPLAIN MATCH (n), (m) RETURN n, m", {}, get_eof=True):
log_debug('Client received message: \n\n{}\n'.format(msg))
log_debug("Get somes nodes...\n")
async for msg in client.run('MATCH (n) RETURN n'):
log_debug('Client received message: {}'.format(msg))
log_debug("\nReset session...\n")
msg = await client.reset()
log_debug('Client received message: \n\n{}\n'.format(msg))
finally:
print("Finished in {}".format(loop.time() - start))
client.close()
if __name__ == '__main__':
parser = argparse.ArgumentParser(description="Options for the Neo4j Bolt demo dialogue")
parser.add_argument('--username', '-u', dest="username", action='store',
help='Username for Neo4j database', default='neo4j')
parser.add_argument('--password', '-p', dest="password", action='store',
help='Password for Neo4j database', default='password')
args = parser.parse_args()
username = args.username
password = args.password
loop = asyncio.get_event_loop()
try:
loop.run_until_complete(go(loop, username, password))
finally:
loop.close()