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

周村企业oa软件开发公司
m26软件开发方法
校园建立健全网络安全责任制
医疗管理软件开发
我的世界服务器叫什么
计算机网络技术主要职位
阿里云服务器上的字母怎么写
关于护苗网络安全小报
elog服务器
软件测试计划数据库测试
生死狙击忘记哪个服务器了怎么办
关于网络安全法的正确说法有
阜阳财务软件开发
逻辑表 数据库怎么写
乡网络安全周宣传报告
税控管理服务器
嘉兴基础网络技术口碑推荐
dhcp服务器设置为自动吗
我的世界服务器必备指令击杀榜
阿里云服务器能玩什么游戏
楚天科技工业互联网
中国铁塔软件开发投资
宁夏银川软件开发公司案例
少年西游记忘记服务器
关于护苗网络安全小报
电脑怎么使用手机上的数据库
怎么做网络安全宣传
软件开发合同要不要签订服务期限
数据库性能维护
中学生网络安全教育专题
        
        


        

          

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