我正在尝试这个简单的代码：
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_私有字段的前缀，这未通过过滤器测试。去掉前缀，现在OObjectProxyMethodHandler.invoke()叫。但是，最终的结果还是一样的。进一步调查。