Gremlin-Server与JanusGraph事务机制疑问及配置求助

1. Gremlin-Server的事务支持性及图实例配置 #

Gremlin-Server本身支持事务，事务能力完全取决于底层挂载的图实例是否支持事务：

• 默认Gremlin-Server自带的TinkerGraph实例是非事务型的，因为默认初始化方式未开启事务开关；
• JanusGraph本身是原生支持事务的图数据库，其兼容TinkerPop的接口天然具备事务能力，所以你看到JanusGraph环境下的图实例支持事务。

配置Gremlin-Server图实例启用事务的方法：

• 若使用TinkerGraph：
  修改对应的properties配置文件（如tinkergraph-empty.properties），添加一行：

  gremlin.tinkergraph.transactions=true
  

  或者在gremlin-server.yaml的graphs段用代码初始化事务型实例：

  graphs: {
    graph: org.apache.tinkerpop.gremlin.tinkergraph.structure.TinkerGraph.open(baseConfiguration().set("gremlin.tinkergraph.transactions", true))
  }
  

• 若使用JanusGraph等原生支持事务的图数据库：
  直接在gremlin-server.yaml中挂载对应的JanusGraph配置文件即可，比如：

  graphs: {
    graph: conf/janusgraph-cql.properties
  }
  

2. TinkerPop事务模型重述与遍历结果疑问 #

事务模型重述 #

TinkerPop的事务模型核心规则：每一次完整的遍历执行（从提交请求到遍历结束）对应一个独立事务，无法将多次独立的遍历操作合并到同一个事务中。简单说，每次提交一个遍历请求，这个请求的全流程就是一个事务，执行完成后自动提交（除非显式开启事务会话）。

举例说明 #

• 两次独立遍历（两个事务）：

  // 事务1：创建顶点A
  g.addV("user").property("name", "A").next()
  // 事务2：创建顶点B
  g.addV("user").property("name", "B").next()
  

  这两个操作属于完全独立的事务，其中一个失败不会影响另一个的提交结果。

• 同一遍历中的多步操作（单个事务）：

  // 整个遍历属于一个事务，创建两个顶点
  g.addV("test").as("v1").addV("test").as("v2").select("v1", "v2").next()
  

  若遍历执行失败，两个顶点都不会被持久化。

遍历结果疑问解答 #

你写的g.addV("test").addV("test").next()只返回最后一个顶点，是因为遍历的流特性：

• 第一个addV("test")创建顶点后，遍历流中仅包含这个顶点；
• 第二个addV("test")是对当前流中的元素（第一个顶点）执行创建新顶点的操作，此时遍历流的输出替换为新创建的第二个顶点；
• 因此整个遍历的结果流只有第二个顶点，next()只能获取到它，再次调用自然提示无结果。

获取所有创建顶点的方法：
调整遍历结构，让所有创建的顶点都进入结果流，比如：

• 用union合并两个创建操作的结果：

  g.union(__.addV("test"), __.addV("test")).toList()
  

• 用as和select捕获所有中间顶点：

  g.addV("test").as("v1").addV("test").as("v2").select("v1", "v2").next()
  

• 用inject生成多元素触发多次创建：

  g.inject(1,2).addV("test").toList()
  

  以上写法都能获取到所有创建的顶点，且整个遍历属于同一个事务。

3. gremlingo事务代码报错的原因与解决 #

你用gremlingo的事务代码连接Gremlin-Server时报错，核心原因是当前Gremlin-Server挂载的图实例不支持事务（比如默认的非事务型TinkerGraph）。

解决方法与问题1一致：

1. 修改Gremlin-Server的图实例配置，启用事务型图（参考问题1的配置步骤）；
2. 确保Gremlin-Server与gremlingo使用兼容的TinkerPop版本；
3. 重启Gremlin-Server后，再执行事务代码即可正常工作。

内容的提问来源于stack exchange，提问作者norym