我正在逐步向我的Neo4j数据库添加数据,但我卡在如何覆盖或更新现有数据以及检查数据是否已经存在于其中。
基本上,我有一组电影及其对应的ID,例如:
[
{id: 'gameofthrones', genre: 'fantasy', release: '2017'},
{id: 'inception', genre: 'scifi', release: '2010'},
...
]
我可以按照以下方式添加电影:
CREATE
(m1:Movie {id: 'gameofthrones', genre: 'fantasy', release: '2017'}),
(m2:Movie {id: 'inception', genre: 'scifi', release: '2010'})
然而,当我运行脚本两次时,它会创建4个节点而不是保持在两个节点。所以我的问题是,如何确保它检查节点
id
是否已经存在,如果存在则覆盖它而不是创建一个新节点?我尝试过(但只有属性被添加)。// data
attributes['id'] = 'gameofthrones';
attributes['genre'] = 'fantasy';
...
// query
MERGE ( s:Movie {attributes}.id)
ON CREATE SET ( s:Movie {attributes} )
我在 NodeJS
中称之为:
executeQuery(queryStr, {"attributes": attributes})
// cypher (nodejs)
function executeQuery(queryStr, params) {
var qq = Q.defer();
db.cypher({
query: queryStr,
params: params,
}, function (error, results) {
if (error) {
qq.reject(error);
} else {
if (results.length != 0) {
qq.resolve(true);
} else {
qq.resolve(false);
}
};
});
return qq.promise;
};