mirror of
https://github.com/IT4Change/Ocelot-Social.git
synced 2025-12-13 07:45:56 +00:00
Import contributions to neo4j
This commit is contained in:
parent
97e6acf46b
commit
887a6d201f
23
neo4j/import/contributions.cql
Normal file
23
neo4j/import/contributions.cql
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
CALL apoc.load.json('file:/mongo-export/contributions.json') YIELD value as post
|
||||||
|
MERGE (p:Post {id: post._id["$oid"]})
|
||||||
|
ON CREATE SET
|
||||||
|
p.title = post.title,
|
||||||
|
p.slug = post.slug,
|
||||||
|
p.image = post.teaserImg,
|
||||||
|
p.content = post.content,
|
||||||
|
p.contentExcerpt = post.contentExcerpt,
|
||||||
|
p.visibility = toLower(post.visibility),
|
||||||
|
p.createdAt = post.createdAt.`$date`,
|
||||||
|
p.updatedAt = post.updatedAt.`$date`,
|
||||||
|
p.deleted = post.deleted,
|
||||||
|
p.disabled = NOT post.isEnabled
|
||||||
|
WITH p, post, post.tags AS tags, post.categoryIds as categoryIds
|
||||||
|
UNWIND tags AS tag
|
||||||
|
UNWIND categoryIds AS categoryId
|
||||||
|
MATCH (c:Category {id: categoryId}),
|
||||||
|
(u:User {id: post.userId})
|
||||||
|
MERGE (t:Tag {id: apoc.create.uuid(), name: tag})
|
||||||
|
MERGE (p)-[:TAGGED]->(t)
|
||||||
|
MERGE (u)-[:WROTE]->(p)
|
||||||
|
MERGE (p)-[:CATEGORIZED]->(c)
|
||||||
|
;
|
||||||
@ -13,25 +13,6 @@ ON CREATE SET b.key = badge.key,
|
|||||||
b.status = badge.status
|
b.status = badge.status
|
||||||
|
|
||||||
|
|
||||||
CALL apoc.load.json('file:/mongo-export/contributions.json') YIELD value as post
|
|
||||||
MERGE (p:Post {id: post._id["$oid"]})
|
|
||||||
ON CREATE SET p.title = post.title,
|
|
||||||
p.slug = post.slug,
|
|
||||||
p.image = post.teaserImg,
|
|
||||||
p.content = post.content,
|
|
||||||
p.contentExcerpt = post.contentExcerpt,
|
|
||||||
p.visibility = apoc.text.toUpperCase(post.visibility),
|
|
||||||
p.createdAt = datetime(post.createdAt["$date"]),
|
|
||||||
p.updatedAt = datetime(post.updatedAt["$date"])
|
|
||||||
WITH p, post, post.tags AS tags, post.categoryIds as categoryIds
|
|
||||||
UNWIND tags AS tag
|
|
||||||
UNWIND categoryIds AS categoryId
|
|
||||||
MATCH (c:Category {id: categoryId}),
|
|
||||||
(u:User {id: post.userId})
|
|
||||||
MERGE (t:Tag {id: apoc.create.uuid(), name: tag})
|
|
||||||
MERGE (p)-[:TAGGED]->(t)
|
|
||||||
MERGE (u)-[:WROTE]->(p)
|
|
||||||
MERGE (p)-[:CATEGORIZED]->(c)
|
|
||||||
|
|
||||||
|
|
||||||
CALL apoc.load.json('file:/mongo-export/comments.json') YIELD value as comment
|
CALL apoc.load.json('file:/mongo-export/comments.json') YIELD value as comment
|
||||||
@ -11,7 +11,7 @@ u.wasInvited = user.wasInvited,
|
|||||||
u.role = toLower(user.role),
|
u.role = toLower(user.role),
|
||||||
u.createdAt = user.createdAt.`$date`,
|
u.createdAt = user.createdAt.`$date`,
|
||||||
u.updatedAt = user.updatedAt.`$date`,
|
u.updatedAt = user.updatedAt.`$date`,
|
||||||
u.deleted = false,
|
u.deleted = user.deletedAt IS NOT NULL,
|
||||||
u.disabled = false
|
u.disabled = false
|
||||||
WITH u, user, user.badgeIds AS badgeIds
|
WITH u, user, user.badgeIds AS badgeIds
|
||||||
UNWIND badgeIds AS badgeId
|
UNWIND badgeIds AS badgeId
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user