Updated to new naming scheme for relations.

Author: ccattuto

cypher_query_timing.py

@@ -4,6 +4,7 @@
 
 # Copyright (C) 2013 ISI Foundation
 # written by Ciro Cattuto <[email protected]>
+# and Andre' Panisson <[email protected]>
 #
 # This program is free software: you can redistribute it and/or modify
 # it under the terms of the GNU General Public License as published by
@@ -35,12 +36,17 @@
 ret = gdb.query(q="""START run=node(%d) MATCH run-[:RUN_FRAME]->frame WHERE frame.frame_id = %d RETURN frame""" % (RUN_ID, 8084), returns=client.Node)[0]
 FRAME_ID = ret[0]._get_id()
 
-ret = gdb.query(q="""START run=node(%d) MATCH run-[:RUN_TAG]->tag WHERE tag.tag = %d RETURN tag""" % (RUN_ID, 1138), returns=client.Node)[0]
-TAG_ID = ret[0]._get_id()
+ret = gdb.query(q="""START run=node(%d) MATCH run-[:RUN_ACTOR]->actor WHERE actor.actor = %d RETURN actor""" % (RUN_ID, 1138), returns=client.Node)[0]
+ACTOR_ID = ret[0]._get_id()
+ACTOR1_ID = ACTOR_ID
+
+ret = gdb.query(q="""START run=node(%d) MATCH run-[:RUN_ACTOR]->actor WHERE actor.actor = %d RETURN actor""" % (RUN_ID, 1146), returns=client.Node)[0]
+ACTOR2_ID = ret[0]._get_id()
+
+ret = gdb.query(q="""START run=node(%d) MATCH run-[:HAS_TIMELINE]->()-[y:NEXT_LEVEL]->()-[m:NEXT_LEVEL]->()-[d:NEXT_LEVEL]->()-[h:NEXT_LEVEL]->hour WHERE d.day = 29 and h.hour = 10
+RETURN hour""" % RUN_ID, returns=client.Node)[0]
+HOUR_ID = ret[0]._get_id()
 
-TAG1_ID = TAG_ID
-ret = gdb.query(q="""START run=node(%d) MATCH run-[:RUN_TAG]->tag WHERE tag.tag = %d RETURN tag""" % (RUN_ID, 1146), returns=client.Node)[0]
-TAG2_ID = ret[0]._get_id()
 
 # =========================================
 
@@ -51,147 +57,150 @@
 RETURN frame ORDER BY frame.timestamp
 """ % RUN_NAME
 
+
 QUERY2 = """
 START frame = node(%d)
-MATCH frame-[:FRAME_TAG]-tag
-RETURN tag.name
+MATCH frame-[:FRAME_ACTOR]-actor
+RETURN actor.name
 """ % FRAME_ID
 
+
 QUERY3 = """
-START frame=node(%s)
-MATCH frame-[r:FRAME_EDGE]-edge
+START frame = node(%s)
+MATCH frame-[r:FRAME_INTERACTION]-interaction
 WHERE r.weight > %d 
-RETURN edge.tag1, edge.tag2, r.weight;
+RETURN interaction.actor1, interaction.actor2, r.weight;
 """ % (FRAME_ID, 0)
 
+
 QUERY4 = """
 START run = node(%d)
-MATCH run-[:RUN_TAG]->tag<-[r:FRAME_TAG]-()
-RETURN tag.name, count(r)
+MATCH run-[:RUN_ACTOR]->actor<-[r:FRAME_ACTOR]-()
+RETURN actor.name, count(r)
 """ % RUN_ID
 
+
 QUERY5 = """
 START run = node(%d)
-MATCH run-[:RUN_TAG]->tag<-[r:FRAME_TAG]-()
-WITH tag.name as name, COUNT(r) as freq
+MATCH run-[:RUN_ACTOR]->actor<-[r:FRAME_ACTOR]-()
+WITH actor.name as name, COUNT(r) as freq
 WHERE freq > 1000
 RETURN name, freq ORDER BY freq DESC
 """ % RUN_ID
 
+
 QUERY5b = """
 START run = node(%d)
-MATCH run-[:RUN_TAG]-tag
-WITH tag
-MATCH ()-[r:FRAME_TAG]-tag
-WITH tag.name as name, COUNT(r) as freq
+MATCH run-[:RUN_ACTOR]-actor
+WITH actor
+MATCH ()-[r:FRAME_ACTOR]-actor
+WITH actor.name as name, COUNT(r) as freq
 WHERE freq > 1000
 RETURN name, freq ORDER BY freq DESC;
 """ % RUN_ID
 
+
 QUERY6 = """
-START tag = node(%d)
-MATCH ()-[d:NEXT_LEVEL]->()-[:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-()-[:FRAME_TAG]-tag
+START actor = node(%d)
+MATCH ()-[d:NEXT_LEVEL]->()-[:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-()-[:FRAME_ACTOR]-actor
 RETURN DISTINCT(d.day)
-""" % TAG_ID
+""" % ACTOR_ID
+
 
 QUERY6b = """
-START tag = node(%d)
-MATCH frame-[:FRAME_TAG]-tag
+START actor = node(%d)
+MATCH frame-[:FRAME_ACTOR]-actor
 RETURN DISTINCT(frame.day)
-""" % TAG_ID
+""" % ACTOR_ID
+
 
 QUERY7 = """
-START tag1 = node(%d)
-MATCH tag1<-[:EDGE_TAG]-()-[:EDGE_TAG]->tag2
-RETURN tag2.name ORDER BY tag2.name
-""" % TAG_ID
+START actor1 = node(%d)
+MATCH actor1<-[:INTERACTION_ACTOR]-()-[:INTERACTION_ACTOR]->actor2
+RETURN actor2.name ORDER BY actor2.name
+""" % ACTOR_ID
+
 
 QUERY8 = """
-START tag1 = node(%d)
-MATCH tag1<-[:EDGE_TAG]-edge-[:EDGE_TAG]->tag2
-WITH edge, tag2
-MATCH ()-[d:NEXT_LEVEL]->()-[:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-()-[:FRAME_EDGE]-edge
+START actor1 = node(%d)
+MATCH actor1<-[:INTERACTION_ACTOR]-interaction-[:INTERACTION_ACTOR]->actor2
+WITH interaction, actor2
+MATCH ()-[d:NEXT_LEVEL]->()-[:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-()-[:FRAME_INTERACTION]-interaction
 WHERE d.day = 7
-RETURN DISTINCT(tag2.name)
-""" % TAG_ID
+RETURN DISTINCT(actor2.name)
+""" % ACTOR_ID
+
 
 QUERY9 = """
-START tag1 = node(%d), tag2 = node(%d)
-MATCH tag1<-[:EDGE_TAG]-()-[:EDGE_TAG]->tag
-WITH COLLECT(tag) as neighs1, tag2
-MATCH tag2<-[:EDGE_TAG]-()-[:EDGE_TAG]->tag
-WHERE tag IN neighs1
-RETURN tag
-""" % (TAG1_ID, TAG2_ID)
+START actor1 = node(%d), actor2 = node(%d)
+MATCH actor1<-[:INTERACTION_ACTOR]-()-[:INTERACTION_ACTOR]->actor
+WITH COLLECT(actor) as neighs1, actor2
+MATCH actor2<-[:INTERACTION_ACTOR]-()-[:INTERACTION_ACTOR]->actor
+WHERE actor IN neighs1
+RETURN actor
+""" % (ACTOR1_ID, ACTOR2_ID)
+
 
 QUERY9b = """
-START tag1 = node(%d), tag2 = node(%d)
-MATCH tag1<-[:EDGE_TAG]-()-[:EDGE_TAG]->tag<-[:EDGE_TAG]-()-[:EDGE_TAG]->tag2
-RETURN tag
-""" % (TAG1_ID, TAG2_ID)
+START actor1 = node(%d), actor2 = node(%d)
+MATCH actor1<-[:INTERACTION_ACTOR]-()-[:INTERACTION_ACTOR]->actor<-[:INTERACTION_ACTOR]-()-[:INTERACTION_ACTOR]->actor2
+RETURN actor
+""" % (ACTOR1_ID, ACTOR2_ID)
+
 
 QUERY10 = """
 START run = node(%d)
-MATCH run-[:RUN_TAG]-tag-[r:EDGE_TAG]-()
-RETURN tag.name, COUNT(r) ORDER BY COUNT(r) DESC
+MATCH run-[:RUN_ACTOR]-actor-[r:INTERACTION_ACTOR]-()
+RETURN actor.name, COUNT(r) ORDER BY COUNT(r) DESC
 """ % RUN_ID
 
-# get the tag focused network during the day 29, hour 10
 
 QUERY11a = """
-START tag = node(%d)
-MATCH neigh1<-[:EDGE_TAG]-edge1-[:EDGE_TAG]->tag,
-      ()-[d1:NEXT_LEVEL]->()-[h1:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-frame-[:FRAME_EDGE]-edge1
+START actor = node(%d)
+MATCH neigh1<-[:INTERACTION_ACTOR]-interaction1-[:INTERACTION_ACTOR]->actor,
+      ()-[d1:NEXT_LEVEL]->()-[h1:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-frame-[:FRAME_INTERACTION]-interaction1
 WHERE d1.day = 29 and h1.hour = 10
-WITH  distinct neigh1, tag
-MATCH neigh2<-[:EDGE_TAG]-edge2-[:EDGE_TAG]->tag,
-      ()-[d2:NEXT_LEVEL]->()-[h2:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-frame-[:FRAME_EDGE]-edge2
+WITH DISTINCT neigh1, actor
+MATCH neigh2<-[:INTERACTION_ACTOR]-interaction2-[:INTERACTION_ACTOR]->actor,
+      ()-[d2:NEXT_LEVEL]->()-[h2:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-frame-[:FRAME_INTERACTION]-interaction2
 WHERE d2.day = 29 and h2.hour = 10
 WITH distinct neigh2, neigh1
-MATCH neigh1<-[:EDGE_TAG]-edge3-[:EDGE_TAG]->neigh2,
-      ()-[d3:NEXT_LEVEL]->()-[h3:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-frame-[:FRAME_EDGE]-edge3
+MATCH neigh1<-[:INTERACTION_ACTOR]-interaction3-[:INTERACTION_ACTOR]->neigh2,
+      ()-[d3:NEXT_LEVEL]->()-[h3:NEXT_LEVEL]->()-[:TIMELINE_INSTANCE]-frame-[:FRAME_INTERACTION]-interaction3
 WHERE d3.day = 29 and h3.hour = 10
-RETURN distinct neigh1.tag, neigh2.tag ORDER BY neigh1.tag, neigh2.tag;
-""" % TAG_ID
+RETURN DISTINCT neigh1.actor, neigh2.actor ORDER BY neigh1.actor, neigh2.actor;
+""" % ACTOR_ID
 
-ret = gdb.query(q="""
-START run = node(%d)
-MATCH run-[:HAS_TIMELINE]->()-[y:NEXT_LEVEL]->()-[m:NEXT_LEVEL]->()-[d:NEXT_LEVEL]->()-[h:NEXT_LEVEL]->hour
-WHERE d.day = 29 and h.hour = 10
-RETURN hour
-""" % RUN_ID, returns=client.Node)[0]
-HOUR_ID = ret[0]._get_id()
 
 QUERY11b = """
-START tag = node(%d), hour = node(%d)
-MATCH neigh1<-[:EDGE_TAG]-edge1-[:EDGE_TAG]->tag,
-      hour-[:TIMELINE_INSTANCE]->frame-[:FRAME_EDGE]->edge1
-WITH  distinct hour, neigh1, tag
-MATCH neigh2<-[:EDGE_TAG]-edge2-[:EDGE_TAG]->tag,
-      hour-[:TIMELINE_INSTANCE]->frame-[:FRAME_EDGE]->edge2
-WITH distinct hour, neigh1, neigh2
-MATCH neigh1<-[:EDGE_TAG]-edge3-[:EDGE_TAG]->neigh2,
-      hour-[:TIMELINE_INSTANCE]->frame-[:FRAME_EDGE]->edge3
-RETURN distinct neigh1.tag, neigh2.tag ORDER BY neigh1.tag, neigh2.tag;
-""" % (TAG_ID, HOUR_ID)
+START actor = node(%d), hour = node(%d)
+MATCH neigh1<-[:INTERACTION_ACTOR]-interaction1-[:INTERACTION_ACTOR]->actor,
+      hour-[:TIMELINE_INSTANCE]->frame-[:FRAME_INTERACTION]->interaction1
+WITH DISTINCT hour, neigh1, actor
+MATCH neigh2<-[:INTERACTION_ACTOR]-interaction2-[:INTERACTION_ACTOR]->actor,
+      hour-[:TIMELINE_INSTANCE]->frame-[:FRAME_INTERACTION]->interaction2
+WITH DISTINCT hour, neigh1, neigh2
+MATCH neigh1<-[:INTERACTION_ACTOR]-interaction3-[:INTERACTION_ACTOR]->neigh2,
+      hour-[:TIMELINE_INSTANCE]->frame-[:FRAME_INTERACTION]->interaction3
+RETURN DISTINCT neigh1.actor, neigh2.actor ORDER BY neigh1.actor, neigh2.actor;
+""" % (ACTOR_ID, HOUR_ID)
+
 
 QUERY11c = """
-START tag = node(%d)
-MATCH neigh1<-[:EDGE_TAG]-edge1-[:EDGE_TAG]->tag,
-      frame1-[:FRAME_EDGE]->edge1
+START actor = node(%d)
+MATCH neigh1<-[:INTERACTION_ACTOR]-interaction1-[:INTERACTION_ACTOR]->actor,
+      frame1-[:FRAME_INTERACTION]->interaction1
 WHERE frame1.day = 29 and frame1.hour = 10
-WITH  distinct neigh1, tag
-MATCH neigh2<-[:EDGE_TAG]-edge2-[:EDGE_TAG]->tag,
-      frame2-[:FRAME_EDGE]->edge2
+WITH DISTINCT neigh1, actor
+MATCH neigh2<-[:INTERACTION_ACTOR]-interaction2-[:INTERACTION_ACTOR]->actor,
+      frame2-[:FRAME_INTERACTION]->interaction2
 WHERE frame2.day = 29 and frame2.hour = 10
-WITH  distinct neigh1, neigh2
-MATCH neigh1<-[:EDGE_TAG]-edge3-[:EDGE_TAG]->neigh2,
-      frame3-[:FRAME_EDGE]->edge3
+WITH DISTINCT neigh1, neigh2
+MATCH neigh1<-[:INTERACTION_ACTOR]-interaction3-[:INTERACTION_ACTOR]->neigh2,
+      frame3-[:FRAME_INTERACTION]->interaction3
 WHERE frame3.day = 29 and frame3.hour = 10
-RETURN distinct neigh1.tag, neigh2.tag ORDER BY neigh1.tag, neigh2.tag;
-
-""" % TAG_ID
-
+RETURN DISTINCT neigh1.actor, neigh2.actor ORDER BY neigh1.actor, neigh2.actor;
+""" % ACTOR_ID
 
 
 
@@ -202,6 +211,7 @@
     ('QUERY10', QUERY10),
     ('QUERY11a', QUERY11a), ('QUERY11b', QUERY11b), ('QUERY11c', QUERY11c) ]
 
+
 # =========================================
 
 def time_query(gdb, query, N=10):