Gremlin-Java中动态批量插入顶点：addV的高效使用指南

import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
import org.apache.tinkerpop.gremlin.structure.T; // 导入T.id

// 假设 g 是一个已初始化的 GraphTraversalSource 实例
// 例如：GraphTraversalSource g = TinkerGraph.open().traversal();

// 初始查询，可以为空或包含第一个addV
GraphTraversal<?, ?> query = g.addV("person").property(T.id, "v1").property("name", "Alice");

// 在循环中动态添加更多顶点
// 假设有更多顶点数据，例如从CSV文件读取
String[][] vertexData = {
    {"v2", "Bob"},
    {"v3", "Charlie"},
    {"v4", "David"}
};

for (String[] data : vertexData) {
    query = query.addV("person")
                 .property(T.id, data[0])
                 .property("name", data[1]);
}

// 提交查询以执行所有插入操作
// 注意：对于插入操作，通常使用 iterate() 来触发执行，因为我们不期望有返回值
query.iterate();

System.out.println("顶点插入完成。");

import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
import org.apache.tinkerpop.gremlin.structure.T;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.HashMap;

// 假设 g 是一个已初始化的 GraphTraversalSource 实例

// 准备要插入的顶点数据，以Map列表的形式
List<Map<String, Object>> vertexData = Arrays.asList(
    new HashMap<String, Object>() {{ put(T.id.name(), "v347"); put("label", "test"); put("name", "Son"); }},
    new HashMap<String, Object>() {{ put(T.id.name(), "v348"); put("label", "test"); put("name", "Messi"); }},
    new HashMap<String, Object>() {{ put(T.id.name(), "v349"); put("label", "test"); put("name", "Suarez"); }},
    new HashMap<String, Object>() {{ put(T.id.name(), "v350"); put("label", "test"); put("name", "Kane"); }}
);

// 构建并执行批量插入查询
g.inject(vertexData) // 注入数据列表
 .unfold()           // 将列表展开为单个Map元素
 .addV(org.apache.tinkerpop.gremlin.process.traversal.P.select("label")) // 使用Map中的"label"键作为顶点标签
 .property(T.id, org.apache.tinkerpop.gremlin.process.traversal.P.select(T.id.name())) // 使用Map中的T.id作为顶点ID
 .property("name", org.apache.tinkerpop.gremlin.process.traversal.P.select("name")) // 使用Map中的"name"作为顶点属性
 .iterate(); // 提交查询

System.out.println("批量顶点插入完成。");

import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
import org.apache.tinkerpop.gremlin.structure.T;
import java.util.Map;
import java.util.HashMap;

// 假设 g 是一个已初始化的 GraphTraversalSource 实例

// 场景1: 基于ID进行upsert
Map<Object, Object> vertexData1 = new HashMap<>();
vertexData1.put(T.id, "v101");
vertexData1.put(T.label, "person");
vertexData1.put("name", "Alice Updated");
vertexData1.put("age", 30);

g.mergeV(vertexData1) // 如果存在ID为"v101"的顶点，则更新其属性；否则创建新顶点
 .option(org.apache.tinkerpop.gremlin.process.traversal.Merge.onCreate, 
         org.apache.tinkerpop.gremlin.process.traversal.P.constant(vertexData1)) // 创建时设置所有属性
 .option(org.apache.tinkerpop.gremlin.process.traversal.Merge.onMatch, 
         org.apache.tinkerpop.gremlin.process.traversal.P.constant(vertexData1)) // 匹配时更新所有属性
 .iterate();

// 场景2: 基于属性进行upsert (例如，根据name属性查找或创建)
Map<Object, Object> vertexData2 = new HashMap<>();
vertexData2.put("name", "Bob");
vertexData2.put(T.label, "person");
vertexData2.put("city", "New York");

g.mergeV(vertexData2) // 查找或创建name为"Bob"的person顶点
 .option(org.apache.tinkerpop.gremlin.process.traversal.Merge.onCreate, 
         org.apache.tinkerpop.gremlin.process.traversal.P.constant(vertexData2))
 .option(org.apache.tinkerpop.gremlin.process.traversal.Merge.onMatch, 
         org.apache.tinkerpop.gremlin.process.traversal.P.constant(vertexData2))
 .iterate();

System.out.println("使用mergeV进行upsert操作完成。");