使用RESTful风格整合springboot+mybatis

标签：state   实例   turn   etc   mys   perl   ber   search   coding   

说明：
本文是springboot和mybatis的整合，Controller层使用的是RESTful风格，数据连接池使用的是c3p0，通过postman进行测试

项目结构如下：

1、引入pom.xml依赖

        org.springframework.boot
            spring-boot-starter-web
        org.mybatis.spring.boot
            mybatis-spring-boot-starter
            1.3.2org.springframework.boot
            spring-boot-devtools
            trueruntimecom.mchange
            c3p0
            0.9.5.2mysql
            mysql-connector-java
            runtimeorg.springframework.boot
            spring-boot-configuration-processor
            trueorg.springframework.boot
            spring-boot-starter-test
            testorg.springframework.boot
            spring-boot-starter-thymeleaf
        org.springframework
            springloaded
            1.2.0.RELEASEprovided

实体类User

package com.jiangfeixiang.springbootmybatis.entity;

import java.io.Serializable;

/**
 * Created by jiangfeixiang on 2018/8/19
 */
public class User implements Serializable {
    private Integer id;
    private String username;
    private String age;
    private String city;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getAge() {
        return age;
    }

    public void setAge(String age) {
        this.age = age;
    }

    public String getCity() {
        return city;
    }

    public void setCity(String city) {
        this.city = city;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", age='" + age + '\'' +
                ", city='" + city + '\'' +
                '}';
    }
}

2、application.propreties配置文件

#服务器
server.port=8080
server.servlet.context-path=/

#热部署
spring.devtools.remote.restart.enabled=true
spring.devtools.restart.additional-paths=src/main

#mybatis
mybatis.type-aliases-package=com.jiangfeixiang.springbootmybatis.entity 
mybatis.config-locations=mybatis-config.xml    #mybatis-config.xml配置文件
mybatis.mapper-locations=mapper/*.xml   #mapper.xml映射文件

#数据库连接信息
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/springbootdb?useUnicode=true&characterEncoding=utf8&useSSL=false
jdbc.username=root
jdbc.password=1234

3、Mybatis配置文件：mybatis-config.xml

4、UserMapper接口

在com.jiangfeixiang.springbootmybatis.mapper包下创建UserMapper接口

package com.jiangfeixiang.springbootmybatis.mapper;

import com.jiangfeixiang.springbootmybatis.entity.User;

import java.util.List;

/**
 * Created by jiangfeixiang on 2018/8/19
 */
public interface UserMapper {
    /**
     * 查询所有用户
     */
    List getAllUser();

    /**
     * 根据id查询
     */
    User getUserById(Integer id);

    /**
     * 添加用户
     */
    Integer addUser(User user);

    /**
     * 修改用户
     */
    Integer updateUser(User user);
    /**
     * 根据id删除用户
     */
    Integer deleteUserById(Integer id);

}

5、UserMapper.xml映射文件

在resources/mapper包下创建UserMapper.xml文件如下：

        id, username, age, city
    
        select
        
        from user
    
        select
        
        from user
        where id = #{id}
    
        insert into
        user
        (username,age,city)
        values
        (#{username},#{age},#{city})
    
        update
        user
        set
        
            username = #{username},
        
            age = #{age},
        
            city = #{city}
        
        where
        id = #{id}
    
        delete from
        user
        where
        id = #{id}
    

下面配置DataSource和SqlSessionFactory

在config/dao包下创建DataSource

package com.jiangfeixiang.springbootmybatis.config.dao;

import com.mchange.v2.c3p0.ComboPooledDataSource;
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 java.beans.PropertyVetoException;

/**
 * Created by jiangfeixiang on 2018/8/20
 */
@Configuration
//配置mybatis mapper的扫描路径
@MapperScan("com.jiangfeixiang.springbootmybatis.mapper")
public class DataSourceConfig {

    @Value("${jdbc.driver}")
    private String jdbcDriver;
    @Value("${jdbc.url}")
    private String jdbcUrl;
    @Value("${jdbc.username}")
    private String jdbcUsername;
    @Value("${jdbc.password}")
    private String jdbcPassword;

    @Bean(name = "dataSource")
    public ComboPooledDataSource createDataSource() throws PropertyVetoException {
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setDriverClass(jdbcDriver);
        dataSource.setJdbcUrl(jdbcUrl);
        dataSource.setUser(jdbcUsername);
        dataSource.setPassword(jdbcPassword);
        //关闭连接后不自动commit
        dataSource.setAutoCommitOnClose(false);
        return dataSource;
    }
}

在config/dao包下创建SessionFactoryConfig

package com.jiangfeixiang.springbootmybatis.config.dao;

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 javax.sql.DataSource;
import java.io.IOException;

/**
 * Created by jiangfeixiang on 2018/8/20
 */
@Configuration
public class SessionFactoryConfig {

    @Value("${mybatis.config-locations}")
    private String mybatisConfigFilePath;
    @Autowired
    @Qualifier("dataSource")
    private DataSource dataSource;
    @Value("${mybatis.mapper-locations}")
    private String mapperPath;
    @Value("{mybatis.type-aliases-package}")
    private String entityPackage;

    @Bean(name = "sqlSessionFactory")
    public SqlSessionFactoryBean createSqlSessionFactoryBean() throws IOException {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); // 创建SqlSession FactoryBean实例
        sqlSessionFactoryBean.setConfigLocation (new ClassPathResource ( mybatisConfigFilePath )); // 扫描mybatis配置文件;
        // 设置数据库连接信息
        sqlSessionFactoryBean.setDataSource(dataSource);
        // 设置 mappe r映射器对应的XML文件的扫描路径
        PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        String packageSearchPath = PathMatchingResourcePatternResolver.CLASSPATH_ALL_URL_PREFIX+mapperPath;
        sqlSessionFactoryBean.setMapperLocations(resolver.getResources(packageSearchPath));
        // 设置实体类扫描路径
        sqlSessionFactoryBean.setTypeAliasesPackage(entityPackage);
        return sqlSessionFactoryBean;
    }
}

在config/service包下创建TransactionManager事务管理器

package com.jiangfeixiang.springbootmybatis.config.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.annotation.TransactionManagementConfigurer;

import javax.sql.DataSource;

/**
 * Created by jiangfeixiang on 2018/4/9
 */
@Configuration
@EnableTransactionManagement
public class TransactionManagerConfig implements TransactionManagementConfigurer{

    @Autowired
    private DataSource dataSource;
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
        return new DataSourceTransactionManager(dataSource);
    }
}

下面开始编写Service层和Controller层

UserService接口

package com.jiangfeixiang.springbootmybatis.service;

import com.jiangfeixiang.springbootmybatis.entity.User;

import java.util.List;

/**
 * Created by jiangfeixiang on 2018/8/25
 */
public interface UserService {

    /**
     * 查询所有用户
     */
    List getAllUser();

    /**
     * 根据id查询
     */
    User getUserById(Integer id);

    /**
     * 添加用户
     */
    Integer addUser(User user);

    /**
     * 修改用户
     */
    Integer updateUser(User user);
    /**
     * 根据id删除用户
     */
    Integer deleteUserById(Integer id);
}

UserServiceImpl实现类

package com.jiangfeixiang.springbootmybatis.service.impl;

import com.jiangfeixiang.springbootmybatis.entity.User;
import com.jiangfeixiang.springbootmybatis.mapper.UserMapper;
import com.jiangfeixiang.springbootmybatis.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * Created by jiangfeixiang on 2018/8/25
 */
@Service
@Transactional
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    /**
     *查询
     * @return
     */
    @Override
    public List getAllUser() {
        return userMapper.getAllUser();
    }

    /**
     * 根据id查询
     * @param id
     * @return
     */
    @Override
    public User getUserById(Integer id) {
        return userMapper.getUserById(id);
    }

    /**
     * 添加
     * @param user
     * @return
     */
    @Override
    public Integer addUser(User user) {
        return userMapper.addUser(user);
    }

    /**
     * 修改
     * @param user
     * @return
     */
    @Override
    public Integer updateUser(User user) {
        return userMapper.updateUser(user);
    }

    /**
     * 删除
     * @param id
     * @return
     */
    @Override
    public Integer deleteUserById(Integer id) {
        return userMapper.deleteUserById(id);
    }
}

UserController

package com.jiangfeixiang.springbootmybatis.controller;

import com.jiangfeixiang.springbootmybatis.entity.User;
import com.jiangfeixiang.springbootmybatis.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * Created by jiangfeixiang on 2018/8/19
 */
@RestController
//@Controller
//@RequestMapping(value="/users")     // 通过这里配置使下面的映射都在/users下
public class UserController {

    @Autowired
    private UserService userService;

    /**
     * 查询所有用户
     * 处理"/users"的GET请求，用来获取用户列表
     *还可以通过@RequestParam从页面中传递参数来进行查询条件或者翻页信息的传递
     * @return
     */
    @RequestMapping(value = "/user",method = RequestMethod.GET)
    public List getAllUser() {
        List users=userService.getAllUser();
        return users;
    }

    /**
     * 添加用户
     * 处理"/users"的POST请求，用来创建User
     * @param user
     */
    @RequestMapping(value = "/user",method = RequestMethod.POST)
    public String addUser(@ModelAttribute User user) {
        Integer addUser = userService.addUser(user);
        return "success";
    }

    /**
     * 根据id查询
     * 处理"/users/{id}"的GET请求，用来获取url中id值的User信息
     * url中的id可通过@PathVariable绑定到函数的参数中
     * @param id
     * @return
     */
    @RequestMapping(value = "/user/{id}",method = RequestMethod.GET)
    public User getUserById(@PathVariable("id") Integer id) {
        User user=userService.getUserById(id);
        return user;
    }



    /**
     * 更新用户
     * 处理"/users/{id}"的PUT请求，用来更新User信息
     * @param user
     */
    @RequestMapping(value="/user/{id}",method = RequestMethod.PUT)
    public String updateUser(@PathVariable("id") Integer id, @ModelAttribute User user) {
        Integer updateUser = userService.updateUser(user);
        return "success";
    }

    /**
     * 处理"/users/{id}"的DELETE请求，用来删除User
     * @param id
     */
    @RequestMapping(value="/user/{id}",method = RequestMethod.DELETE)
    public String deleteUserById(@PathVariable("id") Integer id) {
        Integer deleteUserById = userService.deleteUserById(id);
        return "success";
    }
}

最后启动类上添加@MapperScan("com.jiangfeixiang.springbootmybatis.mapper")用了扫描UserMapper接口

package com.jiangfeixiang.springbootmybatis;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan("com.jiangfeixiang.springbootmybatis.mapper")
public class SpringbootMybatisApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootMybatisApplication.class, args);
    }
}

使用RESTful风格整合springboot+mybatis

标签：state   实例   turn   etc   mys   perl   ber   search   coding   

原文地址：https://www.cnblogs.com/smfx1314/p/9689824.html