IBATIS+ExecutorService进行多线程查询问题

0 0

IBATIS+ExecutorService进行多线程查询问题0

我们系统中有一个比较大的导出功能，考虑到数据量比较大，消耗时间较长，所以采用ExecutorService多线程框架处理，每个线程处理5000条数据，现在发现多线程时每个线程的数据都是一样的，我自己初步分析应该是getsqlmapclientTemplate共用的原因，求高手分析，代码如下：
dao类代码：

Long count = (Long) this
		.getSqlMapClientTemplate()
		.queryForObject(
				"sql.perfomaceQuery.getContractPerfomerByConditionsPageCount2",
				conditionPage.getConditionMap());
		ExecutorService executorService = Executors.newCachedThreadPool();
		long pagecount = (count%5000==0)?(count/5000):((count/5000)+1);
		List<Future<List<ContractInstance>>> ciallList= new ArrayList<Future<List<ContractInstance>>>();
		for (int i = 1; i <= pagecount; i++) {
            //使用ExecutorService执行Callable类型的任务，并将结果保存在future变量中
			ConditionPage conditionPageTemp= null;
			try {
				conditionPageTemp = (ConditionPage)conditionPage.clone();
			} catch (CloneNotSupportedException e) {
				return  new ArrayList<ContractInstance>();
			}
			conditionPageTemp.setPageSize(5000);
			conditionPageTemp.setCurrentPage(i);
			Future<List<ContractInstance>> subList = executorService.submit(new TaskWithQueryExcelResult(conditionPageTemp,this.getSqlMapClientTemplate()) );
            //将任务执行结果存储到List中
			ciallList.add(subList);
    }
		//<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)  
		//遍历任务的结果
		List<ContractInstance> ciList = new ArrayList<ContractInstance>();
        for (Future<List<ContractInstance>> fs : ciallList) {
                try {
                	ciList.addAll(fs.get());
                } catch (InterruptedException e) {
                	log.debug("InterruptedException  is:" + e.getMessage()); 
                } catch (Exception e) {
                        e.printStackTrace();
                } finally {
                        //启动一次顺序关闭，执行以前提交的任务，但不接受新任务。如果已经关闭，则调用没有其他作用。
                        executorService.shutdown();
                }
        }

任务类代码：

public List<ContractInstance> call() throws Exception {
		
	
		List<ContractInstance> ciList = new ArrayList<ContractInstance>();
		List<ExtfieldConfig> extFiledList = (List<ExtfieldConfig>)conditionPage.getConditionMap().get("extFiledList4Excel");

		long time = System.currentTimeMillis();
//		ciList = sct.queryForList(
//				"sql.perfomaceQuery.getContractPerfomerByConditions4Excel",
//				conditionPage.getConditionMap());
		long time1 = System.currentTimeMillis();
		SqlMapClientImpl sm =  (SqlMapClientImpl)(sct.getSqlMapClient());
		SqlMapExecutorDelegate smed = sm.getDelegate();
		SqlMapExecutorDelegateExtend smede = new SqlMapExecutorDelegateExtend(smed);
		 Connection con = null;
		 ResultSet rs =null;
		try {
			com.ibatis.sqlmap.engine.scope.SessionScope ss = new com.ibatis.sqlmap.engine.scope.SessionScope();
			ss.setSqlMapClient(sm);
		    ss.setSqlMapExecutor(sm);
		    ss.setSqlMapTxMgr(sm);
		    con = sm.getDataSource().getConnection();
		    smede.setUserProvidedTransaction(ss, con);
			
//			smed.queryForList(ss, "sql.perfomaceQuery.getContractPerfomerByConditions4Excel", "");
			smede.queryForList(ss, "sql.perfomaceQuery.getContractPerfomerByConditions4Excel", conditionPage.getConditionMap());
			 
			MappedStatementExtend mse = smede.getMse();
			
			//取得运行时的sql和参数
			String sqlStr = mse.getRuntimeSql();
			Object[] parameters = mse.getParameters();
			log.debug("contract info exporting sql is:" + sqlStr);
			log.debug("---and the parameters are :" + parameters);
			//使用jdbc查询和封装对象
			PreparedStatement ps = con.prepareStatement(sqlStr);
			int len = parameters.length;
			for(int i = 0 ;i < len ;i++){
				Object obj = parameters[i];
				
				if(obj instanceof Date){
//					System.out.println("----date is--------" + obj);
					java.sql.Date date = new java.sql.Date(((Date)obj).getTime());
					ps.setDate(i+1, date);
				}else if(obj instanceof String){
//					System.out.println("-----String is -----" + obj);
					ps.setString(i+1, (String)obj);
				}else if(obj instanceof Double ){
//					System.out.println("-----Double is----" + obj);
					ps.setDouble(i+1, (Double)obj);
				}else if(obj instanceof Long){
//					System.out.println("------Long is---------" + obj);
					ps.setLong(i+1, (Long)obj);
				}else if(obj instanceof Integer){
//					System.out.println("------Ingeter is---------" + obj);
					ps.setInt(i+1, (Integer)obj);
				}else{
//					System.out.println("--unkown type is--" + obj);
					ps.setObject(i+1, obj);
				}
			}
			
			rs = ps.executeQuery();  
			
			ciList = ExcelUtil.fetchData(rs,extFiledList,sqlStr);
			
			
			ss.cleanup();
			long time2 = System.currentTimeMillis();
//			System.out.println("---------------ibatis 查询所耗时间："+(time1-time));
//			System.out.println("---------------JDBC 查询所耗时间："+(time2-time1));
		} catch (Exception e) {
			log.error(" e.getMessage());
			
		}finally{
			
			
				try {
					if(null != rs){
						rs.close();
					}
					if(null != con){
					con.close();
					}
				} catch (SQLException e) {
					log.error(e.getMessage());
				}
			
		}
		
		return ciList;
	}