2. 程式人生 > 實用技巧 >mybatis 使用自定義sql 語句

mybatis 使用自定義sql 語句

阿新 • • 發佈：2020-07-25

新建一個介面 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();
    }
}

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

相關推薦

Mybatis 自定義SQL語句（執行任意語句）

Mybatis 直接執行SQL 好久不更新部落格了，今天開發遇到一個問題就是如何在mybatis中直接執行sql，直接上程式碼：

mybatis 使用自定義sql 語句

新建一個介面 SqlBaseMapper 封裝常用的增刪改查 public interface SqlBaseMapper { /** * 查詢單條資料返回Map<String, Object>

MyBatis-Plus 自定義sql語句的實現

一、引言 Good Good Study，Day Day Up，童鞋點個關注，不迷路，麼麼噠～～～ MP自帶的條件構造器雖然很強大，有時候也避免不了寫稍微複雜一點業務的sql，那麼那麼今天說說MP怎麼自定義sql語句吧。

Mybatis Plus分頁及自定義SQL語句

技術標籤：javamybatis ** 1、資料庫的連線配置 首先我們要配置資料的連線等相關資訊，因此我們需要在application.properties檔案中，增加如下定義：

Mybatis自定義SQL的關係對映、分頁、排序

技術標籤：Mybatis-plus 目的： 記錄資料庫表與實體物件之間不同的對映關係如何用mybatis的自定義sql和結果返回集處理。

Mybatis自定義SQL的關係對映、分頁、排序功能的實現

目的： 記錄資料庫表與實體物件之間不同的對映關係如何用mybatis的自定義sql和結果返回集處理。

django執行自定義sql語句

from django.http import HttpResponse,JsonResponse from django.shortcuts import render from django.db import connection

MyBatis-Plus 分頁查詢以及自定義sql分頁的實現

一、引言 分頁查詢每個人程式猿幾乎都使用過，但是有部分同學不懂什麼是物理分頁和邏輯分頁。

Mybatis Plus 自定義sql

匯入依賴(mybatis-plus的版本要大於3.1.2，這裡使用的是3.2.0，不然會報錯) pom.xml <!--mybatis-plus-->

mybatis-plus 自定義SQL，XML形式，傳參的幾種方式

mybatis-plus 自定義SQL，XML形式，傳參的幾種方式 前提說明 所涉及檔案 傳參型別說明

Mybatis Plus 自定義SQL和分頁外掛

一、使用條件構造器的自定義SQL 1、使用註解的方式 public interface UserMapper extends BaseMapper<User> {

mybatis-plus 自定義sql

自定義mybatisplus sql 自定義首先繼承於 DefaultSqlInjector 這個類 實現介面 getMethodList

mybatis/mybatis-plus 自定義SQL（多表查詢）

轉：https://blog.csdn.net/aiwangtingyun/article/details/120225563 一、Mapper.java 和 Mapper.xml 對映關係Mybatis 為我們提供了基本的增刪改查的介面，特別是 Mybatis-Plus 提供的 Wrappers 更是可以組合出更復

Mybatis自定義TypeHandler解決特殊型別轉換問題詳解

我們知道，Java和MySQL中的資料型別是不同的，Java中除了基本資料型別，還有物件。

MyBatis的動態SQL語句實現

1. 動態SQL之<if>標籤 我們根據實體類的不同取值，使用不同的SQL語句來進行查詢。比如在id如果不為空時可以根據id查詢，如果username不為空時還要加入使用者名稱作為條件，這種情況在我們的多條件組合查詢中經

Mybatis中使用SQL語句插入資料全為0

<!-- public int insertUser(User user); --> <insert id=\"insertUser\" parameterType=\"com.offcn.pojo.User\" >

Mybatis自定義typeHandle過程解析

一 前言 本篇文章的基礎是建立在mybatis配置 二 準備工作 2.1建表語句 CREATE TABLE `customer` (

JPA自定義sql的三種方式

1：在repository介面上註解@Query引數 1：@Query(\"select o fromAgentInfoowhere o.userId = ?1 and o.balance<0\")

小書MybatisPlus第3篇-自定義SQL

本檔案為一個系列，前面章節： 小書MybatisPlus第1篇-整合SpringBoot快速開始增刪改查

如何為預先資料庫建立自定義SQL Server複製

　　SyncNavigator是一款功能強大的資料庫同步軟體，適用於SQLSERVER, MySQL，具有自動/定時同步資料、無人值守、故障自動恢復、同構/異構資料庫同步、斷點續傳和增量同步等功能，支援Windows xp以上所有作業系統，