Recipe: Batch Projection

const mutations = [
  "MERGE (p:Person {id: 'p1', name: 'Alice'})",
  "MERGE (p:Person {id: 'p2', name: 'Bob'})",
  "MERGE (o:Org {id: 'o1', name: 'Acme'})",
]
const count = db.batchMutate(mutations)
// count === 3

// Phase 1: Create all nodes
db.batchMutate([
  "MERGE (p:Person {id: 'p1', name: 'Alice', workspaceId: 'ws1'})",
  "MERGE (o:Org {id: 'o1', name: 'Acme', workspaceId: 'ws1'})",
  "MERGE (f:Fact {uuid: 'f1', predicate: 'employment', confidence: 0.87})",
])
 
// Phase 2: Create all relationships (nodes guaranteed to exist)
db.batchMutate([
  "MATCH (p:Person {id: 'p1'}) MATCH (f:Fact {uuid: 'f1'}) MERGE (p)-[:SUBJECT_OF]->(f)",
  "MATCH (f:Fact {uuid: 'f1'}) MATCH (o:Org {id: 'o1'}) MERGE (f)-[:OBJECT_IS]->(o)",
])

interface PipelineEntity {
  label: string
  id: string
  properties: Record<string, string | number | boolean>
}
 
interface PipelineRelation {
  fromLabel: string
  fromId: string
  toLabel: string
  toId: string
  relType: string
}
 
function projectBatch(db: ArcflowDB, entities: PipelineEntity[], relations: PipelineRelation[]) {
  // Phase 1: Entities
  const entityMutations = entities.map(e => {
    const props = Object.entries(e.properties)
      .map(([k, v]) => `${k}: ${typeof v === 'string' ? `'${v}'` : v}`)
      .join(', ')
    return `MERGE (n:${e.label} {id: '${e.id}', ${props}})`
  })
  db.batchMutate(entityMutations)
 
  // Phase 2: Relationships
  const relMutations = relations.map(r =>
    `MATCH (a:${r.fromLabel} {id: '${r.fromId}'}) MATCH (b:${r.toLabel} {id: '${r.toId}'}) MERGE (a)-[:${r.relType}]->(b)`
  )
  if (relMutations.length > 0) {
    db.batchMutate(relMutations)
  }
}