事务处理 #

事务特点（ACID）：
├── 原子性（Atomicity）：事务不可分割
├── 一致性（Consistency）：数据保持一致
├── 隔离性（Isolation）：事务互不干扰
└── 持久性（Durability）：提交后永久保存

Neo4j事务特点：
├── 完全支持ACID
├── 支持嵌套事务
├── 支持分布式事务
├── 自动锁管理
└── 支持事务超时

CREATE (p:Person {name: 'Tom'})
RETURN p

隐式事务范围：
├── 单条语句
├── 自动提交
├── 失败自动回滚
└── 无需显式控制

BEGIN

COMMIT

ROLLBACK

BEGIN
CREATE (p:Person {name: 'Tom'})
CREATE (p)-[:KNOWS]->(:Person {name: 'Jerry'})
COMMIT

BEGIN
CREATE (p:Person {name: 'Tom'})
ROLLBACK

CALL dbms.setConfigValue('dbms.tx_isolation', 'read_committed')

CALL dbms.setConfigValue('dbms.transaction.timeout', '30s')

CALL dbms.listConfig() YIELD name, value
WHERE name = 'dbms.transaction.timeout'
RETURN value

CALL dbms.listTransactions()

CALL dbms.killTransaction('transaction-id')

UNWIND range(1, 10000) AS id
CALL {
    WITH id
    CREATE (p:Person {id: id})
} IN TRANSACTIONS OF 1000 ROWS

LOAD CSV WITH HEADERS FROM 'file:///data.csv' AS row
CALL {
    WITH row
    CREATE (p:Person {id: row.id, name: row.name})
} IN TRANSACTIONS OF 1000 ROWS

MATCH (p:Person)
CALL {
    WITH p
    SET p.processed = true
} IN TRANSACTIONS OF 1000 ROWS

MATCH (p:Person {id: 'person_001'})
SET p.locked = true

建议：
├── 按相同顺序访问资源
├── 减少事务持有时间
├── 避免长事务
└── 使用合理的隔离级别

建议：
├── 单个事务不超过10000个操作
├── 使用分批处理大数据量
├── 避免在一个事务中处理过多数据
└── 合理设置事务超时

原则：
├── 事务尽可能短
├── 避免在事务中执行耗时操作
├── 合理使用索引
├── 避免热点数据竞争
└── 使用乐观锁处理并发

TRY
    CREATE (p:Person {id: 'person_001'})
CATCH
    RETURN 'Error: ' + errorMessage
END

BEGIN
MATCH (u:User {id: 'user_001'})
MATCH (p:Product {id: 'prod_001'})
CREATE (o:Order {
    id: 'order_001',
    status: 'pending',
    createdAt: datetime()
})
CREATE (u)-[:PLACED]->(o)
CREATE (o)-[:CONTAINS {quantity: 1}]->(p)
SET p.stock = p.stock - 1
COMMIT

BEGIN
MATCH (a:Account {id: 'account_001'})
MATCH (b:Account {id: 'account_002'})
SET a.balance = a.balance - 100
SET b.balance = b.balance + 100
CREATE (t:Transaction {
    id: 'tx_001',
    amount: 100,
    from: a.id,
    to: b.id,
    createdAt: datetime()
})
CREATE (a)-[:SENT]->(t)
CREATE (t)-[:RECEIVED]->(b)
COMMIT

LOAD CSV WITH HEADERS FROM 'file:///users.csv' AS row
CALL {
    WITH row
    MERGE (u:User {id: row.id})
    SET u += {
        name: row.name,
        email: row.email,
        createdAt: datetime()
    }
} IN TRANSACTIONS OF 1000 ROWS