MyBatisMybatis JPA-集成方案+源码

源码地址(git):https://github.com/LittleNewbie/mybatis-jpa

一、Mybatis简介

mybatis闽南语官方文档:http://www.mybatis.org/mybatis-3/zh/index.html

简介是为前边用到的情节做铺垫,熟悉mybatis的爱侣可以平素跳过,到第二章节。

有关mybatis-jpa的选拔办法,请参见博文:http://www.cnblogs.com/svili/p/6828077.html

1.1 SqlSession

Mybatis中3个重点的定义:Configuration(容器),SqlSessionFactory(工厂),SqlSession;

相对于Spring中的applicationContext,BeanFactory,Bean。

不同之处在于SqlSession包含了装有的SQL方法,即那一个SqlSession有且只有一个。SqlSession可以执行mybatis中注册的具有办法。官方示例表达

<!-- SqlSession 完全包含了面向数据库执行 SQL 命令所需的所有方法。
你可以通过 SqlSession 实例来直接执行已映射的 SQL 语句。例如:-->
SqlSession session = sqlSessionFactory.openSession();
try {
  Blog blog = (Blog) session.selectOne("org.mybatis.example.BlogMapper.selectBlog", 101);
} finally {
  session.close();
}

<!-- 映射器实例(Mapper Instances)-->
SqlSession session = sqlSessionFactory.openSession();
try {
  BlogMapper mapper = session.getMapper(BlogMapper.class);
  // do work
} finally {
  session.close();
}

1.2 Namespace

<!DOCTYPE mapper
    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--  xml中命名空间与java中Mapper接口一致  -->
<mapper namespace="org.apache.ibatis.submitted.rounding.Mapper">

</mapper>

1.3 ResultType 和 ResultMap

ResultMap是myabtis最关键最有力的要素,是SQL列名columnName与POJO属性名filedName的尖端结果映射。对ResultMap不熟悉的朋友可以翻阅官方文档精通。

ResultType可以了然为mybatis自动映射生成的大概的ResultMap,当POJO中的filedName与数据库ColumnName不同等时,无法做到映射。

1.4 javaType和typeHandler

ResultMap中使用

<resultMap id="userResultMap" type="User">
  <!--  主键   -->
  <id property="id" column="user_id" />
  <!--  当column类型与field类型不一致时,需指定javaType或typeHandler,二者选其一即可。   -->
  <!--  简单的类型转换只需指定javaType即可,需要逻辑处理的使用typeHandler  -->
  <result property="remark" column="remark" javaType="string"/>
  <result property="effective" column="is_effective" typeHandler="BooleanTypeHandler"/>
</resultMap>

1.5 jdbcType

官方证实:

jdbcType JDBC 类型是
仅需要对插入,更新和删除操作可能为空的列举行拍卖。这是 JDBC jdbcType
的需要,而不是 MyBatis 的。

NOTE: 假诺 null 被当作值来传递,对于有所可能为空的列,JDBC Type
是急需的。你可以自己通过阅读预处理语句的 setNull() 方法的 JavaDocs
文档来探讨这种状态。java.sql.PreparedStatement.setNull()

示例:

<insert id="insertAuthor">
  insert into Author
    (id, username)
  values
    <!--  请注意,当sql中参数可能为null时,需要指定jdbcType,不然会出错  -->
    ('1', #{username,jdbcType=VARCHAR})
</insert>

1.6 MappedStatement

Mapper中的方法(方法签名和可举行的sql语句)会被装进为MappedStatement注册到Configuration中。

详见mybatis源码MapperBuilderAssistant.addMappedStatement(args);

二、Mybatis JPA

2.1 需求

1)首先,我们期待可以与spring集成,使用spring的依靠注入。

2)其次,我们希望可以兼容spring-mybatis集成的代码,拒绝污染。

3)解析注册ResultMap和MappedStatement。

2.2 主线

1)参考spring data
jpa,使用@RepositoryDefinition声明,标记需要自动生成sql的dao。

咱俩应用@MapperDefinition和@StatementDefinition讲明,标记需要自动生成sql的dao和method。

以此是根本,既保证了不传染原有代码,又有何不可接纳spring-mybatis已经落实的倚重性注入。

我们只需要在此基础上,对特定注明标注的mapper类和措施做处理即可。

2)参考spring-mybatis

MapperScannerConfigurer,扫描mapper并注册到mybatis
Configuration中,继而生成代理类。

MapperAnnotationBuilder实现java申明生成ResultMap和MappedStatement。

2.3 入口-MapperEnhancerScaner

在spring容器开头化后,对@MapperDefinition标注的mapper类实行围观。

2.4 解析POJO 生成ResultMap

重中之重:columnName与fieldName映射,特殊字段的jdbcType和typeHandler。

1)columnName与fieldName映射,使用JPA注解@Cloumn即可,不过,我们愿意可以活动转换驼峰与下划线风格,即对于符合规范命名的,不需要注明,直接照射。参见:PersistentUtil,ColumnNameUtil。

MyBatis 1MyBatis 2

 /**
     * 将驼峰标识转换为下划线
     * 
     * @param text
     * @return camel
     */
    public static String camelToUnderline(String text) {
        if (text == null || "".equals(text.trim())) {
            return "";
        }
        StringBuilder result = new StringBuilder(text.length() + 1);
        result.append(text.substring(0, 1));
        for (int i = 1; i < text.length(); i++) {
            if (!Character.isLowerCase(text.charAt(i))) {
                result.append('_');
            }
            result.append(text.substring(i, i + 1));
        }
        return result.toString().toLowerCase();
    }

    /**
     * 将下划线标识转换为驼峰
     * 
     * @param text
     * @return underline
     */
    public static String underlineToCamel(String text) {
        if (text == null || "".equals(text.trim())) {
            return "";
        }
        int length = text.length();
        StringBuilder result = new StringBuilder();
        for (int i = 0; i < length; i++) {
            char c = text.charAt(i);
            if (c == '_') {
                if (++i < length) {
                    result.append(Character.toUpperCase(text.charAt(i)));
                }
            } else {
                result.append(c);
            }
        }
        return result.toString();
    }        

ColunNameUtil

 

2)jdbcType和typeHandler

拍卖了以下3种档次:POJO中的Enum,Boolean,以及数据库中的CLOB,代码见MybatisColumnMeta。

亟待强调表明的是,这里为拥有的field都宣称了jdbcType,是为了躲过sql中参数为null时,爆发异常。

MyBatis 3MyBatis 4

/** meta resolver */
    private static class ColumnMetaResolver {

        public static String resolveJdbcAlias(Field field) {

            Class<?> fieldType = field.getType();
            if (field.getType().isEnum()) {
                if (field.isAnnotationPresent(Enumerated.class)) {
                    // 获取注解对象
                    Enumerated enumerated = field.getAnnotation(Enumerated.class);
                    // 设置了value属性
                    if (enumerated.value() == EnumType.ORDINAL) {
                        return "INTEGER";
                    }
                }
                return "VARCHAR";
            }
            if (field.isAnnotationPresent(Lob.class)) {
                if (String.class.equals(fieldType)) {
                    return "CLOB";
                }
            }
            if (Integer.class.equals(fieldType)) {
                return "INTEGER";
            }
            if (Double.class.equals(fieldType)) {
                return "DOUBLE";
            }
            if (Float.class.equals(fieldType)) {
                return "FLOAT";
            }
            if (String.class.equals(fieldType)) {
                return "VARCHAR";
            }
            // date类型需声明
            if (java.util.Date.class.isAssignableFrom(fieldType)) {
                return "TIMESTAMP";
            }
            return null;
        }

        public static JdbcType resolveJdbcType(String alias) {
            if (alias == null) {
                return null;
            }
            try {
                return JdbcType.valueOf(alias);
            } catch (IllegalArgumentException e) {
                throw new BuilderException("Error resolving JdbcType. Cause: " + e, e);
            }
        }

        @SuppressWarnings("unchecked")
        public static Class<? extends TypeHandler<?>> resolveTypeHandler(Field field) {
            Class<? extends TypeHandler<?>> typeHandlerClass = null;
            if (field.getType().isEnum()) {
                typeHandlerClass = (Class<? extends TypeHandler<?>>) EnumTypeHandler.class;
                if (field.isAnnotationPresent(Enumerated.class)) {
                    // 获取注解对象
                    Enumerated enumerated = field.getAnnotation(Enumerated.class);
                    // 设置了value属性
                    if (enumerated.value() == EnumType.ORDINAL) {
                        typeHandlerClass = (Class<? extends TypeHandler<?>>) EnumOrdinalTypeHandler.class;
                    }
                }
            }

            if (field.getType().equals(Boolean.class)) {
                typeHandlerClass = (Class<? extends TypeHandler<?>>) BooleanTypeHandler.class;
            }
            return typeHandlerClass;
        }
    }

ColumnMetaResolver

 

3)ResultMap注册

见ResultMapAdapter.parseResultMap(args);

2.5 MappedStatement注册

分类处理,select需要用到ResultMap,默认为Pojo.getSimpleName() +
“ResultMap”;

insert和insertSelective的界别:在于null值的处理,尽管column_1在数据库设置了默认值,而参数中的field_1为null值,则insert 在数据库写入null,而insertSelective写入数据库默认值.

急需专门表明的是,动态SQL需要运用”<script></script>”标签包围。

对于各样sql方法的语句生成方法,详见com.mybatis.jpa.statement.builder包下的类。

这里以InsertSelective和select为例

MyBatis 5MyBatis 6

public class InsertSelectiveBuilder implements StatementBuildable {

    @Override
    public String buildSQL(PersistentMeta persistentMeta, Method method) {
        // columns
        StringBuilder columns = new StringBuilder();
        columns.append("<trim prefix='(' suffix=')' suffixOverrides=',' > ");
        // values
        StringBuilder values = new StringBuilder();
        values.append("<trim prefix='(' suffix=')' suffixOverrides=',' > ");
        for (MybatisColumnMeta columnMeta : persistentMeta.getColumnMetaMap().values()) {
            // columns
            columns.append("<if test='" + columnMeta.getProperty() + "!= null'> ");
            columns.append(columnMeta.getColumnName() + ", ");
            columns.append("</if> ");
            // values
            values.append("<if test='" + columnMeta.getProperty() + "!= null'> ");
            values.append(SqlAssistant.resolveSqlParameter(columnMeta) + ", ");
            values.append("</if> ");
        }

        columns.append("</trim> ");
        values.append("</trim> ");

        return "<script>" + "INSERT INTO " + persistentMeta.getTableName() + columns.toString() + " VALUES "
                + values.toString() + "</script>";
    }

    @Override
    public void parseStatement(MybatisStatementAdapter adapter, PersistentMeta persistentMeta, Method method) {
        // 方法名
        adapter.setMethodName(method.getName());
        // 参数类型
        adapter.setParameterTypeClass(persistentMeta.getType());
        // sqlScript
        adapter.setSqlScript(buildSQL(persistentMeta, method));
        // 返回值类型
        adapter.setResultType(int.class);
        adapter.setResultMapId(null);

        adapter.setSqlCommandType(SqlCommandType.INSERT);

        // 主键策略
        adapter.setKeyGenerator(new NoKeyGenerator());
        adapter.setKeyProperty(null);
        adapter.setKeyColumn(null);

        adapter.parseStatement();

    }

}

InsertSelectiveBuilder

 

MyBatis 7MyBatis 8

public class SelectBuilder implements StatementBuildable {

    @Override
    public String buildSQL(PersistentMeta persistentMeta, Method method) {
        return "SELECT " + persistentMeta.getColumnNames() + " FROM " + persistentMeta.getTableName()
                + SqlAssistant.buildSingleCondition(method, persistentMeta);
    }

    @Override
    public void parseStatement(MybatisStatementAdapter adapter, PersistentMeta persistentMeta, Method method) {
        // 方法名
        adapter.setMethodName(method.getName());
        // 参数类型
        if (method.getParameterTypes().length > 0) {
            // Mybatis mapper 方法最多支持一个参数,先设置成Object.class,mybatis会在sql中解析
            adapter.setParameterTypeClass(Object.class);
        } else {
            adapter.setParameterTypeClass(void.class);
        }

        String orderBy = " ";

        if (method.isAnnotationPresent(OrderBy.class)) {
            orderBy = " order by " + method.getAnnotation(OrderBy.class).value();
        }

        // sqlScript
        adapter.setSqlScript(buildSQL(persistentMeta, method) + orderBy);
        // 返回值类型
        adapter.setResultType(persistentMeta.getType());
        adapter.setResultMapId(persistentMeta.getType().getSimpleName() + "ResultMap");

        adapter.setSqlCommandType(SqlCommandType.SELECT);

        // 主键策略
        adapter.setKeyGenerator(new NoKeyGenerator());
        adapter.setKeyProperty(null);
        adapter.setKeyColumn(null);

        adapter.parseStatement();

    }

SelectBuilder

 

ok,以上就是mybatis-jpa的第一设计思路了,具体的细节,我已经竭尽的在代码中加进注释。

关于mybatis-jpa的代码构建利用办法,请参见博文:http://www.cnblogs.com/svili/p/6828077.html

是因为个体力量简单,代码可能有点简陋,如有不妥之处,欢迎指正交流。

 

网站地图xml地图