欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

通用mapper生成sql及mybatis使用过程

程序员文章站 2022-05-09 22:36:33
...

 

sql装配,自己实现一个,通用mapper和mybatis-generator是两个东西各自功能不同,结合使用而已

通用mapper:

1,省略单表操作的xml

2,不必写实现类(用通用mapper的单表操作方法不用,用xml中sql(mybatis)也不用)

   mybaits      VS         hibernate

mybatis-generator对应hibernate反向工程

通用mapper对应spring-data-jpa

 

 

(一)、通用mapper生成sql过程:

 

生成具体生成sql的地方在相应的操作方法接口中

 

public interface SelectOneMapper<T> {

 

    /**

     * 鏍规嵁瀹炰綋涓殑灞炴�杩涜鏌ヨ锛屽彧鑳芥湁涓�釜杩斿洖鍊硷紝鏈夊涓粨鏋滄槸鎶涘嚭寮傚父锛屾煡璇㈡潯浠朵娇鐢ㄧ瓑鍙�

     *

     * @param record

     * @return

     */

    @SelectProvider(type = BaseSelectProvider.class, method = "dynamicSQL")

    T selectOne(T record);

 

}

 

public class BaseSelectProvider extends MapperTemplate 

 

“V”型调试

 

MapperTemplate中setSqlSource:

 

SqlNode sqlNode = (SqlNode) method.invoke(this, ms);BaseSelectProvider--》dynamicSQL///调用对应操作接口的方法获取对应单表语句

DynamicSqlSource dynamicSqlSource = new DynamicSqlSource(ms.getConfiguration(), sqlNode);

setSqlSource(ms, dynamicSqlSource);////自动生成mybatis能用的写在xml中的节点格式语句

 

 

MappedStatement ms这个含有mybatis的1,通用配置,2,基于哪个是实体的单表操作,3,参数,4,哪种操作,5,用什么打印日志

 

sqlNode包含三个段1,select from端,2,表名端,3,where端(由ms得来)

 

 

 

 

 

/**

     * 重新设置SqlSource

     *

     * @param ms

     * @throws java.lang.reflect.InvocationTargetException

     * @throws IllegalAccessException

     */

    public void setSqlSource(MappedStatement ms) throws Exception {

        if (this.mapperClass == getMapperClass(ms.getId())) {

            throw new RuntimeException("请不要配置或扫描通用Mapper接口类:" + this.mapperClass);

        }

        Method method = methodMap.get(getMethodName(ms));

        try {

            //第一种,直接操作ms,不需要返回值

            if (method.getReturnType() == Void.TYPE) {

                method.invoke(this, ms);

            }

            //第二种,返回SqlNode

            else if (SqlNode.class.isAssignableFrom(method.getReturnType())) {

                SqlNode sqlNode = (SqlNode) method.invoke(this, ms);

                DynamicSqlSource dynamicSqlSource = new DynamicSqlSource(ms.getConfiguration(), sqlNode);

                setSqlSource(ms, dynamicSqlSource);

            }

            //第三种,返回xml形式的sql字符串

            else if (String.class.equals(method.getReturnType())) {

                String xmlSql = (String) method.invoke(this, ms);

                SqlSource sqlSource = createSqlSource(ms, xmlSql);

                //替换原有的SqlSource

                setSqlSource(ms, sqlSource);

            } else {

                throw new RuntimeException("自定义Mapper方法返回类型错误,可选的返回类型为void,SqlNode,String三种!");

            }

            //cache

            checkCache(ms);

        } catch (IllegalAccessException e) {

            throw new RuntimeException(e);

        } catch (InvocationTargetException e) {

            throw new RuntimeException(e.getTargetException() != null ? e.getTargetException() : e);

        }

    }

 

    protected void setSqlSource(MappedStatement ms, SqlSource sqlSource)

  {

    MetaObject msObject = SystemMetaObject.forObject(ms);/////////////////////////可知MetaObject其实就是ms

    msObject.setValue("sqlSource", sqlSource);

    

    KeyGenerator keyGenerator = ms.getKeyGenerator();

    if ((keyGenerator instanceof Jdbc3KeyGenerator)) {

      msObject.setValue("keyGenerator", new MultipleJdbc3KeyGenerator());

    }

  }

  

MetaObject:mybatis的类

    public void setValue(String name, Object value)

  {

    PropertyTokenizer prop = new PropertyTokenizer(name);

    if (prop.hasNext())

    {

      MetaObject metaValue = metaObjectForProperty(prop.getIndexedName());

      if (metaValue == SystemMetaObject.NULL_META_OBJECT)

      {

        if ((value == null) && (prop.getChildren() != null)) {

          return;

        }

        metaValue = this.objectWrapper.instantiatePropertyValue(name, prop, this.objectFactory);

      }

      metaValue.setValue(prop.getChildren(), value);

    }

    else

    {

      this.objectWrapper.set(prop, value);

    }

  }

  

查看这几个类:

SqlSourceBuilder

UnpooledDataSourceFactory

Jdbc3KeyGenerator

可知:在检查注入主键的的时候就用MetaObject设置了一次默认的sqlsource(MetaObject是单例)

在具体时候某个通用mapper的单表方法时重置下MetaObject的sqlsource,之后执行sql的时候取到的MetaObject的sqlsource就是覆盖后的()

这个sqlsource的格式就是传统的mybaits.xml手动写的sql节点的格式,之后就交给mybatis去解析这种格式(mybatis使用节点语句都是放到MetaObject中后使用)

 

 

(二)、mybatis中使用ms大致过程:

 

SelectKeyGenerator///使用的地方调用Executor对象

CachingExecutor////////////////这里直接用ms去执行sql

BaseExecutor

MappedStatement

DynamicSqlSource

SqlSourceBuilder

StaticSqlSource

BoundSql

 

 

SelectKeyGenerator:

 

  private void processGeneratedKeys(Executor executor, MappedStatement ms, Object parameter)

  {

    try

    {

      if ((parameter != null) && (this.keyStatement != null) && (this.keyStatement.getKeyProperties() != null))

      {

        String[] keyProperties = this.keyStatement.getKeyProperties();

        Configuration configuration = ms.getConfiguration();

        MetaObject metaParam = configuration.newMetaObject(parameter);

        if (keyProperties != null)

        {

          Executor keyExecutor = configuration.newExecutor(executor.getTransaction(), ExecutorType.SIMPLE);

          List<Object> values = keyExecutor.query(this.keyStatement, parameter, RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);

        ...

}

}}}

CachingExecutor:

 @Override

  public <E> List<E> query(MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {

    BoundSql boundSql = ms.getBoundSql(parameterObject);

    CacheKey key = createCacheKey(ms, parameterObject, rowBounds, boundSql);

    return query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);

  }

 

DynamicSqlSource:

  public BoundSql getBoundSql(Object parameterObject) {

    DynamicContext context = new DynamicContext(configuration, parameterObject);

    rootSqlNode.apply(context);

    SqlSourceBuilder sqlSourceParser = new SqlSourceBuilder(configuration);

    Class<?> parameterType = parameterObject == null ? Object.class : parameterObject.getClass();

    SqlSource sqlSource = sqlSourceParser.parse(context.getSql(), parameterType, context.getBindings());

    BoundSql boundSql = sqlSource.getBoundSql(parameterObject);

    for (Map.Entry<String, Object> entry : context.getBindings().entrySet()) {

      boundSql.setAdditionalParameter(entry.getKey(), entry.getValue());

    }

    return boundSql;

  }

 

StaticSqlSource:

 public StaticSqlSource(Configuration configuration, String sql, List<ParameterMapping> parameterMappings) {

    this.sql = sql;

    this.parameterMappings = parameterMappings;

    this.configuration = configuration;

  }

 

  @Override

  public BoundSql getBoundSql(Object parameterObject) {

    return new BoundSql(configuration, sql, parameterMappings, parameterObject);

  }

 

 

 

 

参考:

http://blog.csdn.net/isea533/article/details/41892319

 

 

 

 

 

相关标签: mapper mybatis