本人用的oracle

场景是这样的： 用spring做了一个定时任务，每20分钟调用一次，每次调用的时候读一个配置文件来切换数据源。

每切换一次数据源开启一个线程调用一次存储过程，

每个不同数据源的存储过程都往同一个目标数据库里面灌数据来达到数据同步的效果。

问题：  

   1：但任务启动是，目标数据库的session增多，好似没有释放。  

   2：当运行一天后，plsql无法连接目标数据库。

本人对问题的分析可能性：    1：oracle的session中inactive的会话导致.

                                        2：每个线程调用存储过程后资源没有释放。（原因：停止服务器后oracle的session减少）

                                        3：线程在切换数据源后，spring的单例没起作用。（不断不断的去连接，直到超过连接数）。

请大虾们分析。 

一下是spring的代码

<!-- 数据源配置start -->
	<bean id="parentDataSource" class="org.apache.commons.dbcp.BasicDataSource" >  
            <property name="maxIdle" value="20" ></property>
		    <property name="maxActive" value="50" ></property>
		    <property name="maxWait" value="3000" />
		    <property name="minIdle" value="10" />
		    <property name="removeAbandoned" value="true"/>
		    <property name="removeAbandonedTimeout" value="60"/>
    </bean>
	
	<bean id="cx_dataSource" class="com.changx.ds.DynamicDataSource">   
        <property name="targetDataSources">    
          <map key-type="java.lang.String">  
             <entry key="cx_4306020_xx" value-ref="cx_4306020_xx"/>
             <entry key="cx_4306021_xx" value-ref="cx_4306021_xx"/>
            
             
             
          </map>    
       </property>    
       <property name="defaultTargetDataSource" ref="cx_4306021_xx"/>    
    </bean> 
    
   
        <bean id="cx_4306020_xx" parent="parentDataSource">
        <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
        <property name="url" value="jdbc:oracle:thin:@192.1.2.145:1521:orclzhs" />
        <property name="username" value="cx_4306020" />
        <property name="password" value="4306020" />
    </bean>
    
    <bean id="cx_4306021_xx" parent="parentDataSource">
        <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
        <property name="url" value="jdbc:oracle:thin:@192.1.2.145:1521:orclzhs" />
        <property name="username" value="cx_4306021" />
        <property name="password" value="4306021" />
    </bean>

线程调用的类

public class TaskExecutorExample implements TaskExecutorInterface{  
    
    private TaskExecutor taskExecutor;  
    private CallProduce callPro;
    public CallProduce getCallPro() {
        return callPro;
    }
    public void setCallPro(CallProduce callPro) {
        this.callPro = callPro;
    }
    public TaskExecutorExample(TaskExecutor taskExecutor) {      
        this.taskExecutor = taskExecutor;    
    }  
      
 
    private class CallProduceTask implements Runnable {      
        private String dbStr;   
 
        public CallProduceTask(String dbStr) {        
            this.dbStr = dbStr;      
        }  
        
        public void run() {    
            CustomerContextHolder.setCustomerType("cx_"+dbStr);
            callPro.tranData();
            callPro.call_send_joindata_to_front();
            System.out.println("---运行over--"+dbStr);      
        }  
    }

    
    /**
     * 调用存储过程
     */
    public void executeProdure() {
        Set dsSet=ProperUtil.properds.keySet();
        String dbStr= "";
        for(Iterator i=dsSet.iterator();i.hasNext();){
            dbStr = i.next().toString();
            //System.out.println(dbStr);
            taskExecutor.execute(new CallProduceTask(dbStr)); 
        }

    
    }



     
}  

调用的dao

public class CallProduceImpl extends JdbcDaoSupport implements CallProduce {
    
	/**
	 * 数据标化
	 */
	public void tranData() {
		// TODO Auto-generated method stub
	    //CustomerContextHolder.setCustomerType("cx_"+dbStr);
		//System.out.println("---开始执行---"+CustomerContextHolder.getCustomerType());
		Connection conn=null;
		String qx = CustomerContextHolder.getCustomerType();
		try {
			
			//List list = this.getJdbcTemplate().queryForList("select count(1) from t107_referral t");
			//System.out.println(list.get(0).toString());
			
			List sb_ywb_list = this.getJdbcTemplate().queryForList("select hospital_id,ywid,id,flag from sb_send_dyywb where send_flag='0'");
			conn=this.getJdbcTemplate().getDataSource().getConnection();
			
			for(int i=0;i<sb_ywb_list.size();i++){

                Map map=(Map)(sb_ywb_list.get(i));
                //System.out.println(map.get("hospital_id")+"-----"+map.get("ywid")+"==="+map.get("ywid"));
                
                String hospital_id = map.get("hospital_id").toString();
                String ywid  = map.get("ywid").toString();
                String id = map.get("id").toString();
                
                String pro_str = "";
                if(map.get("flag").toString().trim().equals("i")||map.get("flag").toString().trim().equals("I")){
                  //send_dyywb_insert(i.hospital_id, i.ywid, i.id, vs_flag, vs_str);
                    pro_str = "{call pkg_standard.send_dyywb_insert(?,?,?,?,?)}";
                    
                }else if(map.get("flag").toString().trim().equals("u")||map.get("flag").toString().trim().equals("U")){
                    // send_dyywb_update(i.hospital_id, i.ywid, i.id, vs_flag, vs_str);
                    pro_str = "{call pkg_standard.send_dyywb_update(?,?,?,?,?)}";
                }
                
                
                CallableStatement cs=conn.prepareCall(pro_str);
                cs.setString(1, hospital_id);
                cs.setString(2, ywid);
                cs.setString(3, id);
                cs.registerOutParameter(4, Types.VARCHAR);//vs_flag
                cs.registerOutParameter(5, Types.VARCHAR);//vs_str
                cs.execute();
                
                
                String  vs_flag = cs.getString(4);
                String  vs_str = cs.getString(5);
                
                
                System.out.println("qx:"+qx+",返回标志："+vs_flag+"返回值："+vs_str);
                if("0".equals(vs_flag)){
                    String delSql = "delete from sb_send_dyywb  where hospital_id = '"+hospital_id+"' and ywid = '"+ywid+"' and id = '"+id+"'";
                    this.getJdbcTemplate().execute(delSql);
                    
                    conn.commit();
                }else{
                    conn.rollback();
                    
//                    String temp =  vs_str + ",hospital_id:" + hospital_id + ",ywid:" + ywid +",id:" + id;
//                    String exceptionSql = "insert into xt_ywrzb values (seq_ywrz.nextval,  'send_data',  '1', sysdate,'"+temp+"', '','1','cx', 'send_dyywb_to_front')";
//                    java.sql.Statement ps = conn.createStatement();
//                    //System.out.println("错误日志："+exceptionSql);
//                    ps.execute(exceptionSql);
                    
                }
			}
			
		} catch (SQLException e) {
		    System.out.println("---这个连接无法获得："+CustomerContextHolder.getCustomerType());
			try {
				conn.rollback();
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			if(conn!=null){
				try {
				    System.out.println("关闭连接！");
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}
		
	}

}

请大虾们指点下。