SQL 类

MyBatis 提供了一个 SQL 工具类，使用这个工具类，我们可以很方便在 Java 代码动态构建 SQL 语句

String newSql = new SQL() ({
  SELECT("P.ID, P.USERNAME, P.PASSWORD, P.FULL NAME");
  SELECT("P.LAST NAME, P.CREATED ON, P.UPDATED ON");
  FROM("PERSON P");
  FROM("ACCOUNT A");
  INNER JOIN("DEPARTMENT D ON DID=P.DEPARTMENT ID");
  INNER JOIN("COMPANY C On D.COMPANY ID=C.ID");
  WHERE("P.ID = A.ID");
  WHERE("P.FIRST NAME like ?");
  OR();
  WHERE("P.LAST NAME like ?");
  GROUP BY("P.ID");
  HAVING("P.LAST_NAME like ?");
  OR();
  HAVING("P.FIRST NAME like ?");
  ORDER BY("P.ID");
  ORDER BY("P.FULL NAME");
}}.tostring();

如上面的代码所示，创建了一个匿名的 SQL 类的子类，在匿名子类的初始化代码块中，调用 SELECT()、FROM() 等方法构建 SQL 语句，这种方式能够很好地避免字符串拼接过程中缺少空格或者偶然间重复出现的 AND 关键字导致的 SOL 语句不正确

除了 SELECT 语句外，SQL 工具类也可以用作构建 UPDATE、INSERT 等语句

@Test
public void testInsertSql() {
  String insertSql = new SQL().
    INSERT INTO("PERSON").
    VALUES("ID, FIRST NAME","#{id}, #{firstName}").
    VALUES("LAST NAME","#(lastName}").toString();
  System.out.println(insertSal);
}

@Test
public void testDeleteSql() {
  String deleteSql= new SQL() {{
    DELETE FROM("PERSON");
    WHERE("ID = #{id)");
  }}.toString();
  System.out.println(deleteql);
}

@Test
public void testUpdateSql() {
  String updateSql= new SQL() {{
    UPDATE("PERSON");
    SET("FIRST NAME = #{firstName}");
    WHERE("ID = #{id}");
  }}.toString();
  System.out.println(updateSql);
}

使用 SQL 工具类的另一个好处是可以很方便地在 Java 代码中根据条件动态地拼接 SQL 语句

public String selectPerson(final String id, final String firstName, final String lastName) {
  return new SQL() {{
    SELECT("P.ID, P.USERNAME, P.PASSWORD");
    SELECT("P.FIRST_NAME, P.LAST NAME");
    FROM("PERSON P");
    if (id != null) {
      WHERE("P.ID=#{id}");
    }
    if (firstName != null) {
      WHERE("P.FIRST_NAME=#{firstName}");
    }
    if (lastName != null) {
      WHERE("P.LAST_NAME=#{lastName}");
    }
  }}.toString();
}

ScriptRunner

该工具类用于读取脚本文件中的 SQL 语句并执行

public void testscriptRunner() {
  try  {
    Connection connection=DriverManager.getConnection("jdbc:hsqldb:mem:mybatis","sa","");
    Scriptrunner scriptRunnermnew ScriptRunner(connection):
    scriptrunner.runScript(Resources.getResourceAsReader("create-table.sql"))
  } catch (Exception e) {
    e.printstackTrace();
  }
}

如上面的代码所示，ScriptRunner 工具类的构造方法需要一个 java.sql.Connection 对象作为参数。创建 ScriptRunner 对象后，调用该对象的 runScript 方法即可，该方法接收一个读取 SQL 脚本文件的 Reader 对象作为参数

ScriptRunner 工具类中提供了一些属性，用于控制执行 SQL 脚本的一些行为，代码如下;

public class ScriptRunner{
  // SQL异常是否中断程序执行
  private boolean stopOnError;
  // 是否抛出 SQLWarning 警告
  private boolean throwWarning;
  //是否自动提交
  private boolean autoCommit;
  // 属性为 true 时，批量执行文件中的 SQL 语句
  //为false时逐条执行 sQL 语句，默认情况下，SQL语句以分号分割
  private boolean sendfullScript;
  //是否去除Windows系统换行符中的\r
  private boolean removecrs;
  //设置statement属性是否支持转义处理
  private boolean escapeProcessing=true;
  // 日志输出位置，默认标准输入输出，即控制台
  private PrintWriter logWriter=new PrintWriter(System.out);
  // 错误日志输出位置，默认控制台
  private PrintWriter errorLoqWriter =new PrintWriter(System.err);
  // 脚本文件中 SOL 语句的分隔符，默认为分号
  private String delimi