MMAPI删除边缘后,OrientDB不一致的顶点仍然存在

问题描述

考虑以下代码

private void testMMAPIinLab() {
    OrientDB orientDB = new OrientDB("remote:localhost",OrientDBConfig.defaultConfig());
    
    OrientDBConfigBuilder poolCfg = OrientDBConfig.builder();
    poolCfg.addConfig(OGlobalConfiguration.DB_POOL_MIN,5);
    poolCfg.addConfig(OGlobalConfiguration.DB_POOL_MAX,10);
    //poolCfg.addConfig(OGlobalConfiguration.RID_BAG_EMbedDED_TO_SBTREEBONSAI_THRESHOLD,-1);
    ODatabasePool dbPool = new ODatabasePool(orientDB,"lab","root","toor",poolCfg.build());
    
    
    ODatabaseSession db = dbPool.acquire();

    db.begin();
    System.out.println("creando el vértice....");
    OVertex v1 = db.newVertex();
    v1.save();
    System.out.println("save rid: "+v1.getIdentity().toString());
    
    OVertex v2 = db.newVertex();
    v2.save();
    System.out.println("v2 save rid: "+v2.getIdentity().toString());

    System.out.println("crear un edge.");
    OEdge oe = v1.addEdge(v2);
    v1.save();
    
    System.out.println("llamando a commit...");
    db.commit();
    db.close();
    
    System.out.println("configuración grabada:");
    System.out.println("v1: "+v1.getIdentity().toString());
    System.out.println("v2: "+v2.getIdentity().toString());
    System.out.println("edge: "+oe.getFrom()+" --> "+oe.getTo());
    
    // abrir otra transacción
    db = dbPool.acquire();
    db.begin();
    System.out.println("crear v3");
    OVertex v3 = db.newVertex();
    v3.save();
    System.out.println("v3 save rid: "+v3.getIdentity().toString());
    
    System.out.println("modificar v1...");
    v1.setProperty("value","test");
    
    System.out.println("borrar relación con v2");
    // borrar el edge anterior
    Iterator<OEdge> toRemove = v1.getEdges(ODirection.OUT).iterator();
    while (toRemove.hasNext()) {
        OEdge removeEdge = toRemove.next();
        //removeEdge = (OEdge) edge;
        removeEdge.delete();
        removeEdge.save();
    }
    
    System.out.println("agregar una relación de v1 a v3");
    OEdge oe2 = v1.addEdge(v3);
    
    v1.save();

    // crera en edge nuevo a v3
    db.commit();
    
    System.out.println("v1 edges: "+v1.getEdges(ODirection.OUT));
    System.out.println("v3 post-commit rid: "+v3.getIdentity().toString());
    System.out.println("oe2: "+oe2.getFrom()+" --> "+oe2.getTo());
    
    db.close();
    
}

运行时,您会得到V1,其边缘有两个。一个带有已删除边的EdgeRID,另一个指向V3。 如果您对删除的边缘显示{}感到好奇,并报告404错误。顶点是持久的,因此错误数据库内部。

错误在于移除边缘的那一会儿。如果您使用边参考,它将起作用,但是在实际代码中,我不知道顶点有多少条边。

V2和V3具有正确的IN引用。

我该如何解决

解决方法

这取决于在不同数据库会话之间共享顶点的事实。

一个简单的解决方法是在第二个会话中使用它们之前,先按ID重新加载顶点:

// abrir otra transacción
db = dbPool.acquire();
db.begin();

//RELOAD THE VERTEX BEFORE USING IT AGAIN!
v1 = db.load(v1.getIdentity());