phaserecordcreator.java

短信开发用于文件交换处理转发的类模块

package com.pub.backserver.phase;

import com.pub.berkeleydb.DefaultRecordCreator;
import org.apache.log4j.Logger;
import org.apache.mina.common.ByteBuffer;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2005</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class PhaseRecordCreator extends DefaultRecordCreator {
    private static Logger log = Logger.getLogger(PhaseRecordCreator.class);
//  public PhaseRecordCreator() {
//    super(PhaseEntity.class);
//  }

  public void toKey(ByteBuffer out, Object r) {
    PhaseEntity pe = (PhaseEntity)r;
    out.put(pe.bytesPhase(),0,pe.phaseLength);
 }

  public void fromKey(ByteBuffer in, Object r) {
    PhaseEntity pe = (PhaseEntity)r;
    pe.bytesPhase(in.array(),in.position());
    in.position(in.position() + PhaseEntity.phaseLength/*Math.min(in.array().length , PhaseRecord.phaseLength)*/
        /*in.array().length > PhaseRecord.phaseLength ? PhaseRecord.phaseLength : in.array().length*/);
  }

  public void toValue(ByteBuffer out, Object r) {
    PhaseEntity pe = (PhaseEntity)r;
    out.putShort(pe.getProvID());
    out.putShort(pe.getCityID());
    out.putShort(pe.getGwID());
  }

  public void fromValue(ByteBuffer in, Object r) {
    PhaseEntity pe = (PhaseEntity)r;
    pe.setProvID(in.getShort());
    pe.setCityID(in.getShort());
    pe.setGwID(in.getShort());
  }

}