6

我正在迭代地将数据添加到我的 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;
};
4

2 回答 2

4

您必须将您的查询更改为此

MERGE ( s:Movie {attributes}.id)
ON CREATE SET s += {attributes}
ON MATCH SET s += {attributes} // optional

这应该可以，但是您应该使用 apoc.map.clean() 这样您就不会设置 id 两次，这可能会导致一些问题。

MERGE ( s:Movie {attributes}.id)
ON CREATE SET s += apoc.map.clean({attributes},['id'],[])
于 2017-03-13T13:46:08.127 回答
3

MERGE您可以使用以下子句实现此目的

MERGE (m1:Movie {id: 'gameofthrones'})
ON CREATE SET m1.genre = 'fantasy', m1.release = '2017'

MERGE (m2:Movie {id: 'inception'})
ON CREATE SET m2.genre: 'scifi', m2.release = '2010'

理想情况下，您希望使用参数而不是文字字符串创建查询。如果您使用 apoc.load.json，您可以实现此目的

with "file:///home/sample.json" as url // can be also http://url/sample.json
CALL apoc.load.json(url) yield value
UNWIND value as item
MERGE (m1:Movie {id: item.id})
ON CREATE SET m1.genre = item.genre, m1.release = item.release

具有 apoc 函数的动态属性示例：

with "file:///home/sample.json" as url // can be also http://url/sample.json
CALL apoc.load.json(url) yield value
UNWIND value as item
MERGE (m1:Movie {id: item.id})
ON CREATE SET m1 += apoc.map.clean(item,['id'],[])

或者如果您没有 apoc 插件：

with "file:///home/sample.json" as url // can be also http://url/sample.json
CALL apoc.load.json(url) yield value
UNWIND value as item
MERGE (m1:Movie {id: item.id})
ON CREATE SET m1 += item

请注意， id 将首先合并，然后更新，ON CREATE SET并且您希望避免两次写入单个属性，使用 apoc 和上面的查询我们可以实现

于 2017-03-13T11:38:38.600 回答