offshore_leaks_import.cypher

CREATE CONSTRAINT ON (n:Address) ASSERT n.node_id IS UNIQUE;
CREATE CONSTRAINT ON (n:Officer) ASSERT n.node_id IS UNIQUE;
CREATE CONSTRAINT ON (n:Entity) ASSERT n.node_id IS UNIQUE;
CREATE CONSTRAINT ON (n:Intermediary) ASSERT n.node_id IS UNIQUE;

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///Addresses.csv" AS line
CREATE (n:Address {node_id: line.node_id })
SET n += line;

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///Officers.csv" AS line
CREATE (n:Officer {node_id: line.node_id })
SET n += line;

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///Entities.csv" AS line
CREATE (n:Entity {node_id: line.node_id })
SET n += line;

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///Intermediaries.csv" AS line
CREATE (n:Intermediary {node_id: line.node_id })
SET n += line;

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///all_edges.csv" AS line
WITH line
WHERE line.rel_type = "intermediary_of"
MATCH (i:Intermediary {node_id: line.node_1} )
MATCH (e:Entity {node_id: line.node_2} )
CREATE (i)-[:INTERMEDIARY_OF]->(e);

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///all_edges.csv" AS line
WITH line
WHERE line.rel_type = "officer_of"
MATCH (n:Intermediary {node_id: line.node_1} )
MATCH (m:Entity {node_id: line.node_2} )
CREATE (n)-[:OFFICER_OF]->(m);

LOAD CSV WITH HEADERS FROM "file:///all_edges.csv" AS line
WITH line
WHERE line.rel_type = "registered_address"
MATCH (n:Entity {node_id: line.node_1} )
MATCH (m:Address {node_id: line.node_2} )
CREATE (n)-[:REGISTERED_ADDRESS]->(m);

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///all_edges.csv" AS line
WITH line
WHERE line.rel_type = "registered_address"
MATCH (n:Intermediary {node_id: line.node_1} )
MATCH (m:Address {node_id: line.node_2} )
CREATE (n)-[:REGISTERED_ADDRESS]->(m);

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///all_edges.csv" AS line
WITH line
WHERE line.rel_type = "similar"
MATCH (n:Intermediary {node_id: line.node_1} )
MATCH (m:Intermediary {node_id: line.node_2} )
CREATE (n)-[:SIMILAR]->(m);

USING PERIODIC COMMIT
LOAD CSV WITH HEADERS FROM "file:///all_edges.csv" AS line
WITH line
WHERE line.rel_type = "underlying"
MATCH (n:Entity {node_id: line.node_1} )
MATCH (m:Entity {node_id: line.node_2} )
CREATE (n)-[:UNDERLYING]->(m);