Используя protostuff, как пропустить чтение удаленного объекта?
Я являюсь частью команды, которая использует Protostuff для чтения / записи данных. Это mergeFrom
метод класса простирается от Schema
учебный класс:
@Override
public void mergeFrom(Input input, Entity entity) throws IOException {
for(int number = input.readFieldNumber(this); ; number = input.readFieldNumber(this))
{
if ( number == 0 ) {
break;
} else if ( number == FIELD_DEFINITION_ID ) {
Schema idmSchema = entity.getSchema();
// Definition id
int definitionId = input.readUInt32();
NodeDefinition defn = idmSchema.getById(definitionId);
if ( defn == null ) {
throw new ProtostuffException("Invalid definition id "+definitionId);
}
Node<?> node = defn.createNode();
entity.add(node);
// Node
readAndCheckFieldNumber(input, FIELD_NODE);
input.mergeObject(node, getSchema(node.getClass()));
} else if ( number == FIELD_CHILD_NODE_STATE ){
//Node state
int intState = input.readInt32();
State state = State.parseState(intState);
readAndCheckFieldNumber(input, FIELD_CHILD_DEFINITION_ID);
int childDefnId = input.readInt32();
Schema schema = entity.getSchema();
NodeDefinition childDefn = schema.getById(childDefnId);
entity.childStates.put(childDefn.getName(), state);
} else {
throw new ProtostuffException("Unexpected field number");
}
}
}
Моя текущая задача сейчас состоит в том, чтобы пропустить чтение данных, где схема этих данных уже удалена. Я смотрю на метод handleUnknownField Input
интерфейс.
Кто-нибудь уже сталкивался с этим?
1 ответ
Решение
Решение действительно очень простое. Глядя на эту ссылку: Схема и проверка кода mergeFrom:
public void mergeFrom(Input input, User user) throws IOException
{
while(true)
{
int number = input.readFieldNumber(this);
switch(number)
{
case 0:
return;
case 1:
user.setEmail(input.readString());
break;
case 2:
user.setFirstName(input.readString());
break;
case 3:
user.setLastName(input.readString());
break;
case 4:
if(message.friends == null)
message.friends = new ArrayList<User>();
message.friends.add(input.mergeObject(null, this));
break;
default:
input.handleUnknownField(number, this);
}
}
}
Я думаю, что я должен просто использовать input.handleUnknownField(number, this);
, И это решит мою проблему правильно, так:
...
} else if ( number == FIELD_DEFINITION_ID ) {
Schema idmSchema = entity.getSchema();
// Definition id
int definitionId = input.readUInt32();
NodeDefinition defn = idmSchema.getById(definitionId);
if ( defn == null ) {
input.handleUnknownField(number, this);
continue;
}
Node<?> node = defn.createNode();
entity.add(node);
// Node
readAndCheckFieldNumber(input, FIELD_NODE);
input.mergeObject(node, getSchema(node.getClass()));
}
...
Спасибо, я надеюсь, что это QA принесет пользу другим!