mybatis怎么進(jìn)行使用，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

創(chuàng)新互聯(lián)建站專注于企業(yè)營銷型網(wǎng)站、網(wǎng)站重做改版、鐵西網(wǎng)站定制設(shè)計、自適應(yīng)品牌網(wǎng)站建設(shè)、H5頁面制作、成都做商城網(wǎng)站、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計等建站業(yè)務(wù)，價格優(yōu)惠性價比高，為鐵西等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。

1.數(shù)據(jù)源DataSource

2.mapper.xml文件

3.Dao類的實例化

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

自定義一個BaseDao抽象類實現(xiàn)SqlSessionDaoSupport并注入sqlSessionFactory，通過namespace+id找到mapper.xml文件

方法二：spring-mytabis動態(tài)代理生成實例化

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 = ""; // 數(shù)據(jù)庫方言
	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屬性對應(yīng)的實體參數(shù)，即Mapper接口中執(zhí)行分頁方法的參數(shù),該參數(shù)不得為空
				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"; // 記錄統(tǒng)計
					PreparedStatement countStmt = connection
							.prepareStatement(countSql);
					BoundSql countBS = new BoundSql(
							mappedStatement.getConfiguration(), countSql,
							boundSql.getParameterMappings(), parameterObject);
					/*
					 * 此處特殊處理foreach的參數(shù)
					 */
					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) { // 參數(shù)就是Page實體
						page = (Page) parameterObject;
						page.setEntityOrField(true); // 見com.flf.entity.Page.entityOrField
														// // 注釋
						page.setTotalResult(count);
					} else { // 參數(shù)為某個實體，該實體擁有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); // 通過反射，對實體對象設(shè)置分頁對象
						} 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參數(shù)(?)設(shè)值,參考o(jì)rg.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());
				}
			}
		}
	}

	/**
	 * 根據(jù)數(shù)據(jù)庫方言，生成特定的分頁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;
	}

	/**
	 * 設(shè)置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.補(bǔ)充，可以通過mybatis-config.xml進(jìn)行configuration對象的配置
看完上述內(nèi)容是否對您有幫助呢？如果還想對相關(guān)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)的支持。
            
            
                        

            網(wǎng)站名稱：mybatis怎么進(jìn)行使用            

            文章地址：http://weahome.cn/article/psecsh.html
        
    


    
其他資訊
    

        

                Golang中的并發(fā)模型理解Actor模式
            

                在Golang中構(gòu)建自定義Web框架的實踐
            

                Golang語言特性值類型與引用類型的區(qū)別
            

                揭秘當(dāng)今最嚴(yán)重的網(wǎng)絡(luò)攻擊類型以及如何預(yù)防
            

                Golang編程中的常見陷阱避免常見的錯誤
            
    


    

        

            

                

                    
網(wǎng)站制作
                    手機(jī)網(wǎng)站制作成都網(wǎng)站制作手機(jī)網(wǎng)站制作網(wǎng)站制作成都網(wǎng)站制作成都網(wǎng)站制作                
                

                    
企業(yè)服務(wù)
                    網(wǎng)站快速收錄友情鏈接出售成都網(wǎng)站維護(hù)互聯(lián)網(wǎng)信息經(jīng)營許可證賣友情鏈接軟文平臺                
                

                    
網(wǎng)站建設(shè)
                    商城網(wǎng)站建設(shè)公司成都定制網(wǎng)站建設(shè)成都網(wǎng)站建設(shè)定制網(wǎng)站建設(shè)網(wǎng)站建設(shè)方案溫江網(wǎng)站建設(shè)                
                

                    
服務(wù)器托管
                    機(jī)柜租用服務(wù)器托管機(jī)房重慶水土三線托管多線服務(wù)器托管貴陽聯(lián)通機(jī)房綿陽主機(jī)托管                
            
        
        

            
全國免費(fèi)咨詢:
            400-028-6601
            
業(yè)務(wù)咨詢：028-86922220 / 13518219792
            
節(jié)假值班：18980820575 / 13518219792
            
聯(lián)系地址：成都市太升南路288號錦天國際A幢1002號
        
    
    

        

            
Copyright ? 成都創(chuàng)新互聯(lián)科技有限公司重慶分公司  渝ICP備2021005571號
            
        
    
    

        

            友情鏈接:：
            成都網(wǎng)站建設(shè)
            重慶網(wǎng)站建設(shè)
            四川網(wǎng)站建設(shè)
            重慶建設(shè)網(wǎng)站
            移動服務(wù)器托管
            成都服務(wù)器托管
            云服務(wù)器
            廣告設(shè)計制作
            重慶網(wǎng)頁設(shè)計
            重慶做網(wǎng)站
            重慶網(wǎng)站制作
            重慶網(wǎng)站建設(shè)
            重慶網(wǎng)站公司
            渝中網(wǎng)站制作
            重慶網(wǎng)站設(shè)計
        
    


    

        

            
                
                在線咨詢
            
        
        

            
                
                電話咨詢
            
        
        

            
                
                QQ咨詢
            
        
        

            
                
                預(yù)約顧問
            
        
    


    

        

            
                
                
在線咨詢
            
        
    
    

        
微信咨詢
        

    
    

        
電話咨詢
        

            
028-86922220（工作日）
            
18980820575（7×24）
        
    
    

        

            
                
提交需求
            
        
    
    

        

            
                
返回頂部
            
        
    






<strike id="aycmu"></strike>
<tfoot id="aycmu"></tfoot>