因?yàn)閟pring 整合mybatis的過(guò)程中， 有好幾種整合方式，尤其是數(shù)據(jù)源那塊，經(jīng)?？吹讲灰粯拥呐渲梅绞剑偢杏X(jué)有點(diǎn)亂，所以今天有空總結(jié)下。
創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),沂水企業(yè)網(wǎng)站建設(shè),沂水品牌網(wǎng)站建設(shè),網(wǎng)站定制,沂水網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷,網(wǎng)絡(luò)優(yōu)化,沂水網(wǎng)站推廣 為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。
一、采用org.mybatis.spring.mapper.MapperScannerConfigurer
其實(shí)逆向工程也是這種方式
1、數(shù)據(jù)源配配置文件
2、DAO文件
package com.jdd.mapper;
import com.jdd.pojo.Employee;
import java.util.List;
public interface EmployeeMapper {
public Employee getEmployeeById(int id);
public List findAllEmployees();
} 3、Mapper.xml 文件
<?xml version="." encoding="UTF-" ?>
這樣在service類里就可以直接注入dao接口了
package com.jdd.service.impl;
import com.jdd.mapper.EmployeeMapper;
import com.jdd.pojo.Employee;
import com.jdd.service.EmployeeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service("employeeService")
public class EmployeeServiceImpl implements EmployeeService{
@Autowired
private EmployeeMapper employeeMapper;
@Override
public Employee getEmployeeById(int id) {
return employeeMapper.getEmployeeById(id);
}
@Override
public List findAllEmployees() {
return employeeMapper.findAllEmployees();
}
}
二、 采用抽象類org.mybatis.spring.support.SqlSessionDaoSupport， 給它注入 sqlSessionFactory的方式
1、數(shù)據(jù)源配置文件
<?xml version="." encoding="UTF-"?>
2、baseDao類
package com.jdd.dao;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.support.SqlSessionDaoSupport;
import javax.annotation.Resource;
public abstract class BaseDao extends SqlSessionDaoSupport {
@Resource
public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
super.setSqlSessionFactory(sqlSessionFactory);
}
}
3、接口 EmployeeDao.java 類
package com.jdd.dao;
import com.jdd.pojo.Employee;
import java.util.List;
public interface EmployeeDao {
Employee getEmployeeById(int id);
List findAllEmployees();
} 4、dao實(shí)現(xiàn)類 EmployeeDaoImpl
package com.jdd.dao.impl;
import com.jdd.dao.BaseDao;
import com.jdd.dao.EmployeeDao;
import com.jdd.pojo.Employee;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository("employeeDao")
public class EmployeeDaoImpl extends BaseDao implements EmployeeDao {
@Override
public Employee getEmployeeById(int id) {
return this.getSqlSession().selectOne("com.jdd.dao.EmployeeDao.getEmployeeById", id);
}
@Override
public List findAllEmployees() {
return this.getSqlSession().selectList("com.jdd.dao.EmployeeDao.findAllEmployees");
}
} 5、這樣就可以在service類里注入 employeeDao了
三、采用 org.mybatis.spring.SqlSessionTemplate 模板類
1、數(shù)據(jù)源文件
<?xml version="." encoding="UTF-"?>
2、 basedao.java 類
package com.jdd.dao;
import org.mybatis.spring.SqlSessionTemplate;
import javax.annotation.Resource;
public abstract class BaseDao {
public SqlSessionTemplate sqlSessionTemplate;
@Resource
public void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {
this.sqlSessionTemplate = sqlSessionTemplate;
}
}
3、接口 EmployeeDao.java 類
package com.jdd.dao;
import com.jdd.pojo.Employee;
import java.util.List;
public interface EmployeeDao {
Employee getEmployeeById(int id);
List findAllEmployees();
} 4、dao實(shí)現(xiàn)類 EmployeeDaoImpl
package com.jdd.dao.impl;
import com.jdd.dao.BaseDao;
import com.jdd.dao.EmployeeDao;
import com.jdd.pojo.Employee;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository("employeeDao")
public class EmployeeDaoImpl extends BaseDao implements EmployeeDao {
@Override
public Employee getEmployeeById(int id) {
return sqlSessionTemplate.selectOne("com.jdd.dao.EmployeeDao.getEmployeeById", id);
}
@Override
public List findAllEmployees() {
return sqlSessionTemplate.selectList("com.jdd.dao.EmployeeDao.findAllEmployees");
}
} 5、同樣現(xiàn)在也可以在service類里直接注入 employeeDao使用了。
注：這里basedao的注入比較靈活，也可以注入 SqlSessionFactory， 然后再setter方法里創(chuàng)建 SqlSessionTemplate，如下：
package com.jdd.dao;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import javax.annotation.Resource;
public abstract class BaseDao {
public SqlSessionTemplate sqlSessionTemplate;
@Resource
public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory);
}
} 其實(shí)不管是采用 繼承SqlSessionDaoSupport類， 注入 sqlSessionFactory的方式， 還是直接注入 SqlSessionTemplate 的方式， 本質(zhì)上是一樣的。
如果你采用 注入 sqlSessionFactory的方式， 它在底層也是通過(guò)sqlSessionFactory 來(lái)創(chuàng)建 SqlSessionTemplate ，然后通過(guò)其api來(lái)操作。
不信給你們看下 SqlSessionDaoSupport 的源碼：
//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//
package org.mybatis.spring.support;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.dao.support.DaoSupport;
import org.springframework.util.Assert;
public abstract class SqlSessionDaoSupport extends DaoSupport {
private SqlSession sqlSession;
private boolean externalSqlSession;
public SqlSessionDaoSupport() {
}
public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
if (!this.externalSqlSession) {
this.sqlSession = new SqlSessionTemplate(sqlSessionFactory);
}
}
public void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {
this.sqlSession = sqlSessionTemplate;
this.externalSqlSession = true;
}
public SqlSession getSqlSession() {
return this.sqlSession;
}
protected void checkDaoConfig() {
Assert.notNull(this.sqlSession, "Property 'sqlSessionFactory' or 'sqlSessionTemplate' are required");
}
} 同樣 SqlSessionTemplate 繼承了 SqlSession 接口， 因此不管操作哪個(gè)效果都一樣
//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//
package org.mybatis.spring;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.exceptions.PersistenceException;
import org.apache.ibatis.executor.BatchResult;
import org.apache.ibatis.reflection.ExceptionUtil;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.ResultHandler;
import org.apache.ibatis.session.RowBounds;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.dao.support.PersistenceExceptionTranslator;
import org.springframework.util.Assert;
public class SqlSessionTemplate implements SqlSession {
private final SqlSessionFactory sqlSessionFactory;
private final ExecutorType executorType;
private final SqlSession sqlSessionProxy;
private final PersistenceExceptionTranslator exceptionTranslator;
public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
this(sqlSessionFactory, sqlSessionFactory.getConfiguration().getDefaultExecutorType());
}
public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType) {
this(sqlSessionFactory, executorType, new MyBatisExceptionTranslator(sqlSessionFactory.getConfiguration().getEnvironment().getDataSource(), true));
}
public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator) {
Assert.notNull(sqlSessionFactory, "Property 'sqlSessionFactory' is required");
Assert.notNull(executorType, "Property 'executorType' is required");
this.sqlSessionFactory = sqlSessionFactory;
this.executorType = executorType;
this.exceptionTranslator = exceptionTranslator;
this.sqlSessionProxy = (SqlSession)Proxy.newProxyInstance(SqlSessionFactory.class.getClassLoader(), new Class[]{SqlSession.class}, new SqlSessionTemplate.SqlSessionInterceptor());
}
public SqlSessionFactory getSqlSessionFactory() {
return this.sqlSessionFactory;
}
public ExecutorType getExecutorType() {
return this.executorType;
}
public PersistenceExceptionTranslator getPersistenceExceptionTranslator() {
return this.exceptionTranslator;
}
public T selectOne(String statement) {
return this.sqlSessionProxy.selectOne(statement);
}
public T selectOne(String statement, Object parameter) {
return this.sqlSessionProxy.selectOne(statement, parameter);
}
public Map selectMap(String statement, String mapKey) {
return this.sqlSessionProxy.selectMap(statement, mapKey);
}
public Map selectMap(String statement, Object parameter, String mapKey) {
return this.sqlSessionProxy.selectMap(statement, parameter, mapKey);
}
public Map selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds) {
return this.sqlSessionProxy.selectMap(statement, parameter, mapKey, rowBounds);
}
public List selectList(String statement) {
return this.sqlSessionProxy.selectList(statement);
}
public List selectList(String statement, Object parameter) {
return this.sqlSessionProxy.selectList(statement, parameter);
}
public List selectList(String statement, Object parameter, RowBounds rowBounds) {
return this.sqlSessionProxy.selectList(statement, parameter, rowBounds);
}
public void select(String statement, ResultHandler handler) {
this.sqlSessionProxy.select(statement, handler);
}
public void select(String statement, Object parameter, ResultHandler handler) {
this.sqlSessionProxy.select(statement, parameter, handler);
}
public void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {
this.sqlSessionProxy.select(statement, parameter, rowBounds, handler);
}
public int insert(String statement) {
return this.sqlSessionProxy.insert(statement);
}
public int insert(String statement, Object parameter) {
return this.sqlSessionProxy.insert(statement, parameter);
}
public int update(String statement) {
return this.sqlSessionProxy.update(statement);
}
public int update(String statement, Object parameter) {
return this.sqlSessionProxy.update(statement, parameter);
}
public int delete(String statement) {
return this.sqlSessionProxy.delete(statement);
}
public int delete(String statement, Object parameter) {
return this.sqlSessionProxy.delete(statement, parameter);
}
public T getMapper(Class type) {
return this.getConfiguration().getMapper(type, this);
}
public void commit() {
throw new UnsupportedOperationException("Manual commit is not allowed over a Spring managed SqlSession");
}
public void commit(boolean force) {
throw new UnsupportedOperationException("Manual commit is not allowed over a Spring managed SqlSession");
}
public void rollback() {
throw new UnsupportedOperationException("Manual rollback is not allowed over a Spring managed SqlSession");
}
public void rollback(boolean force) {
throw new UnsupportedOperationException("Manual rollback is not allowed over a Spring managed SqlSession");
}
public void close() {
throw new UnsupportedOperationException("Manual close is not allowed over a Spring managed SqlSession");
}
public void clearCache() {
this.sqlSessionProxy.clearCache();
}
public Configuration getConfiguration() {
return this.sqlSessionFactory.getConfiguration();
}
public Connection getConnection() {
return this.sqlSessionProxy.getConnection();
}
public List flushStatements() {
return this.sqlSessionProxy.flushStatements();
}
private class SqlSessionInterceptor implements InvocationHandler {
private SqlSessionInterceptor() {
}
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
SqlSession sqlSession = SqlSessionUtils.getSqlSession(SqlSessionTemplate.this.sqlSessionFactory, SqlSessionTemplate.this.executorType, SqlSessionTemplate.this.exceptionTranslator);
Object unwrapped;
try {
Object result = method.invoke(sqlSession, args);
if (!SqlSessionUtils.isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {
sqlSession.commit(true);
}
unwrapped = result;
} catch (Throwable var) {
unwrapped = ExceptionUtil.unwrapThrowable(var);
if (SqlSessionTemplate.this.exceptionTranslator != null && unwrapped instanceof PersistenceException) {
SqlSessionUtils.closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
sqlSession = null;
Throwable translated = SqlSessionTemplate.this.exceptionTranslator.translateExceptionIfPossible((PersistenceException)unwrapped);
if (translated != null) {
unwrapped = translated;
}
}
throw (Throwable)unwrapped;
} finally {
if (sqlSession != null) {
SqlSessionUtils.closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
}
}
return unwrapped;
}
}
} 總結(jié)
以上所述是小編給大家介紹的spring 整合 mybatis 中數(shù)據(jù)源的幾種配置方式，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)歡迎給我留言，小編會(huì)及時(shí)回復(fù)大家的！
當(dāng)前題目：spring整合mybatis中數(shù)據(jù)源的幾種配置方式(總結(jié)篇)
本文路徑：
http://weahome.cn/article/ieddjc.html
重慶分公司
重慶分公司
