MyBatis人事管理系统JobDao

快来打我* 2021-07-24 15:04 420阅读 0赞

**一 JobDao**

package org.fkit.hrm.dao;
    
    
    import java.util.List;
    import java.util.Map;
    import org.apache.ibatis.annotations.Delete;
    import org.apache.ibatis.annotations.Select;
    import org.apache.ibatis.annotations.SelectProvider;
    import org.fkit.hrm.dao.provider.JobDynaSqlProvider;
    import org.fkit.hrm.domain.Job;
    import static org.fkit.hrm.util.common.HrmConstants.JOBTABLE;
    
    public interface JobDao {
    
    
        @Select("select * from "+JOBTABLE+" where ID = #{id}")
        Job selectById(int id);
        
        @Select("select * from "+JOBTABLE+" ")
        List<Job> selectAllJob();
    
    
        // 动态查询
        @SelectProvider(type=JobDynaSqlProvider.class,method="selectWhitParam")
        List<Job> selectByPage(Map<String, Object> params);
        
        @SelectProvider(type=JobDynaSqlProvider.class,method="count")
        Integer count(Map<String, Object> params);
        
        // 根据id删除部门
        @Delete(" delete from "+JOBTABLE+" where id = #{id} ")
        void deleteById(Integer id);
        
        // 动态插入部门
        @SelectProvider(type=JobDynaSqlProvider.class,method="insertJob")
        void save(Job job);
        
        // 动态修改用户
        @SelectProvider(type=JobDynaSqlProvider.class,method="updateJob")
        void update(Job job);
    }

**二 JobDynaSqlProvider**

package org.fkit.hrm.dao.provider;
    
    
    import java.util.Map;
    import org.apache.ibatis.jdbc.SQL;
    import org.fkit.hrm.domain.Job;
    import static org.fkit.hrm.util.common.HrmConstants.JOBTABLE;
    
    public class JobDynaSqlProvider {
        // 分页动态查询
        public String selectWhitParam(Map<String, Object> params){
            String sql =  new SQL(){
                {
                    SELECT("*");
                    FROM(JOBTABLE);
                    if(params.get("job") != null){
                        Job job = (Job) params.get("job");
                        if(job.getName() != null && !job.getName().equals("")){
                            WHERE("  name LIKE CONCAT ('%',#{job.name},'%') ");
                        }
                    }
                }
            }.toString();
            
            if(params.get("pageModel") != null){
                sql += " limit #{pageModel.firstLimitParam} , #{pageModel.pageSize}  ";
            }
            
            return sql;
        }    
        // 动态查询总数量
        public String count(Map<String, Object> params){
            return new SQL(){
                {
                    SELECT("count(*)");
                    FROM(JOBTABLE);
                    if(params.get("job") != null){
                        Job job = (Job) params.get("job");
                        if(job.getName() != null && !job.getName().equals("")){
                            WHERE("  name LIKE CONCAT ('%',#{job.name},'%') ");
                        }
                    }
                }
            }.toString();
        }    
        // 动态插入
        public String insertJob(Job job){
            
            return new SQL(){
                {
                    INSERT_INTO(JOBTABLE);
                    if(job.getName() != null && !job.getName().equals("")){
                        VALUES("name", "#{name}");
                    }
                    if(job.getRemark() != null && !job.getRemark().equals("")){
                        VALUES("remark", "#{remark}");
                    }
                }
            }.toString();
        }
        // 动态更新
        public String updateJob(Job job){
            
            return new SQL(){
                {
                    UPDATE(JOBTABLE);
                    if(job.getName() != null){
                        SET(" name = #{name} ");
                    }
                    if(job.getRemark() != null){
                        SET(" remark = #{remark} ");
                    }
                    WHERE(" id = #{id} ");
                }
            }.toString();
        }
    }