How to query to get n level depth nodes in neo4j

2022-04-21 06:38 Parth imported from Stackoverflow

I want to write a query that will fetch the ciphers(nodes) along with its child nodes to the n-level.

e.g. if any child is having 1 child node and that child node is also having a sub child and that sub child node is also having a sub child node and it continues to the n times. then I want to fetch a result like

{
P: {
    // parent node info,
    child: [
        // data
        {
            a1: {
                // data
                child: [
                    {
                        a2: {
                            // data

                            // And so on...
                        }
                    }
                ]
            }
        },

        {
            b1: {
                // data
                child: [
                    {
                        b2: {
                            // data
                            // And so on...
                        }
                    }
                ]
            }
        }
    ]
}

1 answer

answered 2022-04-21 10:02 Thennan
```
MATCH(P)-[:child*n]->(C)
RETURN P,C
```
Will return all the nodes in the 'child' path from node P.
'n' specifies the number of hops between P and C with the child relationship.
```
MATCH(P)-[:child*]->(C)
RETURN P,C
```
Will return all the nodes in the 'child' path, irrespective of the number of child relationship hops in-between.
Reference - Specifying varying length paths

See also questions close to this topic

Error message : MongoServerError: bad auth :Authentication failed

What is the reason behind this error? this code I am using to connect to DB.

const uri =`mongodb+srv://${process.env.DB_USER}:${process.env.DB_PASSWORD}@cluster0.xft2s.mongodb.net/myFirstDatabase?retryWrites=true&w=majority`;

In Mongo, If a document I'm saving "Prateek" then I don't want on the next create operation even the "prateek" or "praTEEK", etc is saved

//** If I'm adding a new document with the name: "India", then I don't want that the DB allow another name with the name: "INDIA", "india", "indIA", etc. I'm new and learning, help would be great!!**

// Controller

var Dinosaur = require('../models/dinosaurs');

//addDino
module.exports.addDino = (req, res) => {
    var name = req.body.name;
    var type = req.body.type;
    var height = req.body.height;
    var weight = req.body.weight;
    var Period = req.body.Period;

    req.checkBody('name', 'Name is required').notEmpty();

    var errors = req.validationErrors();
    if (errors)
        return res.status(400).send({
            message: 'Name is Required'
        });
    else {
        let newDino = {
            name: name,
            type: type,
            height: height,
            weight: weight,
            Period: Period
        }
        Dinosaur.addDino(newDino, (err, result) => {
            if (err) {
                if (err.name) return res.status(409).send({
                    message: name + ' Already Exist'
                });
                else if (err.url) return res.json({ status: false, error: { url: "Url already exist" }, message: err.url });
                else return res.json(err, "Server Error");
            }
            else {
                return res.status(200).send({
                    message: "Done"
                });
            }
        });
    }
}

// Model

var mongoose = require('mongoose');

//dinosaur schema
var DinosaurSchema = mongoose.Schema({
    name: {
        type: String,
        unique: true
    },
    type: {
        type: String
    },
    height: {
        type: Number
    },
    weight: {
        type: Number
    },
    Period: {
        type: String
    }
});

var Dinosaur = mongoose.model('dinosaur', DinosaurSchema);

//add
module.exports.addDino = (query, callback) => {
    Dinosaur.create(query, callback);
}

// GetAll, Already Created a new document with the name "Brachiosaurus"

// > Create, a new create with the first letter lower case "brachiosaurus", Don't want it to be pushed.

//Get All, Got pushed.

i am trying to run the node of ganache but getting this error

I am trying to run the node of ganache but getting this error.please resolve my problem.

Connection failure when using airflow to run python script connecting to neo4j database

I'm trying to use airflow to orchestrate a workflow where a neo4j docker is run and then a python script to query data from the neo4j database (the code runs on AWS EC2 instance). I am able to run the neo4j docker successfully. But when I ran the task of querying the database, I got connection error as:

neo4j.exceptions.ServiceUnavailable: Connection to 127.0.0.1:7687 closed without handshake response

If I manually ran the python script on EC2, it can connect to the neo4j database without any issue. The code I am using is as below:

class Neo4jConnection:

    def __init__(self, uri, user, pwd):
        self.__uri = uri
        self.__user = user
        self.__pwd = pwd
        self.__driver = None
        try:
            self.__driver = GraphDatabase.driver(self.__uri, auth=(self.__user, self.__pwd))
            logger.info('SUCCESS: Connected to the Neo4j Database.')
        except Exception as e:
            logger.info('ERROR: Could not connect to the Neo4j Database. See console for details.')
            raise SystemExit(e)

    def close(self):
        if self.__driver is not None:
            self.__driver.close()

    def query(self, query, parameters=None, db=None):
        assert self.__driver is not None, "Driver not initialized!"
        session = None
        response = None
        try:
            session = self.__driver.session(database=db) if db is not None else self.__driver.session()
            response = list(session.run(query, parameters))
        except Exception as e:
            logger.info("Query failed:", e)
        finally:
            if session is not None:
                session.close()
        return response 

class LoadWikiPathway2Neo4j:
    def __init__(self):
        # replace localhost with 127.0.0.1
        self.connection = Neo4jConnection(uri="bolt://localhost:7687",
                                          user="neo4j",
                                          pwd="test")
    def loadData(self):
        WIKIPATHWAY_MOUNTED_DATA_VOLUME = "/home/ec2-user/wikipathway_neo4j/data/Human/"  # the volume is mounted to neo4j docker
        WIKIPATHWAY_DATA_DOCKER_VOLUME = "file:///var/lib/neo4j/data/Human"  # file path in neo4j docker

        # connect db
        graph = self.connection
        # only run once
        graph.query('''MATCH (n) DETACH DELETE n''')
        graph.query('''CALL n10s.graphconfig.init()''')
        graph.query('''CREATE CONSTRAINT n10s_unique_uri IF NOT EXISTS ON (r:Resource) ASSERT r.uri IS UNIQUE''')
        graph.query('''call n10s.nsprefixes.removeAll()''')
        cypher = '''WITH '@prefix biopax:  <http://www.biopax.org/release/biopax-level3.owl#> . \
        @prefix cito:    <http://purl.org/spar/cito/> . \
        @prefix dc:      <http://purl.org/dc/elements/1.1/> . \
        @prefix dcat:     <http://www.w3.org/ns/dcat#> . \
        @prefix dcterms: <http://purl.org/dc/terms/> . \
        @prefix foaf:    <http://xmlns.com/foaf/0.1/> . \
        @prefix freq:    <http://purl.org/cld/freq/> . \
        @prefix gpml:    <http://vocabularies.wikipathways.org/gpml#> . \
        @prefix hmdb:     <https://identifiers.org/hmdb/> . \
        @prefix ncbigene: <https://identifiers.org/ncbigene/> .\
        @prefix owl:     <http://www.w3.org/2002/07/owl#> . \
        @prefix pav:     <http://purl.org/pav/> . \
        @prefix prov:    <http://www.w3.org/ns/prov#> . \
        @prefix pubmed:   <http://www.ncbi.nlm.nih.gov/pubmed/> .\
        @prefix rdf:     <http://www.w3.org/1999/02/22-rdf-syntax-ns#> . \
        @prefix rdfs:    <http://www.w3.org/2000/01/rdf-schema#> . \
        @prefix skos:    <http://www.w3.org/2004/02/skos/core#> . \
        @prefix void:    <http://rdfs.org/ns/void#> . \
        @prefix wp:      <http://vocabularies.wikipathways.org/wp#> . \
        @prefix wprdf:   <http://rdf.wikipathways.org/> . \
        @prefix xsd:     <http://www.w3.org/2001/XMLSchema#> . ' as txt \
        CALL n10s.nsprefixes.addFromText(txt) yield prefix, namespace RETURN prefix, namespace'''
        graph.query(cypher)

        fileLst = os.listdir(WIKIPATHWAY_MOUNTED_DATA_VOLUME)
        # load data
        for filename in fileLst:
            filePath = f'{WIKIPATHWAY_DATA_DOCKER_VOLUME}/{filename}'
            print(filePath)
            cypher = f'''CALL n10s.rdf.import.fetch("{filePath}","Turtle")'''
            logger.info(cypher)
            graph.query(cypher)
            logger.info(f"{filename} is loaded")
        graph.close()

def load_wikipathway_files():
    data = LoadWikiPathway2Neo4j()
    data.loadData()

with DAG(
        default_args=default,
        dag_id=os.path.basename(__file__).replace(".py", ""),
        schedule_interval=None,
        catchup=False,
        start_date=days_ago(1),
        tags=['s3', 'download_wikipathway'],
) as dag:
     loadWikipathwayFile = PythonOperator(
        task_id="load_wikipathway",
        python_callable=load_wikipathway_files
    )

Return count of relationships instead of all
I wonder if anyone can advise how to adjust the following query so that it returns one relationship with a count of the number of actual relationships rather than every relationship? I have some nodes with many relationships and it's killing the graph's performance.
```
MATCH (p:Provider{countorig: "XXXX"})-[r:supplied]-(i:Importer)
RETURN p,  i limit 100
```
Many thanks

How to extract dynamic property names from a json file in Neo4J using Cypher Query

The tags property names are dynamic. e.g. linux and cypher are dynamic in the json. I am trying to extract the dynamic tags and their values and associate them as properties to the Person node. Here is what I have so far:

CALL apoc.load.json("file:///example.json")
YIELD value
MERGE (p:Person {name: value.name})
ON CREATE SET 
p.job = value.job,
p.department = value.department

RETURN p as Person;

example.json:

{
    "name": "Harry",
    "job": "Developer",
    "tags": {
        "linux": "awesome",
        "cypher": "Working on it"
    },

    "department": "IT"

}

neo4j query to get a specific formated response

I am having a node network in the neo4j database which includes multilevel nodes something like,

parent -> child -> sub child -> ...and so on

Now what I need is I need to write a query that will give me the response in the below format.

nodes = [
{
    id: parent1,
    children : [{
        id: child1,
        children: [
            {
                id: sub child1,
                children: [... So on]
            },
            {
                id: sub child2,
                children: [... So on]
            }
        ]
    }]
},
{
    id = parent2,
    children : [...so on]
}
]

How to remotely access an neo4j community container running on azure with python(neo4j module)?
There is a neo4j community version container running on the azure, and i was provided by the dns

http://[remote-address]:7687

if i do curl with proxy(px from github)(office recommended also), i able to get, bolt_routing, transaction, bolt_direct, neo4j_version, neo4j_edition all successfully,

And with 7474 port with web browser i also able to connect to the db and same with neo4j desktop by adding remote db.

but when i do with python neo4j driver, Cannot resolve address [remote-address]:7687
```
import neo4j,sys
link = "bolt://" + sys.argv[1]
print(f"Trying to connect to:  {link}")

def exp():
    try:
        x = neo4j.GraphDatabase.driver(link, auth=("neo4j", "my_pswd"))

        print(x.verify_connectivity())
    except Exception as e:
        print(e)
```
so, how to connect to a container hosted on azure ?

Update:

i tried to connect with IP of the azure instance running, but

Couldn't connect to [IP-address]:7687 (resolved to ('[IP-address]:7687',)):

Failed to establish connection to ResolvedIPv4Address(('[IP-address]', 7687)) (reason [WinError 10060] A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond)

it is connection through web and neo4j browser completely fine, only not through the python script.!!

Related questions

How to query to get n level depth nodes in neo4j

1 answer

See also questions close to this topic