您的位置：首页 > 数据库

nc 服务类接口查询数据库方法

2015-06-12 15:36 495 查看

@Override

public AggSupervisionVO[] queryBillByPK(String[] pks)

throws BusinessException {

AggSupervisionVO[] bills = null;

BillQuery<AggSupervisionVO> query;

query = new BillQuery<AggSupervisionVO>(AggSupervisionVO.class);

bills = query.query(pks);

return PaginationUtils.filterNotExistBills(bills, pks);

}

@Override

public String[] queryPKs(IQueryScheme queryScheme) throws BusinessException {

String beanId = (String) queryScheme.get("bean_id");

Class headVoClass = (Class) queryScheme.get("headVoClass");

SuperVO vo = (SuperVO) ReflectHelper.newInstance(headVoClass);

String fieldName = vo.getPKFieldName();

// String beanId=(String) queryScheme.get(QueryConstants.BEAN_ID);

StringBuffer sql = new StringBuffer();

QuerySchemeProcessor processor = new QuerySchemeProcessor(queryScheme);

processor.appendFuncPermissionOrgSql();

processor.appendCurrentGroup();

String mainAlias = processor.getMainTableAlias();

sql.append(" select distinct ");

sql.append(mainAlias);

sql.append(".");

sql.append(fieldName);

sql.append(processor.getFinalFromWhere());

DataAccessUtils dao = new DataAccessUtils();

IRowSet rowset = dao.query(sql.toString());

String[] keys = rowset.toOneDimensionStringArray();

return keys;

}

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航