首頁 > 軟體

Mybatis如何直接執行SQL語句

2022-08-19 22:02:58

Mybatis直接執行SQL語句

有時候我們如果要對傳入的SQL驗證語法方面怎麼辦呢,首先我們是不是要有一條完整的SQL,而且讓mybatis去執行,這是小白最近遇到的,對於使用者輸入進來的語法與引數,進行拼接並且去執行,判斷SQL語句有沒有語法錯誤。

第一種方法

建立一個SQL工具進行SQL處理再返回完整的SQL語句

1.建立工具類

public class SqlProviderUtils {
    public String sqlProvider(Map<String, Object> para) {
        // 要替換一些欄位的SQL(例子 select * from ${table} where ${filter})
        String str = para.get("sql").toString();
        // 引數用於替換SQL中的一些東西(例子: table ,filter 預設值 1=1)
        List<Params> paramsList = (List<Params>) para.get("ParamsList");
        List<Integer> head = new ArrayList();
        List<Integer> tail = new ArrayList();
        int headNum = 0;
        int tailNum = 0;
        List allStr = new ArrayList();
        // 每個${ 與 } 的位置
        int headPos = str.indexOf("${");
        int tailPos = str.indexOf("}");
        while (headPos > -1){
            if (headPos == headNum + 3) {
                head.set(head.size()-1, headPos);
                tail.set(tail.size() - 1, tailNum);
            } else {
                head.add(headPos);
                tail.add(tailPos);
            }
        headNum = headPos;
        tailNum = tailPos;
        headPos = str.indexOf("${", headPos + 1);
        tailPos = str.indexOf("}", tailPos + 1);
    }
        for (int i = 0; i < head.size(); i++) {
            allStr.add(str.substring(head.get(i)+2, tail.get(i)));
        }
        // 這裡是針對上面儲存的一些要替換的欄位進行替換,具體怎麼操作得詳細理解程式碼
        for (int i=0; i<paramsList.size(); i++) {
         str = str.replace("${"+allStr.get(par-1)+"}.${"+paramsList.get(i).getName()+"}","a表");  
        }
        return str;
    }
}

2.在mapper中建立方法呼叫

// SqlProviderUtils上述類,sqlProvider上述的類方法
@SelectProvider(type = SqlProviderUtils.class, method = "sqlProvider")
 List<HaoDTO> sqlTemTest(@Param("sql") String sqlTemplate,@Param("ParamsList") List ParamsList);

3.controller與server沒啥東西就一些三層呼叫這裡不寫

第二種方法

1.server層

 @Override
    @Transactional
    public Boolean testTemplate(Param param) {
        String str = Param.getSql();
        List<Params> paramsList = Param.getParamsList();
        List<Integer> head = new ArrayList();
        List<Integer> tail = new ArrayList();
        Boolean templateType = true;
        int headNum = 0;
        int tailNum = 0;
        List allStr = new ArrayList();
        int headPos = str.indexOf("${");
        int tailPos = str.indexOf("}");
        while (headPos > -1){
            if (headPos == headNum + 3) {
                head.set(head.size()-1, headPos);
                tail.set(tail.size() - 1, tailNum);
            } else {
                head.add(headPos);
                tail.add(tailPos);
            }
            headNum = headPos;
            tailNum = tailPos;
            headPos = str.indexOf("${", headPos + 1);
            tailPos = str.indexOf("}", tailPos + 1);
        }
        for (int i = 0; i < head.size(); i++) {
            try {
                allStr.add(str.substring(head.get(i)+2, tail.get(i)));
            } catch (StringIndexOutOfBoundsException e) {
                templateType = false;
            }
        }
        for (int i=0; i<paramsList.size(); i++) {
           str = str.replace("${"+allStr.get(par-1)+"}.${"+paramsList.get(i).getName()+"}", "b_quality_template");
        }
        try {
            if(templateType){
                baseMapper.sqlTest(str);
            }
        } catch (Exception e){
            templateType = false;
        }
        return templateType;
    }

2.mapper層

@Select("${sqlStr}")
List<Map<String, Object>> sqlTest(@Param(value = "sqlStr") String sqlStr);

3.其他東西也只是一些呼叫

以上只是說明下mybatis中怎麼直接處理sql語句,重點在mapper其他是欄位處理,這是小白弄畢設時考慮到的需求有點簡單莫見怪。

測試Mybatis執行SQL語句步驟

呼叫mybatis某個物件的方法,執行mapper檔案中的sql語句

mybatis核心類:SqlSessionFactory

1.定義mybatis主組態檔的位置, 從類路徑開始的相對路徑——讀取主組態檔裡面的資訊(1.連線資料庫:建立、連線物件的必要資料。2.mapper:找到要執行的sql語句)

2.讀取主組態檔。使用mybatis框架中的Resources類

3.建立SqlSessionFactory物件, 使用SqlSessionFactoryBuidler類  

  • 1)每個基於 MyBatis 的應用都是以一個 SqlSessionFactory的範例為核心的。SqlSessionFactory的範例 可以通過 SqlSessionFactoryBuilder 獲得。而SqlSessionFactoryBuilder 則可以從 XML 組態檔或一個預先設定的 Configuration範例 來構建出 SqlSessionFactory範例 。
  • 2)既然有了 SqlSessionFactory,顧名思義,可以從中獲得SqlSession的範例。SqlSession 提供了在資料庫執行 SQL 命令所需的所有方法。可以通過 SqlSession 範例來直接執行已對映的 SQL 語句。

4.獲取SqlSession物件

5.指定要執行的sql語句的id

  • sql的id = namespace+"."+ select|update|insert|delete標籤的id屬性值

6.通過SqlSession的方法,執行sql語句

7.關閉SqlSession物件

舉例 

@Test
public void testSelectStudentById2() throws IOException {
    //呼叫mybatis某個物件的方法,執行mapper檔案中的sql語句
    //mybatis核心類: SqlSessionFactory
    //1.定義mybatis主組態檔的位置, 從類路徑開始的相對路徑
    String config = "mybatis.xml";
    //2.讀取主組態檔。使用mybatis框架中的Resources類
    InputStream inputStream = Resources.getResourceAsStream(config);
    //3.建立SqlSessionFactory物件, 使用SqlSessionFactoryBuidler類
    // 每個基於 MyBatis 的應用都是以一個 SqlSessionFactory 的範例為核心的。
    // SqlSessionFactory 的範例可以通過 SqlSessionFactoryBuilder 獲得。
    // 而 SqlSessionFactoryBuilder 則可以從 XML 組態檔或一個預先設定的 Configuration 範例來
    // 構建出 SqlSessionFactory 範例。
    SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(inputStream);
    //既然有了 SqlSessionFactory,顧名思義,可以從中獲得 SqlSession 的範例。
    // SqlSession 提供了在資料庫執行 SQL 命令所需的所有方法。
    // 你可以通過 SqlSession 範例來直接執行已對映的 SQL 語句。
    //4.獲取SqlSession物件。
    SqlSession session = factory.openSession();
    //5.指定要執行的sql語句的 id
    //  sql的id = namespace+"."+ select|update|insert|delete標籤的id屬性值
    String sqlId = "com.bjpowernode.dao.StudentDao" + "." + "selectStudentById";
    // 6.通過SqlSession的方法,執行sql語句
    Student student = session.selectOne(sqlId,1002);
    System.out.println("使用mybatis查詢一個學生:" + student);
    // 7.關閉SqlSession物件
    session.close();
}

這些僅為個人經驗,希望能給大家一個參考,也希望大家多多支援it145.com。 


IT145.com E-mail:sddin#qq.com