SpringBoot整合Mybatis使用注解或XML的方式开发

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

2018-6-4

补充mybatis-spring-boot注解的使用

1.导包

只需要再导入mysql+mybatis两个包

<dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.2</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency>

2.数据源

application.yml

spring: datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://118.89.177.110:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false username: root password: 336699ystmybatis: configuration: map-underscore-to-camel-case: true #开启驼峰命名（数据库d_id匹配实体类dId）logging: level: cn.zyzpp.xxxx.mapper: debug #打印SQL日志

3.实体类

public class User { private int id; private String name; private Integer age; public User( String name, Integer age) { this.name = name; this.age = age; } public User() { } @Override public String toString() { return "User{" + "id=" + id + ", name='" + name + '\'' + ", age=" + age + '}'; } ...getter ...setter}

4.@Mapper

在启动类中添加对mapper包扫描@MapperScan

//@MapperScan("") 相比指定扫描包的路径，我更喜欢在mapper接口上加mapper注解@SpringBootApplicationpublic class MybatisZhujieApplication { public static void main(String[] args) { SpringApplication.run(MybatisZhujieApplication.class, args); }}

或者直接在Mapper类上面添加注解@Mapper

@Mapper//@Repository此注解可不加，加是防止在使用@Autowired注解时IDEA报错public interface UserMapper { @Delete("drop table if exists user") void dropTable(); @Insert("CREATE TABLE IF NOT EXISTS user(id INT UNSIGNED AUTO_INCREMENT,name VARCHAR(100) NOT NULL," + " age INT NOT NULL,PRIMARY KEY (id)" + ")ENGINE=InnoDB DEFAULT CHARSET=utf8;") void createTable(); @Insert("insert into user(name,age) values(#{name},#{age})") void insert(User user); @Select("select id,name,age from user") List<User> findAll();}

5.测试使用

@RunWith(SpringRunner.class)@SpringBootTestpublic class MybatisZhujieApplicationTests { @Autowired UserMapper userMapper; // 每次执行Test之前先删除表，创建表 @Before public void before() throws Exception { userMapper.dropTable(); userMapper.createTable(); } @Test public void contextLoads() { userMapper.insert(new User("name",18)); userMapper.insert(new User("name2",19)); userMapper.insert(new User("name3",20)); System.out.println(userMapper.findAll()); }}

执行结果：

[User{id=1, name='name', age=18}, User{id=2, name='name2', age=19}, User{id=3, name='name3', age=20}]

2018-6-3

二：XML配置方式

1.mybatis-config配置

在resources下新建mybatis-config.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="useGeneratedKeys" value="true"/>  <setting name="useColumnLabel" value="true"/>  <setting name="mapUnderscoreToCamelCase" value="true"/> </settings></configuration>

2.Entity实体类

示例：

package cn.zyzpp.entity;import java.util.Date;/** * Created by 巅峰小学生 2018年3月11日下午1:21:17*/public class Area { //主键ID private Integer areaId; //名称 private String areaName; //权重，越大越靠前显示 private Integer priority; //创建时间 private Date createTime; //更新时间 private Date lastEditTime; ...}

3.Dao层接口

package cn.zyzpp.dao;import java.util.List;import cn.zyzpp.entity.Area;/** * Created by 巅峰小学生 2018年3月11日下午7:12:04*/public interface AreaDao { /** * 列出区域列表 * * @return areaList */ List<Area> queryArea(); /** * 根据Id列出具体区域 * * @return area */ Area queryAreaById(int areaId); /** * 插入区域信息 * * @param area * @return */ int insertArea(Area area); /** * 更新区域信息 * * @param area * @return */ int updateArea(Area area); /** * 删除区域信息 * * @param areaId * @return */ int deleteArea(int areaId);}

4.Mapper映射

在/resources/mapper/下新建AreaDao.xml

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">  <mapper namespace="cn.zyzpp.dao.AreaDao">  <select id="queryArea" resultType="cn.zyzpp.entity.Area"> SELECT area_id, area_name, priority, create_time, last_edit_time FROM tb_area ORDER BY priority DESC </select> <select id="queryAreaById" resultType="cn.zyzpp.entity.Area"> SELECT area_id, area_name, priority, create_time, last_edit_time FROM tb_area WHERE area_id=#{areaId} </select> <insert id="insertArea" useGeneratedKeys="true" keyProperty="areaId" keyColumn="area_id" parameterType="cn.zyzpp.entity.Area"> INSERT INTO tb_area(area_name,priority, create_time,last_edit_time) VALUES (#{areaName},#{priority}, #{createTime},#{lastEditTime}) </insert> <update id="updateArea" parameterType="cn.zyzpp.entity.Area"> update tb_area <set> <if test="areaName != null">area_name=#{areaName},</if> <if test="priority != null">priority=#{priority},</if> <if test="lastEditTime != null">last_edit_time=#{lastEditTime}</if> </set> where area_id=#{areaId} </update> <delete id="deleteArea"> DELETE FROM tb_area WHERE area_id = #{areaId} </delete></mapper>

5.application.properties自定义配置

#mysqljdbc.driverClass=com.mysql.jdbc.Driverjdbc.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=falsejdbc.username=rootjdbc.password=123456#Mybatismybatis_config_file=mybatis-config.xmlmapper_path=/mapper/**.xmltype_alias_package=cn.zyzpp.entity

6.配置SqlSessionFactoryBean

DataSourceBean

import java.beans.PropertyVetoException;import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import com.mchange.v2.c3p0.ComboPooledDataSource;@Configuration//配置MyBatis mapper的扫描路径@MapperScan("cn.zyzpp.dao")public class DataSourceConfiguration { @Value("${jdbc.driverClass}") private String jdbcDriverClass; @Value("${jdbc.url}") private String jdbcUrl; @Value("${jdbc.username}") private String jdbcUser; @Value("${jdbc.password}") private String jdbcPassword; @Bean("dataSource") public ComboPooledDataSource createDataSource() throws PropertyVetoException{ ComboPooledDataSource dataSource = new ComboPooledDataSource(); dataSource.setDriverClass(jdbcDriverClass); dataSource.setJdbcUrl(jdbcUrl); dataSource.setUser(jdbcUser); dataSource.setPassword(jdbcPassword); //关闭连接后不自动commit dataSource.setAutoCommitOnClose(false); return dataSource; }}

SqlSessionFactoryBean

import javax.sql.DataSource;import org.mybatis.spring.SqlSessionFactoryBean;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.core.io.ClassPathResource;import org.springframework.core.io.support.PathMatchingResourcePatternResolver;import org.springframework.core.io.support.ResourcePatternResolver;/** * Created by 巅峰小学生 * 2018年3月11日下午2:20:19*/@Configurationpublic class SessionFactoryConfiguration { @Value("${mybatis_config_file}") private String mybatisConfigFile; @Value("${mapper_path}") private String mapperPath; // 实体类所在的package @Value("${type_alias_package}") private String typeAliasPackage; @Autowired @Qualifier("dataSource") private DataSource dataSource; @Bean("sqlSessionFactory") public SqlSessionFactoryBean creatSqlSessionFactoryBean() throws IOException{ SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); // 设置mybatis configuration 扫描路径 sqlSessionFactoryBean.setConfigLocation(new ClassPathResource(mybatisConfigFile)); // 添加mapper 扫描路径 PathMatchingResourcePatternResolver pathMatchingResourcePatternResolver = new PathMatchingResourcePatternResolver(); String packageSearchPath = ResourcePatternResolver.CLASSPATH_ALL_URL_PREFIX + mapperPath; sqlSessionFactoryBean.setMapperLocations(pathMatchingResourcePatternResolver.getResources(packageSearchPath)); // 设置dataSource sqlSessionFactoryBean.setDataSource(dataSource); // 设置typeAlias 包扫描路径 sqlSessionFactoryBean.setTypeAliasesPackage(typeAliasPackage); return sqlSessionFactoryBean; }}

7.开始使用

@Servicepublic class AreaServiceImpl implements AreaService { @Autowired private AreaDao areaDao; @Override public List<Area> getAreaList() { // 返回所有的区域信息 return areaDao.queryArea(); } @Override public Area getAreaById(int areaId) { return areaDao.queryAreaById(areaId); } ....