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安全错误
数据库的锁怎样保障安全

网络安全审查重点评估
学校网站 网络安全
有一台服务器做什么好
抄车牌号上传数据库如何赚钱
哈尔滨小熊软件开发公司雷
服务器能插pcie网卡
账本服务器
怎么看网页服务器在哪
设计网络安全审计
软件开发学不会怎么办
神武新区服务器开多少升120
数据库使用场景
初中毕业学软件开发好就业吗
连接登录数据库服务器的命令
河南通用软件开发均价
服务器jar
建立sql数据库的步骤
兴创服务器是什么意思
未来有前景的郑州软件开发
电影电视数据库分享平台
网络通信与网络安全总结
网络技术为人类带来哪些好处
清空数据库事务日志
服务器停止的游戏怎么玩
外网服务器下载游戏
移动应用开发与软件开发
网络安全意识的总结
数据库远程用户
我的世界服务器领地地图怎么建
数据库坏块英语作文
        
        


        

          

            
扫描关注千家信息网微信公众号，第一时间获取内容更新动态
            
转载请说明来源于"千家信息网"
            
本文地址：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