mybatis怎么进行使用

mybatis怎么进行使用，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

1.数据源DataSource

2.mapper.xml文件

3.Dao类的实例化

方法一：原生方法的实例化

自定义一个BaseDao抽象类实现SqlSessionDaoSupport并注入sqlSessionFactory，通过namespace+id找到mapper.xml文件

方法二：spring-mytabis动态代理生成实例化

4.分页插件

4.1自定义分页插件

                                                                                        package com.unilife.commons.utils;import com.unilife.commons.dto.Page;import org.apache.ibatis.executor.ErrorContext;import org.apache.ibatis.executor.ExecutorException;import org.apache.ibatis.executor.statement.BaseStatementHandler;import org.apache.ibatis.executor.statement.RoutingStatementHandler;import org.apache.ibatis.executor.statement.StatementHandler;import org.apache.ibatis.mapping.BoundSql;import org.apache.ibatis.mapping.MappedStatement;import org.apache.ibatis.mapping.ParameterMapping;import org.apache.ibatis.mapping.ParameterMode;import org.apache.ibatis.plugin.*;import org.apache.ibatis.reflection.MetaObject;import org.apache.ibatis.reflection.property.PropertyTokenizer;import org.apache.ibatis.scripting.xmltags.ForEachSqlNode;import org.apache.ibatis.session.Configuration;import org.apache.ibatis.type.TypeHandler;import org.apache.ibatis.type.TypeHandlerRegistry;import org.springframework.util.StringUtils;import java.lang.reflect.Field;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.util.List;import java.util.Properties;@Intercepts({ @Signature(type = StatementHandler.class, method = "prepare", args = { Connection.class }) })public class PagePlugin implements Interceptor {        private String dialect = ""; // 数据库方言        private String pageSqlId = ""; // mapper.xml中需要拦截的ID(正则匹配)        @Override        public Object intercept(Invocation ivk) throws Throwable {                if (ivk.getTarget() instanceof RoutingStatementHandler) {                        RoutingStatementHandler statementHandler = (RoutingStatementHandler) ivk                                        .getTarget();                        BaseStatementHandler delegate = (BaseStatementHandler) ReflectHelper                                        .getValueByFieldName(statementHandler, "delegate");                        MappedStatement mappedStatement = (MappedStatement) ReflectHelper                                        .getValueByFieldName(delegate, "mappedStatement");                        if (mappedStatement.getId().matches(pageSqlId)) { // 拦截需要分页的SQL                                BoundSql boundSql = delegate.getBoundSql();                                Object parameterObject = boundSql.getParameterObject();// 分页SQL中parameterType属性对应的实体参数，即Mapper接口中执行分页方法的参数,该参数不得为空                                if (parameterObject == null) {                                        throw new NullPointerException("parameterObject尚未实例化！");                                } else {                                        Connection connection = (Connection) ivk.getArgs()[0];                                        String sql = boundSql.getSql();                                        String countSql = "select count(0) from (" + sql                                                        + ") tmp_count"; // 记录统计                                        PreparedStatement countStmt = connection                                                        .prepareStatement(countSql);                                        BoundSql countBS = new BoundSql(                                                        mappedStatement.getConfiguration(), countSql,                                                        boundSql.getParameterMappings(), parameterObject);                                        /*                                         * 此处特殊处理foreach的参数                                         */                                        Field metaParamsField = ReflectHelper.getFieldByFieldName(                                                        boundSql, "metaParameters");                                        if (metaParamsField != null) {                                                MetaObject mo = (MetaObject) ReflectHelper                                                                .getValueByFieldName(boundSql, "metaParameters");                                                ReflectHelper.setValueByFieldName(countBS,                                                                "metaParameters", mo);                                        }                                        setParameters(countStmt, mappedStatement, countBS,                                                        parameterObject);                                        ResultSet rs = countStmt.executeQuery();                                        int count = 0;                                        if (rs.next()) {                                                count = rs.getInt(1);                                        }                                        rs.close();                                        countStmt.close();                                        // System.out.println(count);                                        Page page = null;                                        if (parameterObject instanceof Page) { // 参数就是Page实体                                                page = (Page) parameterObject;                                                page.setEntityOrField(true); // 见com.flf.entity.Page.entityOrField                                                                                                                // // 注释                                                page.setTotalResult(count);                                        } else { // 参数为某个实体，该实体拥有Page属性                                                Field pageField = ReflectHelper.getFieldByFieldName(                                                                parameterObject, "page");                                                if (pageField != null) {                                                        page = (Page) ReflectHelper.getValueByFieldName(                                                                        parameterObject, "page");                                                        if (page == null)                                                                page = new Page();                                                        page.setEntityOrField(false); // 见com.flf.entity.Page.entityOrField                                                                                                                        // 注释                                                        page.setTotalResult(count);                                                        ReflectHelper.setValueByFieldName(parameterObject,                                                                        "page", page); // 通过反射，对实体对象设置分页对象                                                } else {                                                        throw new NoSuchFieldException(parameterObject                                                                        .getClass().getName() + "不存在 page 属性！");                                                }                                        }                                        String pageSql = generatePageSql(sql, page);                                        ReflectHelper.setValueByFieldName(boundSql, "sql", pageSql); // 将分页sql语句反射回BoundSql.                                }                        }                }                return ivk.proceed();        }        @Override        public Object plugin(Object target) {                return Plugin.wrap(target, this);        }        /**         * 对SQL参数(?)设值,参考org.apache.ibatis.executor.parameter.         * DefaultParameterHandler         *          * @param ps         * @param mappedStatement         * @param boundSql         * @param parameterObject         * @throws SQLException         */        private void setParameters(PreparedStatement ps,                        MappedStatement mappedStatement, BoundSql boundSql,                        Object parameterObject) throws SQLException {                ErrorContext.instance().activity("setting parameters")                                .object(mappedStatement.getParameterMap().getId());                List parameterMappings = boundSql                                .getParameterMappings();                if (parameterMappings != null) {                        Configuration configuration = mappedStatement.getConfiguration();                        TypeHandlerRegistry typeHandlerRegistry = configuration                                        .getTypeHandlerRegistry();                        MetaObject metaObject = parameterObject == null ? null                                        : configuration.newMetaObject(parameterObject);                        for (int i = 0; i < parameterMappings.size(); i++) {                                ParameterMapping parameterMapping = parameterMappings.get(i);                                if (parameterMapping.getMode() != ParameterMode.OUT) {                                        Object value;                                        String propertyName = parameterMapping.getProperty();                                        PropertyTokenizer prop = new PropertyTokenizer(propertyName);                                        if (parameterObject == null) {                                                value = null;                                        } else if (typeHandlerRegistry                                                        .hasTypeHandler(parameterObject.getClass())) {                                                value = parameterObject;                                        } else if (boundSql.hasAdditionalParameter(propertyName)) {                                                value = boundSql.getAdditionalParameter(propertyName);                                        } else if (propertyName                                                        .startsWith(ForEachSqlNode.ITEM_PREFIX)                                                        && boundSql.hasAdditionalParameter(prop.getName())) {                                                value = boundSql.getAdditionalParameter(prop.getName());                                                if (value != null) {                                                        value = configuration.newMetaObject(value)                                                                        .getValue(                                                                                        propertyName.substring(prop                                                                                                        .getName().length()));                                                }                                        } else {                                                value = metaObject == null ? null : metaObject                                                                .getValue(propertyName);                                        }                                        TypeHandler typeHandler = parameterMapping.getTypeHandler();                                        if (typeHandler == null) {                                                throw new ExecutorException(                                                                "There was no TypeHandler found for parameter "                                                                                + propertyName + " of statement "                                                                                + mappedStatement.getId());                                        }                                        typeHandler.setParameter(ps, i + 1, value,                                                        parameterMapping.getJdbcType());                                }                        }                }        }        /**         * 根据数据库方言，生成特定的分页sql         *          * @param sql         * @param page         * @return         */        private String generatePageSql(String sql, Page page) {                if (page != null && StringUtils.hasLength(dialect)) {                        StringBuffer pageSql = new StringBuffer();                        if ("mysql".equals(dialect)) {                                pageSql.append(sql);                if (StringUtils.hasLength(page.getSort())) {                    pageSql.append(" ORDER BY " + page.getSort());                    if (StringUtils.hasLength(page.getSort())) {                        pageSql.append(" " + page.getOrder());                    }                }                                pageSql.append(" limit " + page.getCurrentResult() + ","                                                + page.getShowCount());                        } else if ("oracle".equals(dialect)) {                                pageSql.append("select * from (select tmp_tb.*,ROWNUM row_id from (");                                pageSql.append(sql);                                pageSql.append(") tmp_tb where ROWNUM<=");                                pageSql.append(page.getCurrentResult() + page.getShowCount());                                pageSql.append(") where row_id>");                                pageSql.append(page.getCurrentResult());                                if (StringUtils.hasLength(page.getSort())) {                    pageSql.append(" ORDER BY " + page.getSort());                    if (StringUtils.hasLength(page.getSort())) {                        pageSql.append(" " + page.getOrder());                    }                }                        }                        return pageSql.toString();                } else {                        return sql;                }        }        @Override        public void setProperties(Properties properties) {                dialect = properties.getProperty("dialect");                pageSqlId = properties.getProperty("pageSqlId");        }}class ReflectHelper {        /**         * 获取obj对象fieldName的Field         *          * @param obj         * @param fieldName         * @return         */        public static Field getFieldByFieldName(Object obj, String fieldName) {                for (Class superClass = obj.getClass(); superClass != Object.class; superClass = superClass                                .getSuperclass()) {                        try {                                return superClass.getDeclaredField(fieldName);                        } catch (NoSuchFieldException e) {                        }                }                return null;        }        /**         * 获取obj对象fieldName的属性值         *          * @param obj         * @param fieldName         * @return         * @throws SecurityException         * @throws NoSuchFieldException         * @throws IllegalArgumentException         * @throws IllegalAccessException         */        public static Object getValueByFieldName(Object obj, String fieldName)                        throws SecurityException, NoSuchFieldException,                        IllegalArgumentException, IllegalAccessException {                Field field = getFieldByFieldName(obj, fieldName);                Object value = null;                if (field != null) {                        if (field.isAccessible()) {                                value = field.get(obj);                        } else {                                field.setAccessible(true);                                value = field.get(obj);                                field.setAccessible(false);                        }                }                return value;        }        /**         * 设置obj对象fieldName的属性值         *          * @param obj         * @param fieldName         * @param value         * @throws SecurityException         * @throws NoSuchFieldException         * @throws IllegalArgumentException         * @throws IllegalAccessException         */        public static void setValueByFieldName(Object obj, String fieldName,                        Object value) throws SecurityException, NoSuchFieldException,                        IllegalArgumentException, IllegalAccessException {                Field field = obj.getClass().getDeclaredField(fieldName);                if (field.isAccessible()) {                        field.set(obj, value);                } else {                        field.setAccessible(true);                        field.set(obj, value);                        field.setAccessible(false);                }        }}
4.2 开源分页插件
com.github.pagehelper
5.补充，可以通过mybatis-config.xml进行configuration对象的配置
看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注行业资讯频道，感谢您对的支持。

        


        
 很赞哦！ 
        


        



        参数
            对象
            数据
            实体
            属性
            实例
            方法
            插件
            数据库
            数据源
            配置
            文件
            方言
            注释
            反射
            帮助
            生成
            清楚
            特殊
            内容
    
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全

互联网高科技
互联网新科技
广东万易互联网科技有限公司惠州分公司
北京路客互联网科技有限公司
今日互联网科技
互联网核心科技是什么
齐家互联网科技
鑫亿盛互联网科技
上海亿帐通互联网科技
甘肃拓世互联网科技有限公司
恒银科技与互联网金融
中国的互联网科技企业的崛起
中化能源互联网科技招聘
互联网公司科技股
众安科技工业互联网合作
互联网金融科技元年
万物互联网智能科技
知域互联网科技有限公司官网
互联网科技快速发展优美句子
武汉亿视互联网科技有限公司
互联网科技园
小米移动互联网科技园
互联网科技工作委员会副主任毛军
互联网科技类展会
开启互联网科技时代小说
温州喔噻互联网科技有限公司
成都铂石互联网科技做什么的
崇明区互联网教育科技诚信经营
浙南科技城互联网大厦建设工程
杭州融税互联网科技有限公司
        
        


        

          

            
扫描关注千家信息网微信公众号，第一时间获取内容更新动态
            
转载请说明来源于"千家信息网"
            
本文地址：https://www.qianjiagd.com/a45255
          
        
        

        

          

            
上一篇
              
Java中怎么实现 for循环
              
本篇文章给大家分享的是有关Java中怎么实现 for循环，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。第一种写法：public clas
              
            
下一篇
              
Redis基础知识有哪些
              
这篇文章主要为大家展示了"Redis基础知识有哪些"，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下"Redis基础知识有哪些"这篇文章吧。Redis基础知识1
              
          
        
      
    


    



    

      

        
相关文章
      
      

        
搭建zoopker+hbase 环境
        
版本控制系统（git + gitolite）
        
【新梦想老师分享】分布式锁的正确"姿势"
        
如何搭建母婴社区
        
spring通过profile实现开发和测试环境切换
        
最新2.7版本丨DataPipeline数据融合产品最新版本
        
串口调试助手，VB6.0开发
        
七、flink--异步IO
        
团队转型之痛之悟
        
Oracle 和 MySQL 的 JDBC 到底有多慢?
        
      
    





   





  































0