Spring集成MyBatis持久层框架

一.MyBatis介绍

MyBatis 是一款优秀的持久层框架，它支持定制化SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的JDBC代码和手动设置参数以及获取结果集，可以使用简单的XML或注解将Java的POJO对象映射成数据库中的记录。

创建MyBatis SQL映射XML文件：MyBatis Generator使用示例

MyBatis配置，创建resources/mybatis/mybatis.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org/DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>
    <settings>
        <setting name="lazyLoadingEnabled" value="false"/>
        <!-- 设置mybatis内置日志工厂 -->
        <setting name="logImpl" value="LOG4J"/>
        <!-- 支持Null值(value)输出Key -->
        <setting name="callSettersOnNulls" value="true"/>
    </settings>
</configuration>

Maven导入MyBatis相关依赖，编辑pom.xml

<!-- 导入database依赖,使用druid作连接池 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.3</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>1.3.1</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.44</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.4.1</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>4.3.10.RELEASE</version>
        </dependency>

二.方法一(通过MapperScannerConfigurer实现，直接对Mapper接口进行代理)

数据库相关bean对象配置，创建resources/spring/applicationContext_database.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!-- 引入配置文件 -->
    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:/mybatis/db.properties"/>
    </bean>

    <!-- dataSource配置 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          init-method="init" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>

        <property name="filters" value="log4j"/>
        <property name="maxActive" value="5"/>
        <property name="initialSize" value="1"/>
        <property name="maxWait" value="6000"/>
    </bean>

    <!-- mybatis文件配置,mapper.xml文件扫描 -->
    <bean id="sessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="configLocation" value="classpath:/mybatis/mybatis.xml"/>
        <property name="mapperLocations" value="classpath:/mybatis/mapper/*Mapper.xml"/>
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!-- mapper注解扫描器配置,扫描@MapperScan注解,自动生成代码对象 -->
    <bean id="mapperScanner" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.learn.spring.server.dao"/>
        <property name="sqlSessionFactoryBeanName" value="sessionFactory"/>
    </bean>
</beans>

UserDOMapper添加注解@MapperScan，编辑dao/UserDOMapper.java

/**
 * 接口中的方法名称要和对应的MyBatis映射文件中的语句的id值一样
 */
@MapperScan
public interface UserDOMapper {
    int deleteByPrimaryKey(Integer id);

    int insert(UserDO record);

    int insertSelective(UserDO record);

    UserDO selectByPrimaryKey(Integer id);

    int updateByPrimaryKeySelective(UserDO record);

    int updateByPrimaryKey(UserDO record);
}

三.方法二(继承SqlSessionDaoSupport,并实现SqlSession接口)

数据库相关bean对象配置，创建resources/spring/applicationContext_database.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!-- 引入配置文件 -->
    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:/mybatis/db.properties"/>
    </bean>

    <!-- dataSource配置 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          init-method="init" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>

        <property name="filters" value="log4j"/>
        <property name="maxActive" value="5"/>
        <property name="initialSize" value="1"/>
        <property name="maxWait" value="6000"/>
    </bean>

    <!-- mybatis配置,mapper.xml文件扫描 -->
    <bean id="sessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="configLocation" value="classpath:/mybatis/mybatis.xml"/>
        <property name="mapperLocations" value="classpath:/mybatis/mapper/*Mapper.xml"/>
        <property name="dataSource" ref="dataSource"/>
    </bean>
</beans>

继承SqlSessionDaoSupport,并实现SqlSession接口,创建dao/impl/BaseDaoImpl.java

public class BaseDaoImpl extends SqlSessionDaoSupport implements SqlSession {

    @Override
    @Resource
    public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
        super.setSqlSessionFactory(sqlSessionFactory);
    }

    public <T> T selectOne(String s) {
        return getSqlSession().selectOne(s);
    }

    public <T> T selectOne(String s, Object o) {
        return getSqlSession().selectOne(s, o);
    }

    public <E> List<E> selectList(String s) {
        return getSqlSession().selectList(s);
    }

    public <E> List<E> selectList(String s, Object o) {
        return getSqlSession().selectList(s, o);
    }

    public <E> List<E> selectList(String s, Object o, RowBounds rowBounds) {
        return getSqlSession().selectList(s, o, rowBounds);
    }

    public <K, V> Map<K, V> selectMap(String s, String s1) {
        return getSqlSession().selectMap(s, s1);
    }

    public <K, V> Map<K, V> selectMap(String s, Object o, String s1) {
        return getSqlSession().selectMap(s, o, s1);
    }

    public <K, V> Map<K, V> selectMap(String s, Object o, String s1, RowBounds rowBounds) {
        return getSqlSession().selectMap(s, o, s1, rowBounds);
    }

    public <T> Cursor<T> selectCursor(String s) {
        return getSqlSession().selectCursor(s);
    }

    public <T> Cursor<T> selectCursor(String s, Object o) {
        return getSqlSession().selectCursor(s, o);
    }

    public <T> Cursor<T> selectCursor(String s, Object o, RowBounds rowBounds) {
        return getSqlSession().selectCursor(s, o, rowBounds);
    }

    public void select(String s, Object o, ResultHandler resultHandler) {
        getSqlSession().select(s, o, resultHandler);
    }

    public void select(String s, ResultHandler resultHandler) {
        getSqlSession().select(s, resultHandler);
    }

    public void select(String s, Object o, RowBounds rowBounds, ResultHandler resultHandler) {
        getSqlSession().select(s, o, rowBounds, resultHandler);
    }

    public int insert(String s) {
        return getSqlSession().insert(s);
    }

    public int insert(String s, Object o) {
        return getSqlSession().insert(s, o);
    }

    public int update(String s) {
        return getSqlSession().update(s);
    }

    public int update(String s, Object o) {
        return getSqlSession().update(s, o);
    }

    public int delete(String s) {
        return getSqlSession().delete(s);
    }

    public int delete(String s, Object o) {
        return getSqlSession().delete(s, o);
    }

    public void commit() {
        getSqlSession().commit();
    }

    public void commit(boolean b) {
        getSqlSession().commit(b);
    }

    public void rollback() {
        getSqlSession().rollback();
    }

    public void rollback(boolean b) {
        getSqlSession().rollback(b);
    }

    public List<BatchResult> flushStatements() {
        return getSqlSession().flushStatements();
    }

    /**
     * 实现空方法,SqlSession由Spring管理并关闭,如果手工关闭,则会拋异常
     * java.lang.UnsupportedOperationException: Manual close is not allowed over a Spring managed SqlSession
     */
    public void close() {

    }

    public void clearCache() {
        getSqlSession().clearCache();
    }

    public Configuration getConfiguration() {
        return getSqlSession().getConfiguration();
    }

    public <T> T getMapper(Class<T> aClass) {
        return getSqlSession().getMapper(aClass);
    }

    public Connection getConnection() {
        return getSqlSession().getConnection();
    }
}

继承BaseDaoImol,并实现UserDOMapper接口,创建dao/impl/UserDaoImpl.java

@Repository
public class UserDaoImpl extends BaseDaoImpl implements UserDOMapper {
    public int deleteByPrimaryKey(Integer id) {
        return delete("com.learn.spring.server.dao.UserDOMapper.deleteByPrimaryKey", id);
    }

    public int insert(UserDO record) {
        return insert("com.learn.spring.server.dao.UserDOMapper.insert", record);
    }

    public int insertSelective(UserDO record) {
        return insert("com.learn.spring.server.dao.UserDOMapper.insertSelective", record);
    }

    public UserDO selectByPrimaryKey(Integer id) {
        return selectOne("com.learn.spring.server.dao.UserDOMapper.selectByPrimaryKey", id);
    }

    public int updateByPrimaryKeySelective(UserDO record) {
        return update("com.learn.spring.server.dao.UserDOMapper.updateByPrimaryKeySelective", record);
    }

    public int updateByPrimaryKey(UserDO record) {
        return update("com.learn.spring.server.dao.UserDOMapper.updateByPrimaryKey", record);
    }
}

四.调用示例

Spring框架直接注入UserDOMapper,创建service/UserService.java

@Service
public class UserServiceImpl implements UserService {

    @Resource
    private UserDOMapper userDao;

    public UserDO get(Integer id) {
        return userDao.selectByPrimaryKey(id);
    }
}

转载于:https://www.cnblogs.com/faramita2016/p/7512462.html

Spring集成MyBatis持久层框架

一.MyBatis介绍

二.方法一(通过MapperScannerConfigurer实现，直接对Mapper接口进行代理)

三.方法二(继承SqlSessionDaoSupport,并实现SqlSession接口)

四.调用示例

继续阅读

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的简单使用

neo4j之cypher使用文档

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

NOSQL安全攻击

mybatis_入门程序Mybatis入门

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

登录plsql 报错 the account is locked --用户被锁

Effective Java 8:通用程序设计

SequoiaDB巨杉数据库C++驱动概述

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method