bbossgroups 3.x持久层行处理器使用示例
bbossgroups 3.x持久层行处理器使用示例

1.概述
行处理主要用来提供灵活高效的查询结果处理方法，下面着重介绍一下三种主要行处理器:空行处理器、返回值行处理器以及字段行处理器。
1.1 空行处理器-灵活度最高的行处理器，结果集全部自行封装，框架干预少
com.frameworkset.common.poolman.handle.NullRowHandler
空行处理器适用于
1.2.返回值行处理器-框架负责返回数据集，记录字段转换为值对象自行处理
com.frameworkset.common.poolman.handle.RowHandler
1.3.字段行处理器-对单个字段进行行级处理，并将处理值发挥给调用程序，字段行处理器主要用来处理blob和clob大字段类型的单字段查询功能，消除不同的数据库对大字段处理的差异性
com.frameworkset.common.poolman.handle.FieldRowHandler


2.使用方法

2.1 空行处理器
map方式

public Map<String,String> getUserDeskMapMenus(DeskTopMenuBean bean)throws Exception {String sql = "SELECT menupath,subsystem,userid FROM TD_SM_DESKMENU WHERE userid=#[userid] and subsystem=#[subsystem]";final Map<String,String> datas = new HashMap<String,String>();SQLExecutor.queryBeanWithDBNameByNullRowHandler(new NullRowHandler(){@Overridepublic void handleRow(Record origine) throws Exception{datas.put(origine.getString("menupath"), origine.getString("subsystem"));}}, dbname,sql , bean);return datas;}

list方式

final List<ListBean> lbs = new ArrayList<ListBean>();SQLExecutor.queryWithDBNameByNullRowHandler(new NullRowHandler(){@Overridepublic void handleRow(Record record) throws Exception {ListBean lb = new ListBean();lb.setId(record.getInt("id"));lb.setFieldName(record.getString("fieldName"));lbs.add(lb);}}, "mysql", "select * from LISTBEAN where id>?", 80);

2.2 返回值行处理器

String sql = "select * from LISTBEAN where ID>?";List<ListBean> beans = (List<ListBean>) SQLExecutor.queryListByRowHandler(new RowHandler<ListBean>(){@Overridepublic void handleRow(ListBean lb, Record record)throws Exception {System.out.println("queryListByRowHandler test Result**:"+record.getString("fieldName"));lb.setId(record.getInt("id"));lb.setFieldName(record.getString("fieldName"));}}, ListBean.class, sql, 80);

2.3 字段行处理器
字段行处理器实现从blob/clob中获取单个字段文件对象的处理,其他类似类型数据也可以使用FieldRowHandler，使用示例如下：

public File getDownloadClobFile(String fileid) throws Exception{try{return SQLExecutor.queryTField(File.class,new FieldRowHandler<File>() {@Overridepublic File handleField(Record record)throws Exception{// 定义文件对象File f = new File("d:/",record.getString("filename"));// 如果文件已经存在则直接返回fif (f.exists())return f;// 将blob中的文件内容存储到文件中record.getFile("filecontent",f);return f;}},"select filename,filecontent from CLOBFILE where fileid=?",fileid);}catch (Exception e){throw e;}}

几种常用的使用方法就介绍完了，同时我们还可以结合行处理器完成分页查询，这里就不多说，更进一步的内容请关注博客动态。