菜单 学习猿地 - LMONKEY

VIP

开通学习猿地VIP

尊享10项VIP特权 持续新增

知识通关挑战

打卡带练!告别无效练习

接私单赚外块

VIP优先接,累计金额超百万

学习猿地私房课免费学

大厂实战课仅对VIP开放

你的一对一导师

每月可免费咨询大牛30次

领取更多软件工程师实用特权

入驻
122
0

【Java】线程需要独立的Connection,那对已经配好session的Spring/Mabatis工程该怎么办?

原创
05/13 14:22
阅读数 1768

方法一:让线程从配置中取DataSource。

方法二:从配置中取出SessionFactory,然后交给线程去创建session和Connection,举例如下:

// Get Session Factory
ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("root-context.xml");
DefaultSqlSessionFactory sqlSessionFactory=(DefaultSqlSessionFactory)ctx.getBean("sqlSessionFactory");

for (String table : myJobInfo.tableList) {
... 
    CleanExpiredDataJobThread ct=new CleanExpiredDataJobThread();
    ct.setParams(index,table,myJobInfo.expiredDate,myJobInfo.commitSize,sqlSessionFactory,this);
    new Thread(ct).start();
...
}

线程里可以这样用:

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.defaults.DefaultSqlSessionFactory;

public class CleanExpiredDataJobThread extends AbstractJob implements Job,Runnable {
    private org.apache.ibatis.session.defaults.DefaultSqlSessionFactory sqlSessionFactory;
    
    ....


    @Override
    public void run(){
        logger.info("Start...");
        long startTime = System.currentTimeMillis();
        
        try {
            SqlSession sqlSession = null;
            sqlSession = sqlSessionFactory.openSession();
            
            // get connection and set it's auto-commit status to false
            Connection conn = getConnection(sqlSession);
            
            ....
        }catch(Exception ex) {
            ex.printStackTrace();
        }finally {
            
        }
        
    }
}

--END-- 2019年11月17日12:08:15

发表评论

0/200
122 点赞
0 评论
收藏
为你推荐 换一批