Method testSelectRange

java/unittests/EnvironmentTest.java:354–405

()

  }

  public void testSelectRange() {
    byte[] k = new byte[5];
    byte[] r = new byte[5];
    Environment env = new Environment();
    Database db = null;
    Cursor c = null;
    try {
      env.create("jtest.db");
      db = env.createDatabase((short)1);
      for (int i = 0; i < 100; i++) {
        k[0] = (byte)i;
        r[0] = (byte)i;
        db.insert(k, r);
      }

      k[0] = 50;
      c = new Cursor(db);
      c.find(k);
      assertByteArrayEquals(c.getRecord(), k);

      Result result1 = env.selectRange("COUNT($key) FROM DATABASE 1", null, c);
      assertEquals(result1.getRowCount(), 1);
      assertEquals(result1.getKeyType(), Const.UPS_TYPE_BINARY);

      byte[] r1 = result1.getRecordData();
      ByteBuffer b1 = ByteBuffer.wrap(r1);
      b1.order(ByteOrder.LITTLE_ENDIAN);
      assertEquals(b1.getInt(), 50);
      Result result2 = env.selectRange("COUNT($key) FROM DATABASE 1", c, null);
      assertEquals(result2.getRowCount(), 1);

      byte[] r2 = result2.getRecordData();
      ByteBuffer b2 = ByteBuffer.wrap(r2);
      b2.order(ByteOrder.LITTLE_ENDIAN);
      assertEquals(b2.getInt(), 50);
    }
    catch (DatabaseException err) {
      fail("Exception "+err);
    }

    boolean failed = false;
    try {
      c.move(Const.UPS_CURSOR_NEXT); // must fail
    }
    catch (DatabaseException err) {
      failed = true;
    }
    assertEquals(failed, true);

    db.close();
    env.close();
  }
  
}