mybatis 使用自定義sql 語句(非Mapper.xml SQL)

本文轉載自查看原文 2020-07-25 21:23 1087

新建一個接口 SqlBaseMapper 封裝常用的增刪改查

public interface SqlBaseMapper {

    /**
     * 查詢單條數據返回Map<String, Object>
     *
     * @param sql sql語句
     * @return Map<String, Object>
     */
    Map<String, Object> sqlSelectOne(String sql);

    /**
     * 查詢單條數據返回Map<String, Object>
     *
     * @param sql   sql語句
     * @param value 參數
     * @return Map<String, Object>
     */
    Map<String, Object> sqlSelectOne(String sql, Object value);

    /**
     * 查詢單條數據返回實體類型
     *
     * @param sql        sql語句
     * @param resultType 具體類型
     * @return 定義的實體類型
     */
    <T> T sqlSelectOne(String sql, Class<T> resultType);

    /**
     * 查詢單條數據返回實體類型
     *
     * @param sql        sql語句
     * @param value      參數
     * @param resultType 具體類型
     * @return 定義的實體類型
     */
    <T> T sqlSelectOne(String sql, Object value, Class<T> resultType);

    /**
     * 查詢數據返回
     *
     * @param sql sql語句
     * @return List<Map < String, Object>>
     */
    List<Map<String, Object>> sqlSelectList(String sql);

    /**
     * 查詢數據返回
     *
     * @param sql   sql語句
     * @param value 參數
     * @return List<Map < String, Object>>
     */
    List<Map<String, Object>> sqlSelectList(String sql, Object value);

    /**
     * 查詢數據返回
     *
     * @param sql        sql語句
     * @param resultType 具體類型
     * @return List<T>
     */
    <T> List<T> sqlSelectList(String sql, Class<T> resultType);

    /**
     * 查詢數據返回
     *
     * @param sql        sql語句
     * @param value      參數
     * @param resultType 具體類型
     * @return List<T>
     */
    <T> List<T> sqlSelectList(String sql, Object value, Class<T> resultType);

    /**
     * 插入數據
     *
     * @param sql sql語句
     * @return int
     */
    int sqlInsert(String sql);

    /**
     * 插入數據
     *
     * @param sql   sql語句
     * @param value 參數
     * @return int
     */
    int sqlInsert(String sql, Object value);

    /**
     * 更新數據
     *
     * @param sql sql語句
     * @return int
     */
    int sqlUpdate(String sql);

    /**
     * 更新數據
     *
     * @param sql   sql語句
     * @param value 參數
     * @return int
     */
    int sqlUpdate(String sql, Object value);

    /**
     * 刪除數據
     *
     * @param sql sql語句
     * @return int
     */
    int sqlDelete(String sql);

    /**
     * 查詢數據返回List<T>
     *
     * @param sql   sql語句
     * @param value 參數
     * @return int
     */
    int sqlDelete(String sql, Object value);


}

新建一個SqlMapper 實現SqlBaseMapper接口

/**
 * @author chaild
 * @Date 2020-7-7 14:43:35
 * 自定義SQL查詢類
 */
@Component
public class SqlMapper implements SqlBaseMapper {

    /**
     * 使用方式
     *
     * @Autowired private SqlMapper sqlMapper;
     */
    private SqlSession sqlSession;
    private SqlMapper.MSUtils msUtils;

    @Autowired
    SqlSessionFactory sqlSessionFactory;

    public SqlMapper() {
    }

/**這個注解具體意思可以自己去了解一下**/
    @PostConstruct
    private void init() {
        this.sqlSession = sqlSessionFactory.openSession(true);
        this.msUtils = new SqlMapper.MSUtils(sqlSession.getConfiguration());
    }

    private <T> T getOne(List<T> list) {
        if (list.size() == 1) {
            return list.get(0);
        } else if (list.size() > 1) {
            throw new TooManyResultsException("Expected one result (or null) to be returned by selectOne(), but found: " + list.size());
        } else {
            return null;
        }
    }

    /**
     * 查詢單條數據返回Map<String, Object>
     *
     * @param sql sql語句
     * @return Map<String, Object>
     */
    @Override
    public Map<String, Object> sqlSelectOne(String sql) {
        List<Map<String, Object>> list = this.sqlSelectList(sql);
        return (Map) this.getOne(list);
    }

    /**
     * 查詢單條數據返回Map<String, Object>
     *
     * @param sql   sql語句
     * @param value 參數
     * @return Map<String, Object>
     */
    @Override
    public Map<String, Object> sqlSelectOne(String sql, Object value) {
        List<Map<String, Object>> list = this.sqlSelectList(sql, value);
        return (Map) this.getOne(list);
    }

    /**
     * 查詢單條數據返回實體類型
     *
     * @param sql        sql語句
     * @param resultType 具體類型
     * @return 定義的實體類型
     */
    @Override
    public <T> T sqlSelectOne(String sql, Class<T> resultType) {
        List<T> list = this.sqlSelectList(sql, resultType);
        return this.getOne(list);
    }

    /**
     * 查詢單條數據返回實體類型
     *
     * @param sql        sql語句
     * @param value      參數
     * @param resultType 具體類型
     * @return 定義的實體類型
     */
    @Override
    public <T> T sqlSelectOne(String sql, Object value, Class<T> resultType) {
        List<T> list = this.sqlSelectList(sql, value, resultType);
        return this.getOne(list);
    }

    /**
     * 查詢數據返回
     *
     * @param sql sql語句
     * @return List<Map < String, Object>>
     */
    @Override
    public List<Map<String, Object>> sqlSelectList(String sql) {
        String msId = this.msUtils.select(sql);
        return this.sqlSession.selectList(msId);
    }

    /**
     * 查詢數據返回
     *
     * @param sql   sql語句
     * @param value 參數
     * @return List<Map < String, Object>>
     */
    @Override
    public List<Map<String, Object>> sqlSelectList(String sql, Object value) {
        Class<?> parameterType = value != null ? value.getClass() : null;
        String msId = this.msUtils.selectDynamic(sql, parameterType);
        return this.sqlSession.selectList(msId, value);
    }

    /**
     * 查詢數據返回
     *
     * @param sql        sql語句
     * @param resultType 具體類型
     * @return List<T>
     */
    @Override
    public <T> List<T> sqlSelectList(String sql, Class<T> resultType) {
        String msId;
        if (resultType == null) {
            msId = this.msUtils.select(sql);
        } else {
            msId = this.msUtils.select(sql, resultType);
        }

        return this.sqlSession.selectList(msId);
    }

    /**
     * 查詢數據返回
     *
     * @param sql        sql語句
     * @param value      參數
     * @param resultType 具體類型
     * @return List<T>
     */
    @Override
    public <T> List<T> sqlSelectList(String sql, Object value, Class<T> resultType) {
        Class<?> parameterType = value != null ? value.getClass() : null;
        String msId;
        if (resultType == null) {
            msId = this.msUtils.selectDynamic(sql, parameterType);
        } else {
            msId = this.msUtils.selectDynamic(sql, parameterType, resultType);
        }

        return this.sqlSession.selectList(msId, value);
    }

    /**
     * 插入數據
     *
     * @param sql sql語句
     * @return int
     */
    @Override
    public int sqlInsert(String sql) {
        String msId = this.msUtils.insert(sql);
        return this.sqlSession.insert(msId);
    }

    /**
     * 插入數據
     *
     * @param sql   sql語句
     * @param value 參數
     * @return int
     */
    @Override
    public int sqlInsert(String sql, Object value) {
        Class<?> parameterType = value != null ? value.getClass() : null;
        String msId = this.msUtils.insertDynamic(sql, parameterType);
        return this.sqlSession.insert(msId, value);
    }

    /**
     * 更新數據
     *
     * @param sql sql語句
     * @return int
     */
    @Override
    public int sqlUpdate(String sql) {
        String msId = this.msUtils.update(sql);
        return this.sqlSession.update(msId);
    }

    /**
     * 更新數據
     *
     * @param sql   sql語句
     * @param value 參數
     * @return int
     */
    @Override
    public int sqlUpdate(String sql, Object value) {
        Class<?> parameterType = value != null ? value.getClass() : null;
        String msId = this.msUtils.updateDynamic(sql, parameterType);
        return this.sqlSession.update(msId, value);
    }

    /**
     * 刪除數據
     *
     * @param sql sql語句
     * @return int
     */
    @Override
    public int sqlDelete(String sql) {
        String msId = this.msUtils.delete(sql);
        return this.sqlSession.delete(msId);
    }

    /**
     * 查詢數據返回List<T>
     *
     * @param sql   sql語句
     * @param value 參數
     * @return int
     */
    @Override
    public int sqlDelete(String sql, Object value) {
        Class<?> parameterType = value != null ? value.getClass() : null;
        String msId = this.msUtils.deleteDynamic(sql, parameterType);
        return this.sqlSession.delete(msId, value);
    }

    /**
     * 進行預編譯
     */
    private class MSUtils {
        private Configuration configuration;
        private LanguageDriver languageDriver;

        private MSUtils(Configuration configuration) {
            this.configuration = configuration;
            this.languageDriver = configuration.getDefaultScriptingLanguageInstance();
        }

        private String newMsId(String sql, SqlCommandType sqlCommandType) {
            StringBuilder msIdBuilder = new StringBuilder(sqlCommandType.toString());
            msIdBuilder.append(".").append(sql.hashCode());
            return msIdBuilder.toString();
        }

        private boolean hasMappedStatement(String msId) {
            return this.configuration.hasStatement(msId, false);
        }

        private void newSelectMappedStatement(String msId, SqlSource sqlSource, final Class<?> resultType) {
            MappedStatement ms = (new MappedStatement.Builder(this.configuration, msId, sqlSource, SqlCommandType.SELECT)).resultMaps(new ArrayList<ResultMap>() {
                {
                    this.add((new org.apache.ibatis.mapping.ResultMap.Builder(com.culturalCenter.placeManage.mapper.SqlMapper.MSUtils.this.configuration, "defaultResultMap", resultType, new ArrayList(0))).build());
                }
            }).build();
            this.configuration.addMappedStatement(ms);
        }

        private void newUpdateMappedStatement(String msId, SqlSource sqlSource, SqlCommandType sqlCommandType) {
            MappedStatement ms = (new MappedStatement.Builder(this.configuration, msId, sqlSource, sqlCommandType)).resultMaps(new ArrayList<ResultMap>() {
                {
                    this.add((new org.apache.ibatis.mapping.ResultMap.Builder(com.culturalCenter.placeManage.mapper.SqlMapper.MSUtils.this.configuration, "defaultResultMap", Integer.TYPE, new ArrayList(0))).build());
                }
            }).build();
            this.configuration.addMappedStatement(ms);
        }

        private String select(String sql) {
            String msId = this.newMsId(sql, SqlCommandType.SELECT);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                StaticSqlSource sqlSource = new StaticSqlSource(this.configuration, sql);
                this.newSelectMappedStatement(msId, sqlSource, Map.class);
                return msId;
            }
        }

        private String selectDynamic(String sql, Class<?> parameterType) {
            String msId = this.newMsId(sql + parameterType, SqlCommandType.SELECT);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                SqlSource sqlSource = this.languageDriver.createSqlSource(this.configuration, sql, parameterType);
                this.newSelectMappedStatement(msId, sqlSource, Map.class);
                return msId;
            }
        }

        private String select(String sql, Class<?> resultType) {
            String msId = this.newMsId(resultType + sql, SqlCommandType.SELECT);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                StaticSqlSource sqlSource = new StaticSqlSource(this.configuration, sql);
                this.newSelectMappedStatement(msId, sqlSource, resultType);
                return msId;
            }
        }

        private String selectDynamic(String sql, Class<?> parameterType, Class<?> resultType) {
            String msId = this.newMsId(resultType + sql + parameterType, SqlCommandType.SELECT);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                SqlSource sqlSource = this.languageDriver.createSqlSource(this.configuration, sql, parameterType);
                this.newSelectMappedStatement(msId, sqlSource, resultType);
                return msId;
            }
        }

        private String insert(String sql) {
            String msId = this.newMsId(sql, SqlCommandType.INSERT);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                StaticSqlSource sqlSource = new StaticSqlSource(this.configuration, sql);
                this.newUpdateMappedStatement(msId, sqlSource, SqlCommandType.INSERT);
                return msId;
            }
        }

        private String insertDynamic(String sql, Class<?> parameterType) {
            String msId = this.newMsId(sql + parameterType, SqlCommandType.INSERT);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                SqlSource sqlSource = this.languageDriver.createSqlSource(this.configuration, sql, parameterType);
                this.newUpdateMappedStatement(msId, sqlSource, SqlCommandType.INSERT);
                return msId;
            }
        }

        private String update(String sql) {
            String msId = this.newMsId(sql, SqlCommandType.UPDATE);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                StaticSqlSource sqlSource = new StaticSqlSource(this.configuration, sql);
                this.newUpdateMappedStatement(msId, sqlSource, SqlCommandType.UPDATE);
                return msId;
            }
        }

        private String updateDynamic(String sql, Class<?> parameterType) {
            String msId = this.newMsId(sql + parameterType, SqlCommandType.UPDATE);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                SqlSource sqlSource = this.languageDriver.createSqlSource(this.configuration, sql, parameterType);
                this.newUpdateMappedStatement(msId, sqlSource, SqlCommandType.UPDATE);
                return msId;
            }
        }

        private String delete(String sql) {
            String msId = this.newMsId(sql, SqlCommandType.DELETE);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                StaticSqlSource sqlSource = new StaticSqlSource(this.configuration, sql);
                this.newUpdateMappedStatement(msId, sqlSource, SqlCommandType.DELETE);
                return msId;
            }
        }

        private String deleteDynamic(String sql, Class<?> parameterType) {
            String msId = this.newMsId(sql + parameterType, SqlCommandType.DELETE);
            if (this.hasMappedStatement(msId)) {
                return msId;
            } else {
                SqlSource sqlSource = this.languageDriver.createSqlSource(this.configuration, sql, parameterType);
                this.newUpdateMappedStatement(msId, sqlSource, SqlCommandType.DELETE);
                return msId;
            }
        }
    }
}

然后做一個數據連接工廠類

SqlSessionFactoryConfig

/**
 * @author chaild
 * @Date 2020年6月23日18:25:22
 *  創建SQL連接工廠類
 * */
@Configuration
public class SqlSessionFactoryConfig {
    @javax.annotation.Resource
    DruidDataSource dataSource;

    @Bean
    @Primary
    public SqlSessionFactory sqlSessionFactory() throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);//更多參數請自行注入
        bean.setPlugins(new Interceptor[]{new SqlInterceptor()});
        Resource[] resources = new PathMatchingResourcePatternResolver()
                .getResources("classpath*:mapper/*.xml");
        bean.setMapperLocations(resources);
        return bean.getObject();
    }
}

使用示例：

@Autowired 
private SqlMapper sqlMapper;

###selectList

//查詢，返回List<Map>
List<Map<String, Object>> list = sqlMapper.selectList("select * from country where id < 11");

//查詢，返回指定的實體類
List<Country> countryList = sqlMapper.selectList("select * from country where id < 11", Country.class);

//查詢，帶參數
countryList = sqlMapper.selectList("select * from country where id < #{id}", 11, Country.class);

//復雜點的查詢，這里參數和上面不同的地方，在於傳入了一個對象
Country country = new Country();
country.setId(11);
countryList = sqlMapper.selectList("<script>" +
        "select * from country " +
        "   <where>" +
        "       <if test=\"id != null\">" +
        "           id &lt; #{id}" +
        "       </if>" +
        "   </where>" +
        "</script>", country, Country.class);
##復雜查詢使用map傳入參數   
 Map<String,String> map=new HashMap<>();
map.put("id","21321312312312312");
map.put("status","1");
sqlMapper.sqlSelectList("select * from tb_admin where id=#{id} and status=#{status}",map,Admin.class);


###selectOne 查詢單條數據

Map<String, Object> map = sqlMapper.selectOne("select * from country where id = 35");

map = sqlMapper.selectOne("select * from country where id = #{id}", 35);

Country country = sqlMapper.selectOne("select * from country where id = 35", Country.class);

country = sqlMapper.selectOne("select * from country where id = #{id}", 35, Country.class);
###insert,update,delete

###insert 插入數據
int result = sqlMapper.insert("insert into country values(1921,'天朝','TC')");

Country tc = new Country();
tc.setId(1921);
tc.setCountryname("天朝");
tc.setCountrycode("TC");
//注意這里的countrycode和countryname故意寫反的
result = sqlMapper.insert("insert into country values(#{id},#{countrycode},#{countryname})"
                          , tc);


###update 更新使用
result = sqlMapper.update("update country set countryname = '天朝' where id = 35");

tc = new Country();
tc.setId(35);
tc.setCountryname("天朝");

int result = sqlMapper.update("update country set countryname = #{countryname}" +
           " where id in(select id from country where countryname like 'A%')", tc);


##delete 刪除使用
result = sqlMapper.delete("delete from country where id = 35");
result = sqlMapper.delete("delete from country where id = #{id}", 35);

如果實現了 Interceptor 類進行SQL二次處理封裝，會報二次編譯的問題

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 mybatis-plus在mapper.xml自定義sql問題 mybaties實體的 Mapper.xml文件中自定義sql時模糊查詢的寫法 mybatis里的mapper，@Mapper參數，Mapper.xml文件 sql語句Select+where語句 mapper.xml中sql語句 Mybatis傳多個參數（三種解決方案） mapper.xml的sql語句修改！ MyBatis Mapper.xml文件中 MySql的SQL語句比較大小 Mybatis手工寫sql語句及Mapper.xml方法 mapper.xml文件，sql語句參數為list Spring Boot配置自定義mapper.xml文件 Spring Boot自定義Mapper的SQL語句