NCC中快速持久化更新某实体的少量字段

zhou66

/* 43 */     String[] oppids = (String[])aloppid.toArray(new String[aloppid.size()]);

/* 45 */     String[] updateKeys = { "fopposeflag" };

/* 49 */     String[] selectKeys = { "csaleinvoiceid", "fopposeflag", "ts" };

/* 54 */     VOQuery<SaleInvoiceHVO> querysrv = new VOQuery(SaleInvoiceHVO.class, selectKeys);
/*    */     
/* 56 */     SaleInvoiceHVO[] hvos = (SaleInvoiceHVO[])querysrv.query(oppids);
/* 57 */     VOConcurrentTool tool = new VOConcurrentTool();
/* 58 */     tool.checkTSWithDB(hvos);
/* 59 */     for (SaleInvoiceHVO hvo : hvos) {
/* 60 */       hvo.setFopposeflag((Integer)oppflag.value());
/*    */     }
/* 62 */     Object bo = new VOUpdate();
/* 63 */     ((VOUpdate)bo).update(hvos, updateKeys);

zhou66

dao.retrieveByClause 方法中，不用增加where字段  和 order by 字段

Systematic

看不懂, 很厉害, 大神加油

zhou66

查询和持久化的写法很多，记录一下
1，
                List<ReelMaterialVO> matVos = (List<ReelMaterialVO>) baseDao.executeQuery(sbSql.toString(), new BeanListProcessor(ReelMaterialVO.class));
2，
                List<Map> mapList =  (List<Map>) baseDao.executeQuery(sbSql.toString(),param, new MapListProcessor());

zhou66

import nc.itf.pubapp.pub.smart.IBillQueryService;

IBillQueryService billQuery = NCLocator.getInstance().lookup(IBillQueryService.class);
String[] pks = {pk};
AbstractBill[] aggvos = billQuery.queryAbstractBillsByPks(SaleOutVO.class, pks);
SaleOutVO newvo = (SaleOutVO)aggvos[0];
=====================================================
public AggHouse_customer_b[] pubquerybills(IQueryScheme queryScheme)
???throws BusinessException {
??AggHouse_customer_b[] bills = null;
??try {
???this.preQuery(queryScheme);
???BillLazyQuery<AggHouse_customer_b> query = new BillLazyQuery<AggHouse_customer_b>(
?????AggHouse_customer_b.class);
???bills = query.query(queryScheme, null);
??} catch (Exception e) {
???ExceptionUtils.marsh(e);
??}
??return bills;
?}

AggregatedValueObject[] vo = HYPubBO_Client.queryBillVOByCondition(HRDeptVO.class," and nvl(dr,0)");
=============================================================
IMDPersistenceQueryService service = NCLocator.getInstance().lookup(IMDPersistenceQueryService.class);
List<AggsettledVO> listSettledVO = (List<AggsettledVO>)service.queryBillOfVOByCond(AggsettledVO.class, whereSql, true);//(vo.class," nvl(dr,0)=0 and 1=1", 是否懒加载)
AggsettledVO[] vos = (AggsettledVO[])listSettledVO.toArray(new AggsettledVO[listSettledVO.size()]);

zhou66

持久化代码示例

package nc.impl.am.db;

import nc.impl.pubapp.pattern.data.bill.BillDelete;
import nc.impl.pubapp.pattern.data.bill.BillOperator;
import nc.impl.pubapp.pattern.data.bill.BillQuery;
import nc.impl.pubapp.pattern.data.bill.BillUpdate;
import nc.vo.pubapp.pattern.model.entity.bill.IBill;

public class BillPersistUtil {
   public <T extends IBill> void delete(T... billVOs) {
      BillDelete<IBill> action = new BillDelete();
      action.delete(billVOs);
   }

   public <T extends IBill> T[] update(T[] billVOs) {
      String[] key = new String[billVOs.length];

      for(int i = 0; i < billVOs.length; ++i) {
         key[i] = billVOs[i].getPrimaryKey();
      }

      BillUpdate<IBill> action = new BillUpdate();
      BillQuery<IBill> queryAction = new BillQuery(billVOs[0].getClass());
      IBill[] originBills = queryAction.query(key);
      T[] retVO = (IBill[])action.update(billVOs, originBills);
      return retVO;
   }

   public <T extends IBill> T[] update(T[] billVOs, T[] originBills) {
      T[] retVO = null;
      if (originBills == null) {
         retVO = this.update(billVOs);
      } else {
         BillUpdate<IBill> action = new BillUpdate();
         retVO = (IBill[])action.update(billVOs, originBills);
      }

      return retVO;
   }

   public <T extends IBill> T[] insert(T... billVOs) {
      BillOperator<T> action = new BillOperator();
      return action.insert(billVOs);
   }
}