/*- * See the file LICENSE for redistribution information. * * Copyright (c) 2002,2008 Oracle. All rights reserved. * * $Id: MultipleRecnoNIODataEntry.java,v 1.8 2008/04/02 13:43:38 bschmeck Exp $ */ package com.sleepycat.db; import com.sleepycat.db.internal.DbConstants; import com.sleepycat.db.internal.DbUtil; import java.nio.ByteBuffer; /** A DatabaseEntry that holds multiple record number/data pairs returned by a single {@link com.sleepycat.db.Database Database} or {@link com.sleepycat.db.Cursor Cursor} get call. */ public class MultipleRecnoNIODataEntry extends MultipleEntry { /** Construct an entry with no data. The object must be configured before use with the {@link com.sleepycat.db.DatabaseEntry#setDataNIO DatabaseEntry.setDataNIO} method. */ public MultipleRecnoNIODataEntry() { super(null); } /** Construct an entry with a given java.nio.ByteBuffer. The offset is set to zero; the size is set to the length of the java.nio.ByteBuffer.

@param data java.nio.ByteBuffer wrapped by the entry. */ public MultipleRecnoNIODataEntry(final ByteBuffer data) { super(data); } /** * Return the bulk retrieval flag and reset the entry position so that the * next set of key/data can be returned. */ /* package */ int getMultiFlag() { pos = 0; return DbConstants.DB_MULTIPLE_KEY; } /** Get the next record number/data pair in the returned set. This method may only be called after a successful call to a {@link com.sleepycat.db.Database Database} or {@link com.sleepycat.db.Cursor Cursor} get method with this object as the data parameter.

When used with the Queue and Recno access methods, data.getData() will return null for deleted records.

@param recno an entry that is set to refer to the next record number in the returned set.

@param data an entry that is set to refer to the next data element in the returned set.

@return indicates whether a value was found. A return of false indicates that the end of the set was reached. */ public boolean next(final DatabaseEntry recno, final DatabaseEntry data) { byte[] intarr; int saveoffset; if (pos == 0) pos = ulen - INT32SZ; // pull the offsets out of the ByteBuffer. if(this.data_nio.capacity() < 12) return false; intarr = new byte[12]; saveoffset = this.data_nio.position(); this.data_nio.position(pos - INT32SZ*2); this.data_nio.get(intarr, 0, 12); this.data_nio.position(saveoffset); final int keyoff = DbUtil.array2int(intarr, 8); // crack out the key offset and the data offset and length. if (keyoff < 0) return false; final int dataoff = DbUtil.array2int(intarr, 4); final int datasz = DbUtil.array2int(intarr, 0); // move the position to one before the last offset read. pos -= INT32SZ*3; recno.setDataNIO(this.data_nio); recno.setOffset(keyoff); recno.setSize(INT32SZ); data.setDataNIO(this.data_nio); data.setOffset(dataoff); data.setSize(datasz); return true; } }