SqlSessionTemplate 批量增、删、改、查

Love The Way You Lie 2024-03-23 11:06 45阅读 0赞

###### 创建类 ######

package cn.tedu.ff_server.mybatis;
    
    import org.apache.ibatis.session.ExecutorType;
    import org.apache.ibatis.session.ResultHandler;
    import org.apache.ibatis.session.SqlSession;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.util.List;
    
    @Component
    public class SqlBatchTemp {
        
        @Autowired
        private SqlSessionTemplate sqlSessionTemplate;
    
        public void batchInsert(String nameSpace, List objs) {
        
            SqlSessionFactory sqlSessionFactory = sqlSessionTemplate.getSqlSessionFactory();
            //批量执行器
            SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
            try{
        
                if(objs!=null){
        
                    for(int i=0,size=objs.size();i<size;i++){
        
                        sqlSession.insert(nameSpace, objs.get(i));
                    }
                    sqlSession.flushStatements();
                    sqlSession.commit();
                    sqlSession.clearCache();
                }
            }finally{
        
                sqlSession.close();
            }
        }
    
        public void batchUpdate(String nameSpace, List objs) {
        
            SqlSessionFactory sqlSessionFactory = sqlSessionTemplate.getSqlSessionFactory();
            //批量执行器
            SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
            try{
        
                if(objs!=null){
        
                    for(int i=0,size=objs.size();i<size;i++){
        
                        sqlSession.update(nameSpace, objs.get(i));
                    }
                    sqlSession.flushStatements();
                    sqlSession.commit();
                    sqlSession.clearCache();
                }
            }finally{
        
                sqlSession.close();
            }
        }
    
        public void batchDelete(String nameSpace, List objs ) {
        
            SqlSessionFactory sqlSessionFactory = sqlSessionTemplate.getSqlSessionFactory();
            //批量执行器
            SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
            try{
        
                if(objs!=null){
        
                    for(int i=0,size=objs.size();i<size;i++){
        
                        sqlSession.delete(nameSpace, objs.get(i));
                    }
                    sqlSession.flushStatements();
                    sqlSession.commit();
                    sqlSession.clearCache();
                }
            }finally{
        
                sqlSession.close();
            }
        }
    
        public void batchSelect(String nameSpace, List objs ) {
        
            SqlSessionFactory sqlSessionFactory = sqlSessionTemplate.getSqlSessionFactory();
            //批量执行器
            SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
            try{
        
                if(objs!=null){
        
                    for(int i=0,size=objs.size();i<size;i++){
        
                        sqlSession.select(nameSpace, (ResultHandler) objs.get(i));
                    }
                    sqlSession.flushStatements();
                    sqlSession.commit();
                    sqlSession.clearCache();
                }
            }finally{
        
                sqlSession.close();
            }
        }
    }

###### 在mapper.xml里 ######

<delete id="deleteById">
            DELETE FROM category WHERE id = #{id}
        </delete>

###### 在servieceImpl 里调用 ######

@Service
    public class CategoryServiceImpl implements CategoryService {
        
        @Autowired
        SqlBatchTemp sqlBatchTemp;
        
        @Override
        public void deleteBatch(List<Long> ids) {
        
            sqlBatchTemp.batchDelete("cn.tedu.ff_server.mapper.CategoryMapper.deleteById", ids);
        }
    }