事务管理

事务概念

事务是数据库操作的基本单位，具有 ACID 特性：

• 原子性（Atomicity）：事务中的所有操作要么全部成功，要么全部失败回滚
• 一致性（Consistency）：事务执行前后，数据库状态保持一致
• 隔离性（Isolation）：多个事务并发执行时，彼此之间互不影响
• 持久性（Durability）：事务提交后，数据变更永久保存

事务操作

基本语法

// 开始事务
BEGIN

// 执行操作
CREATE (n:Person {name: 'John'})

// 提交事务
COMMIT

// 回滚事务
ROLLBACK

示例

1. 基本事务

   // 开始事务
   BEGIN
   
   // 创建节点
   CREATE (a:Person {name: 'John'})
   CREATE (b:Person {name: 'Alice'})
   
   // 创建关系
   CREATE (a)-[:FRIENDS_WITH]->(b)
   
   // 提交事务
   COMMIT

2. 带条件的事务

   // 开始事务
   BEGIN
   
   // 检查是否存在
   MATCH (p:Person {name: 'John'})
   
   // 如果不存在则创建
   FOREACH (p IN CASE WHEN p IS NULL THEN [1] ELSE [] END |
     CREATE (p:Person {name: 'John'})
   )
   
   // 提交事务
   COMMIT

3. 使用参数的事务

   // 开始事务
   BEGIN
   
   // 使用参数
   CREATE (p:Person $person)
   
   // 提交事务
   COMMIT
   
   // 参数示例: {person: {name: 'John', age: 30}}

事务隔离级别

Neo4j 支持不同的事务隔离级别，用于控制并发事务之间的相互影响。

隔离级别

1. READ_COMMITTED（默认）：读取已提交的数据
2. SNAPSHOT：读取事务开始时的数据快照

设置隔离级别

// 设置隔离级别为 SNAPSHOT
:begin transaction isolation level SNAPSHOT

// 执行操作
MATCH (p:Person)
RETURN p

// 提交事务
:commit

事务失败处理

错误处理

当事务执行过程中出现错误时，Neo4j 会自动回滚事务，确保数据一致性。

常见错误

1. 唯一性约束违反

   // 尝试创建重复的唯一属性
   CREATE (p:Person {email: 'john@example.com'})
   CREATE (p:Person {email: 'john@example.com'}) // 会失败

2. 存在约束违反

   // 尝试创建缺少必填属性的节点
   CREATE (p:Person) // 如果 name 属性有存在约束，会失败

3. 关系完整性错误

   // 尝试创建指向不存在节点的关系
   MATCH (a:Person {name: 'John'})
   CREATE (a)-[:FRIENDS_WITH]->(b:Person {name: 'Alice'}) // 如果 John 不存在，会失败

处理错误的策略

1. 使用 MERGE 替代 CREATE

   // 使用 MERGE 避免重复创建
   MERGE (p:Person {email: 'john@example.com'})
   ON CREATE SET p.name = 'John'

2. 使用 OPTIONAL MATCH

   // 使用 OPTIONAL MATCH 处理不存在的节点
   OPTIONAL MATCH (a:Person {name: 'John'})
   OPTIONAL MATCH (b:Person {name: 'Alice'})
   WHERE a IS NOT NULL AND b IS NOT NULL
   CREATE (a)-[:FRIENDS_WITH]->(b)

3. 使用事务重试

   // 伪代码：事务重试逻辑
   let retries = 3;
   while (retries > 0) {
     try {
       // 执行事务
       break;
     } catch (error) {
       retries--;
       if (retries == 0) {
         throw error;
       }
       // 等待一段时间后重试
       sleep(100);
     }
   }

事务最佳实践

1. 保持事务简短

• 事务执行时间过长会占用数据库资源
• 长时间运行的事务可能导致锁争用
• 建议将大型操作拆分为多个小事务

2. 避免死锁

• 按照相同的顺序访问节点和关系
• 避免在事务中执行长时间的计算
• 使用适当的索引减少锁争用

3. 使用批量操作

• 对于大量数据的导入，使用批量操作
• 每批次处理适当数量的记录
• 定期提交事务以释放资源

4. 监控事务性能

• 使用 Neo4j 监控工具跟踪事务执行情况
• 识别慢事务并进行优化
• 调整事务超时设置

5. 合理使用锁

• 了解 Neo4j 的锁机制
• 避免不必要的锁争用
• 使用适当的隔离级别

示例：批量导入数据

// 批量导入数据的事务
BEGIN

// 导入多个节点
UNWIND $persons AS person
CREATE (p:Person)
SET p = person

// 导入多个关系
UNWIND $relationships AS rel
MATCH (a:Person {id: rel.from_id}), (b:Person {id: rel.to_id})
CREATE (a)-[:FRIENDS_WITH]->(b)

// 提交事务
COMMIT

// 参数示例:
// {
//   "persons": [
//     {"id": 1, "name": "John", "age": 30},
//     {"id": 2, "name": "Alice", "age": 28}
//   ],
//   "relationships": [
//     {"from_id": 1, "to_id": 2}
//   ]
// }

小结

事务管理是保证数据一致性和可靠性的重要机制。通过合理使用事务，可以确保数据操作的原子性、一致性、隔离性和持久性。在实际应用中，需要根据具体场景选择合适的事务策略，以提高系统性能和可靠性。

在接下来的章节中，我们将介绍数据导入与导出，这是 Neo4j 数据管理的重要功能。