本篇内容介绍了“Mybatis怎么直接执行SQL语句”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
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(); }