java - 尝试与 OrientDB 合作

Question

我正在尝试这个简单的代码:

import java.util.List;

import com.orientechnologies.orient.core.exception.OStorageException;
import com.orientechnologies.orient.core.sql.query.OSQLSynchQuery;
import com.orientechnologies.orient.object.db.OObjectDatabasePool;
import com.orientechnologies.orient.object.db.OObjectDatabaseTx;

public class ProgramOrientDB {
  private static TestObjectFiller filler = new TestObjectFiller();

  private static interface DBCallback<T> {
    T call(OObjectDatabaseTx db) throws Exception;
  }

  private static <T> T execWithDB(DBCallback<T> cb) throws Exception {
    OObjectDatabaseTx db;
    try {
      db = OObjectDatabasePool.global().acquire("local:c:/tmp/odb", "admin", "admin");
    } catch (OStorageException exc) {
      db = new OObjectDatabaseTx("local:c:/tmp/odb");
      db.create();
    }
    try {
      return cb.call(db);
    } finally {
      db.close();
    }
  }

  private static TestObject dump(TestObject o) {
    System.out.println(o);
    return o;
  }

  public static void main(String[] args) throws Exception {
    Runtime run = Runtime.getRuntime();
    Process pr = run.exec("cmd /c del /s/q c:\\tmp\\odb");
    pr.waitFor();

    execWithDB(new DBCallback<Void>() {
      @Override
      public Void call(OObjectDatabaseTx db) throws Exception {
        db.getEntityManager().registerEntityClass(TestObject.class);
        dump((TestObject)db.save(filler.randomFill(db.newInstance(TestObject.class))));
        return null;
      }
    });
    execWithDB(new DBCallback<Void>() {
      @Override
      public Void call(OObjectDatabaseTx db) throws Exception {
        db.getEntityManager().registerEntityClass(TestObject.class);
        for (TestObject o : (List<TestObject>)db.query(new OSQLSynchQuery<TestObject>("select * from TestObject"))) {
          System.out.println(o);
        }
        return null;
      }
    });
  }
}

它向控制台输出:

TestObject{prop1: 'captivation', prop2: 'Caribbean's', prop3: -1912492199, prop4: 0.9350339155517686, prop5: false}
TestObject{prop1: 'null', prop2: 'null', prop3: 0, prop4: 0.0, prop5: false}

而我预计第一行会输出两次。谁能找出问题所在吗？

编辑1

这是 TestObject.java:

public class TestObject {
  private String m_prop1;
  private String m_prop2;
  private int m_prop3;
  private double m_prop4;
  private boolean m_prop5;

  public String getProp1() {
    return m_prop1;
  }

  public void setProp1(String prop1) {
    m_prop1 = prop1;
  }

  public String getProp2() {
    return m_prop2;
  }

  public void setProp2(String prop2) {
    m_prop2 = prop2;
  }

  public int getProp3() {
    return m_prop3;
  }

  public void setProp3(int prop3) {
    m_prop3 = prop3;
  }

  public double getProp4() {
    return m_prop4;
  }

  public void setProp4(double prop4) {
    m_prop4 = prop4;
  }

  public boolean isProp5() {
    return m_prop5;
  }

  public void setProp5(boolean prop5) {
    m_prop5 = prop5;
  }

  @Override
  public String toString() {
    final StringBuilder sb = new StringBuilder();
    sb.append("TestObject");
    sb.append("{prop1: '").append(m_prop1).append('\'');
    sb.append(", prop2: '").append(m_prop2).append('\'');
    sb.append(", prop3: ").append(m_prop3);
    sb.append(", prop4: ").append(m_prop4);
    sb.append(", prop5: ").append(m_prop5);
    sb.append('}');
    return sb.toString();
  }
}

编辑2

更改了 TestObject.java 以包含以下字段:

  @javax.persistence.Id
  private Object id;

并添加到toString()。现在程序打印:

TestObject{id: 'null', prop1: 'gnaw', prop2: 'fishermen', prop3: -322577834, prop4: 0.7442149523357203, prop5: true}
TestObject{id: 'null', prop1: 'null', prop2: 'null', prop3: 0, prop4: 0.0, prop5: false}

这也好不了多少。

编辑3

问题是 OObjectProxyMethodHandler.invoke()没有被调用，即使 db.newInstance确实返回代理，我使用 TestObject.setXXX 设置属性方法。我不知道为什么不调用处理程序。

编辑4

好的，处理程序的问题是 OObjectMethodFilter 实现的方法过滤器正在检查方法是否由使用特定命名方案命名的字段支持。 TestObject类不遵循该方案 - 它使用 m_私有(private)字段的前缀，未通过过滤测试。删除了前缀，现在 OObjectProxyMethodHandler.invoke()叫做。然而，最终的结果还是一样。正在进一步调查。

Answer 1

看起来很奇怪，输出没有记录的 RID。您是否出于布局目的删除了它们？