分頁取回資料

分頁取回資料.

分頁取回資料的程式與非分頁取回資料的程式幾乎一模一樣, 差別只在於, 是否在查詢時加入了描述分頁大小的參數.

當資料為分頁取回時, 使用者得到的會是所有資料的代理物件, 而且實際並未進行過任何查詢. 只有當使用者所想存取的資料尚未抓回時, 代理物件才會即時去查詢該資料所在的分頁. 但由於查詢是分開進行的, 使用者要特別注意, 當查詢資料與更新資料的動作同時進行時, 資料一致性的問題.

package com.logntw.eva.orm.defo;



import java.util.List;



import junit.framework.Assert;



import org.junit.Test;



import com.logntw.eva.anno.orm.Entity;

import com.logntw.eva.anno.orm.Id;

import com.logntw.eva.bean.condition.ConditionObj;

import com.logntw.eva.condition.OP;

import com.logntw.eva.orm.DBConnectionProvider;

import com.logntw.eva.orm.EagerToGet;

import com.logntw.eva.orm.ORMapper;

import com.logntw.eva.orm.ORMappers;

import com.logntw.eva.orm.defo.conn.HSQLDB_1_8ConnectionProvider;

import com.logntw.eva.sql.SelectOption;



public class DefoORMappersTestj

{

  @Entity

  public static interface X

  {  

    @Id

    int getId1();

    void setId1(int id1);

    

    Y getData2();

    void setData2(Y data2);

    

    Y getData3();

    void setData3(Y data3);

    

  }

  

  @Entity

  public static interface Y

  {  

    @Id

    int getId4();

    void setId4(int id4);

    

    Z getData5();

    void setData5(Z data5);

  }

  

  @Entity

  public static interface Z

  {  

    @Id

    int getId6();

    void setId6(int id6);

    

    float getData7();

    void setData7(float data7);

  }

  



  @Test

  public void testDefoORMappersTestj() throws Exception

  {  

    DBConnectionProvider provider = new HSQLDB_1_8ConnectionProvider("DefoORMappersTestj");    

    ORMappers mappers = DefoORMappers.getInstance(provider);

    

    DefaultTableCreator.create(mappers, Z.class);

    DefaultTableCreator.create(mappers, Y.class);

    DefaultTableCreator.create(mappers, X.class);

    

    mappers.open();

    

    try

    {        

      Z za = mappers.newObject(Z.class);

      za.setId6(11);

      Z zb = mappers.newObject(Z.class);

      zb.setId6(10);

      Z zc = mappers.newObject(Z.class);

      zc.setId6(9);

      Z zd = mappers.newObject(Z.class);

      zd.setId6(8);

      Z ze = mappers.newObject(Z.class);

      ze.setId6(7);

      Z zf = mappers.newObject(Z.class);

      zf.setId6(6);

      Z zg = mappers.newObject(Z.class);

      zg.setId6(5);

      Z zh = mappers.newObject(Z.class);

      zh.setId6(4);

      Z zi = mappers.newObject(Z.class);

      zi.setId6(3);

      Z zj = mappers.newObject(Z.class);

      zj.setId6(2);

      Z zk = mappers.newObject(Z.class);

      zk.setId6(1);

      

      

      Y ya = mappers.newObject(Y.class);

      Y yb = mappers.newObject(Y.class);

      Y yc = mappers.newObject(Y.class);

      Y yd = mappers.newObject(Y.class);

      Y ye = mappers.newObject(Y.class);

      Y yf = mappers.newObject(Y.class);

      Y yg = mappers.newObject(Y.class);

      Y yh = mappers.newObject(Y.class);

      Y yi = mappers.newObject(Y.class);

      Y yj = mappers.newObject(Y.class);

      Y yk = mappers.newObject(Y.class);

      

      ya.setId4(11);

      ya.setData5(za);

      yb.setId4(12);

      yb.setData5(zb);

      yc.setId4(13);

      yc.setData5(zc);

      yd.setId4(14);

      yd.setData5(zd);

      ye.setId4(15);

      ye.setData5(ze);

      yf.setId4(16);

      yf.setData5(zf);

      yg.setId4(17);

      yg.setData5(zg);

      yh.setId4(18);

      yh.setData5(zh);

      yi.setId4(19);

      yi.setData5(zi);

      yj.setId4(20);

      yj.setData5(zj);

      yk.setId4(21);

      yk.setData5(zk);

      

      X xa = mappers.newObject(X.class);

      X xb = mappers.newObject(X.class);

      X xc = mappers.newObject(X.class);

      X xd = mappers.newObject(X.class);

      X xe = mappers.newObject(X.class);

      X xf = mappers.newObject(X.class);      



      xa.setId1(51);

      xa.setData2(ya); // 11    ( not < 10)

      xa.setData3(yb); // 10 !! ( > 5)

      xb.setId1(52);

      xb.setData2(yc); // 9  !!

      xb.setData3(yd); // 8  !!

      xc.setId1(53);

      xc.setData2(ye); // 7  !!

      xc.setData3(yf); // 6  !!

      xd.setId1(54);

      xd.setData2(yg); // 5  !!

      xd.setData3(yh); // 4

      xe.setId1(55);

      xe.setData2(yi); // 3  !!

      xe.setData3(yj); // 2

      xf.setId1(56);

      xf.setData2(yk); // 1  !!

      xf.setData3(ya); // 11 !!  

      

      mappers.insert(za, zb, zc, zd, ze, zf, zg, zh, zi, zj, zk); 

      mappers.insert(ya, yb, yc, yd, ye, yf, yg, yh, yi, yj, yk);

      mappers.insert(xa, xb, xc, xd, xe, xf);

      

      List<Z> tmp; 

      tmp = mappers.select(EagerToGet.ENTITY, Z.class, SelectOption.NONE);

      Assert.assertEquals(tmp.size(), 11);

      

      

      Assert.assertTrue(tmp.get(3).equals(zh) || tmp.get(3).equals(zd));

      tmp = mappers.select(EagerToGet.ENTITY, Z.class, SelectOption.NONE, 3); // pageSize = 3!

      Assert.assertEquals(tmp.size(), 11);

      Assert.assertTrue(tmp.get(3).equals(zh) || tmp.get(3).equals(zd));

            

    

      Assert.assertEquals(mappers.count(Z.class), 11);

      Assert.assertEquals(mappers.count(Y.class), 11);

      Assert.assertEquals(mappers.count(X.class), 6);



      

      ORMapper<X> infMapper = mappers.getMapper(X.class);

      ORMapper<Y> inf2Mapper = mappers.getMapper(Y.class);

      ORMapper<Z> inf3Mapper = mappers.getMapper(Z.class);

      ConditionObj<X> cx = infMapper.newCondition();

      ConditionObj<Y> cya = inf2Mapper.newCondition();

      ConditionObj<Y> cyb = inf2Mapper.newCondition();      

      ConditionObj<Z> cza = inf3Mapper.newCondition();

      ConditionObj<Z> inf3b = inf3Mapper.newCondition();

      

      ConditionObj<Z> inf3c = mappers.getMapper(Z.class).newCondition();

      inf3c.If(OP.LESS).setId6(8);

      cza.If(OP.LESS).setId6(10);

      inf3b.If(OP.GREATER).setId6(5);

      cya.If(OP.THAT).setData5(cza.This());

      cyb.If(OP.THAT).setData5(inf3b.This());

      cx.If(OP.THAT).setData2(cya.This());

      cx.If(OP.THAT).setData3(cyb.This());

      

      Assert.assertEquals(mappers.count(true, cx), 3);

      List<X> rtn;

      rtn = mappers.select(true, EagerToGet.ENTITY, cx, SelectOption.NONE);

      Assert.assertEquals(rtn.get(0), xb);

      Assert.assertEquals(rtn.get(1), xc);

      Assert.assertEquals(rtn.get(2), xf);

      Assert.assertEquals(rtn.size(), 3);  

      rtn = mappers.select(true, EagerToGet.ENTITY, cx, SelectOption.NONE, 2);      

      Assert.assertEquals(rtn.get(0), xb);

      Assert.assertEquals(rtn.get(1), xc);

      Assert.assertEquals(rtn.get(2), xf);  

      Assert.assertEquals(rtn.size(), 3);  

      

      

      int count = 0;

      int total = 0;

      for(X test : rtn)

      {

        count ++;

        total += test.getId1();

      }

      Assert.assertEquals(count, 3);

      Assert.assertEquals(total, 161);

          

      rtn = mappers.select(true, EagerToGet.NONE, cx);

      mappers.commit();

      Assert.assertEquals(rtn.size(), 3);

      

      mappers.delete(true, xa, xb, xc, xd, xe, xf);

      mappers.delete(true, ya, yb, yc, yd, ye, yf, yg, yh, yi, yj, yk);

      mappers.delete(true, za, zb, zc, zd, ze, zf, zg, zh, zi, zj, zk);

      mappers.commit();

    }

    finally

    {          

      mappers.close();

      DefaultTableCreator.drop(mappers, X.class);

      DefaultTableCreator.drop(mappers, Y.class);

      DefaultTableCreator.drop(mappers, Z.class);        

    }    

  }  

}