Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
tzaeschke committed Sep 5, 2017
1 parent 799d401 commit 94b492c
Show file tree
Hide file tree
Showing 7 changed files with 15 additions and 18 deletions.
8 changes: 7 additions & 1 deletion src/org/zoodb/internal/DataDeSerializerNoClass.java
Expand Up @@ -65,7 +65,6 @@ private int readHeader(ZooClassDef clsDef, boolean allowSchemaMismatch) {
//read class info:
clsOid = in.getHeaderClassOID();
if (!allowSchemaMismatch && clsOid != clsDef.getOid()) {
System.err.println();
throw new UnsupportedOperationException("Schema evolution not yet supported: " +
clsDef.getClassName() + ": " + Util.oidToString(clsDef.getOid()) + " to " +
Util.oidToString(clsOid));
Expand All @@ -79,6 +78,13 @@ private int readHeader(ZooClassDef clsDef, boolean allowSchemaMismatch) {
//instantiated object, only pages or possibly byte arrays.
}

public static long getClassOid(StorageChannelInput in) {
//skip OID
in.readLong();
//read class info:
return in.getHeaderClassOID();
}

public long getClassOid() {
//readHeader(clsDef)
//Read OID
Expand Down
8 changes: 0 additions & 8 deletions src/org/zoodb/internal/SerialInput.java
Expand Up @@ -57,14 +57,6 @@ public interface SerialInput {

public void skipRead(int nBytes);

// /**
// * Assumes autopaging=true.
// * @param pos
// */
// public void seekPosAP(DATA_TYPE type, long pos);
//
// public void seekPage(DATA_TYPE type, int page, int offs);

public long getHeaderClassOID();

public long getHeaderTimestamp();
Expand Down
4 changes: 2 additions & 2 deletions src/org/zoodb/internal/ZooClassDef.java
Expand Up @@ -545,7 +545,7 @@ public void associateSuperDef(ZooClassDef superDef) {
}

public void associateFields() {
ArrayList<ZooFieldDef> allFields = new ArrayList<ZooFieldDef>();
ArrayList<ZooFieldDef> allFields = new ArrayList<>();

//For PersistenceCapableImpl _super may be null:
ZooClassDef sup = superDef;
Expand Down Expand Up @@ -582,7 +582,7 @@ public ZooFieldDef getField(String attrName) {

public Map<String, ZooFieldDef> getAllFieldsAsMap() {
if (fieldBuffer == null) {
fieldBuffer = new HashMap<String, ZooFieldDef>();
fieldBuffer = new HashMap<>();
for (ZooFieldDef def: getAllFields()) {
fieldBuffer.put(def.getName(), def);
}
Expand Down
6 changes: 4 additions & 2 deletions src/org/zoodb/internal/ZooFieldDef.java
Expand Up @@ -33,9 +33,11 @@

public class ZooFieldDef {

public static final int OFS_INIITIAL = 8; //OID
public static final int BYTES_OF_OID = 8; //length of OID
public static final int BYTES_OF_SCHEMA_OID = 8; //lengths of Schema-OID
public static final int OFS_INIITIAL = BYTES_OF_OID + BYTES_OF_SCHEMA_OID; //OID + Schema-OID

public static enum JdoType {
public enum JdoType {
PRIMITIVE(-1, true),
//Numbers are like SCOs. They cannot be indexable, because they can be 'null'!
//Furthermore, if the type is Number, then it could be everything from boolean to double.
Expand Down
3 changes: 1 addition & 2 deletions src/org/zoodb/internal/server/DiskAccessOneFile.java
Expand Up @@ -663,9 +663,8 @@ public long getObjectClass(long oid) {
}

try {
//TODO use ObjectReader!?!?!
fileInAP.seekPage(PAGE_TYPE.DATA, oie.getPage(), oie.getOffs());
return new DataDeSerializerNoClass(fileInAP).getClassOid();
return DataDeSerializerNoClass.getClassOid(fileInAP);
} catch (Exception e) {
throw DBLogger.newObjectNotFoundException(
"ERROR reading object: " + Util.oidToString(oid));
Expand Down
2 changes: 0 additions & 2 deletions src/org/zoodb/internal/server/StorageChannel.java
Expand Up @@ -36,8 +36,6 @@ public interface StorageChannel {

void close();

void flush();

void write(ByteBuffer buf, long currentPage);

void readPage(ByteBuffer buf, long pageId);
Expand Down
2 changes: 1 addition & 1 deletion src/org/zoodb/jdo/impl/QueryImpl.java
Expand Up @@ -517,7 +517,7 @@ private void applyQueryOnExtent(List<Object> ret, QueryAdvice qa) {
}
}
} else {
DBLogger.LOGGER.warn("query.execute() uses extent without index");
DBLogger.LOGGER.warn("query.execute() found no index to use");
if (DBStatistics.isEnabled()) {
pm.getSession().statsInc(STATS.QU_EXECUTED_WITHOUT_INDEX);
if (!ordering.isEmpty()) {
Expand Down

0 comments on commit 94b492c

Please sign in to comment.