11.2.1 基于注解的动态SQL1 select

动态生成注解形式的select语句

根据Map动态生成select

在Provider.java中添加返回动态SQL的方法

在EmployeeDynamicSQLProvider.java中加入如下方法:

G:\workspace_web2\MyADynamicSQLTest\src\mapper\EmployeeDynamicSQLProvider.java

public String selectEmployeeWithParamMap(Map<String, Object> param)
{
    return new SQL() {
        {
            SELECT("*");
            FROM("tb_employee");
            if (param.get("id") != null)
            {
                WHERE("id=#{id}");
            }
            if (param.get("loginname") != null)
            {
                WHERE("loginname=#{loginname}");
            }
            if (param.get("password") != null)
            {
                WHERE("password=#{password}");
            }
            if (param.get("name") != null)
            {
                WHERE("name=#{name}");
            }
            if (param.get("sex") != null)
            {
                WHERE("sex=#{sex}");
            }
            if (param.get("age") != null)
            {
                WHERE("age=#{age}");
            }
            if (param.get("phone") != null)
            {
                WHERE("phone=#{phone}");
            }
            if (param.get("sal") != null)
            {
                WHERE("sal=#{sal}");
            }
            if (param.get("state") != null)
            {
                WHERE("state=#{state}");
            }
        }
    }.toString();
}

该方法根据map的key来动态生成WHERE子句。

mapper接口的方法中引用Provider.java中的方法

并在mapper接口中添加如下方法:

G:\workspace_web2\MyADynamicSQLTest\src\mapper\EmployeeMapper.java

@SelectProvider(
    type = EmployeeDynamicSQLProvider.class,
    method = "selectEmployeeWithParamMap"
)
List<Employee> selectEmployeeWithParamMap(Map<String, Object> param);

测试类 SelectByMapParam.java

/MyADynamicSQLTest/src/test/SelectByMapParam.java

package test;

import java.util.HashMap;
import java.util.List;
import org.apache.ibatis.session.SqlSession;
import domain.Employee;
import fractory.SqlSessionFactoryTools;
import mapper.EmployeeMapper;

public class SelectByMapParam {
    public static void main(String[] args) {
        SqlSession sqlSession = null;
        try {
            // 加载mybatis-config.xml,获取SqlSession实例
            sqlSession = SqlSessionFactoryTools.getSqlSession();
            // 获取mapper接口代理对象
            EmployeeMapper employeeMapper = sqlSession.getMapper(EmployeeMapper.class);
            // 创建Map,作为查询的参数
            HashMap<String, Object> param = new HashMap<String, Object>();
            // param.put("id", 1);
            param.put("sex", "男");
            param.put("age", 19);
            // 执行按map中的参数查询
            List<Employee> employees = employeeMapper.selectEmployeeWithParamMap(param);
            employees.forEach(employee -> System.out.println("    " + employee));
            // 提交事务
            sqlSession.commit();
        } catch (Exception e) {
            // 出错回滚事务
            sqlSession.rollback();
            e.printStackTrace();
        } finally {
            // 关闭会话
            if (sqlSession != null)
                sqlSession.close();
        }
    }
}

运行测试类,控制台输出如下:

DEBUG [main] ==>  Preparing: SELECT * FROM tb_employee WHERE (sex=? AND age=?) 
DEBUG [main] ==> Parameters: 男(String), 19(Integer)
DEBUG [main] <==      Total: 2
    Employee [id=1, loginname=xiaoming, password=xiaoming, name=小明, sex=男, age=19, phone=123456789123, sal=9800.0, state=active]
    Employee [id=2, loginname=xiaowang, password=xiaowang, name=小王, sex=男, age=19, phone=123456789123, sal=6800.0, state=active]

可以看到执行的SQL:

SELECT * FROM tb_employee WHERE (sex=? AND age=?) 

是根据输入的map参数动态生成的。

再添加一个查询条件

现在取消上门的SelectByMapParam.java中id的注释，再往map中放入一个id作为查询条件：

......
// 创建Map,作为查询的参数
HashMap<String, Object> param = new HashMap<String, Object>();
param.put("id", 1);
param.put("sex", "男");
param.put("age", 19);
// 执行按map中的参数查询
List<Employee> employees = employeeMapper.selectEmployeeWithParamMap(param);
employees.forEach(employee -> System.out.println("    " + employee));
......

再次运行,控制台输出如下:

DEBUG [main] ==>  Preparing: SELECT * FROM tb_employee WHERE (id=? AND sex=? AND age=?) 
DEBUG [main] ==> Parameters: 1(Integer), 男(String), 19(Integer)
DEBUG [main] <==      Total: 1
    Employee [id=1, loginname=xiaoming, password=xiaoming, name=小明, sex=男, age=19, phone=123456789123, sal=9800.0, state=active]

可以看到mybatis根据提供的id,sex,age三个参数动态的生成了如下SQL语句:

SELECT * FROM tb_employee WHERE (id=? AND sex=? AND age=?) 

根据持久化对象动态生成select

Provider类中添加动态select方法

在动态SQL生成器EmployeeDynamicSQLProvider.java中添加如下方法:

G:\workspace_web2\MyADynamicSQLTest\src\mapper\EmployeeDynamicSQLProvider.java

public String selectEmployeeWithParamPO(Employee parm)
{
    return new SQL() {
        {
            SELECT("*");
            FROM("tb_employee");
            if (parm.getId() != null)
            {
                WHERE("id=#{id}");
            }
            if (parm.getLoginname() != null)
            {
                WHERE("loginname=#{loginname}");
            }
            if (parm.getPassword() != null)
            {
                WHERE("password=#{password}");
            }
            if (parm.getName() != null)
            {
                WHERE("name=#{name}");
            }
            if (parm.getSex() != null)
            {
                WHERE("sex=#{sex}");
            }
            if (parm.getAge() != null)
            {
                WHERE("age=#{age}");
            }
            if (parm.getPhone() != null)
            {
                WHERE("phone=#{phone}");
            }
            if (parm.getSal() != null)
            {
                WHERE("sal=#{sal}");
            }
            if (parm.getState() != null)
            {
                WHERE("state=#{state}");
            }
        }
    }.toString();
}

在mapper接口中使用Provider类的方法

然后在mapper接口中,添加如下方法:

G:\workspace_web2\MyADynamicSQLTest\src\mapper\EmployeeMapper.java

@SelectProvider(
    type = EmployeeDynamicSQLProvider.class,
    method = "selectEmployeeWithParamPO"
)
List<Employee> selectEmployeeWithParamPo(Employee param);

测试 SelectByPoParam.java

/MyADynamicSQLTest/src/test/SelectByPoParam.java

package test;

import java.util.List;
import org.apache.ibatis.session.SqlSession;
import domain.Employee;
import fractory.SqlSessionFactoryTools;
import mapper.EmployeeMapper;

public class SelectByPoParam {
    public static void main(String[] args) {
        SqlSession sqlSession = null;
        try {
            // 加载mybatis-config.xml,获取SqlSession实例
            sqlSession = SqlSessionFactoryTools.getSqlSession();
            // 获取mapper接口代理对象
            EmployeeMapper employeeMapper = sqlSession.getMapper(EmployeeMapper.class);
            // 创建存放查询条件的PO类
            Employee param = new Employee();
            // param.setId(1);
            param.setAge(19);
            param.setSex("男");
            // 使用PO类里面的套件进行查询
            List<Employee> employees = employeeMapper.selectEmployeeWithParamPo(param);
            // 输出查询结果
            employees.forEach(employee -> System.out.println("  " + employee));
            // 提交事务
            sqlSession.commit();
        } catch (Exception e) {
            // 出错回滚事务
            sqlSession.rollback();
            e.printStackTrace();
        } finally {
            // 关闭会话
            if (sqlSession != null)
                sqlSession.close();
        }
    }
}

我们在测试类中提供了sex和age两个参数。mybatis将会根据这两个参数生成SQL语句,运行该测试类,控制台输出如下:

DEBUG [main] ==>  Preparing: SELECT * FROM tb_employee WHERE (sex=? AND age=?) 
DEBUG [main] ==> Parameters: 男(String), 19(Integer)
DEBUG [main] <==      Total: 2
  Employee [id=1, loginname=xiaoming, password=xiaoming, name=小明, sex=男, age=19, phone=123456789123, sal=9800.0, state=active]
  Employee [id=2, loginname=xiaowang, password=xiaowang, name=小王, sex=男, age=19, phone=123456789123, sal=6800.0, state=active]

再添加一个查询条件

现在取消SelectByPoParam.java中id参数前面的注释,再添加一个id参数作为查询条件,运行测试类,控制台输出如下:

DEBUG [main] ==>  Preparing: SELECT * FROM tb_employee WHERE (id=? AND sex=? AND age=?) 
DEBUG [main] ==> Parameters: 1(Integer), 男(String), 19(Integer)
DEBUG [main] <==      Total: 1
  Employee [id=1, loginname=xiaoming, password=xiaoming, name=小明, sex=男, age=19, phone=123456789123, sal=9800.0, state=active]