【Spring】(六)MyBatis与Spring的整合步骤(含详细整合案例)

简介: 【Spring】(六)MyBatis与Spring的整合步骤(含详细整合案例)

MyBatis与Spring的整合


第一步:导入jar包


20191106213117180.png


包含spring、mybatis、mybatis-spring的jar包,如有需要的朋友可以直接留言哦~


第二步:创建两个Source Folder文件夹( resources和test)


20191106213507636.png


第三步:创建实体类


20191106213644502.png


第四步:创建dao层接口、实现类、mapper映射文件


1、BillMapper接口

package cn.smbms.dao.bill;
import java.util.List;
import cn.smbms.pojo.Bill;
import org.apache.ibatis.annotations.Param;
public interface BillMapper {
  /**
  * 增加订单
  * @param bill
  * @return
  * @throws Exception
  */
  public int add(Bill bill)throws Exception;
  /**
  * 通过查询条件获取供应商列表-模糊查询-getBillList
  * @return
  * @throws Exception
  */
  public List<Bill> getBillList(@Param(value = "providerId") String providerId,
          @Param(value = "productName") String productName,
          @Param(value = "isPayment") String isPayment)throws Exception;
  /**
  * 通过delId删除Bill
  * @param delId
  * @return
  * @throws Exception
  */
  public int deleteBillById(String delId)throws Exception;
  /**
  * 通过billId获取Bill
  * @param id
  * @return
  * @throws Exception
  */
  public Bill getBillById(String id)throws Exception;
  /**
  * 修改订单信息
  * @param bill
  * @return
  * @throws Exception
  */
  public int modify(Bill bill)throws Exception;
  /**
  * 根据供应商ID查询订单数量
  * @param providerId
  * @return
  * @throws Exception
  */
  public int getBillCountByProviderId(String providerId)throws Exception;
}


2、BillMapperImpl实现类

package cn.smbms.dao.bill;
import cn.smbms.pojo.Bill;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.List;
public class BillMapperImpl implements BillMapper {
    ApplicationContext context=new ClassPathXmlApplicationContext("ApplicationContext.xml");
    BillMapper mapper= (BillMapper) context.getBean("billMapper");
    @Override
    public int add(Bill bill) throws Exception {
        return mapper.add(bill);
    }
    @Override
    public List<Bill> getBillList(String providerId, String productName, String isPayment) throws Exception {
        return mapper.getBillList(providerId, productName, isPayment);
    }
    @Override
    public int deleteBillById(String delId) throws Exception {
        return mapper.deleteBillById(delId);
    }
    @Override
    public Bill getBillById(String id) throws Exception {
        return mapper.getBillById(id);
    }
    @Override
    public int modify(Bill bill) throws Exception {
        return mapper.modify(bill);
    }
    @Override
    public int getBillCountByProviderId(String providerId) throws Exception {
        return mapper.getBillCountByProviderId(providerId);
    }
}


3、BillMapper.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.smbms.dao.bill.BillMapper">
    <insert id="add" parameterType="cn.smbms.pojo.Bill">
        insert into smbms_bill (billCode, productName, productDesc,
         productUnit, productCount, totalPrice, isPayment, createdBy,
          creationDate, modifyBy, modifyDate, providerId)
          values (#{billCode},#{productName},#{productDesc},#{productUnit},#{productCount},
          #{totalPrice},#{isPayment},#{createdBy},#{creationDate},#{modifyBy},
          #{modifyDate},#{providerId})
    </insert>
    <select id="getBillList" resultType="cn.smbms.pojo.Bill">
        select b.*,p.proName as providerName
        from smbms_bill b, smbms_provider p
        where b.providerId = p.id
        <if test="providerId!=null">
            and providerId=#{providerId}
        </if>
        <if test="providerId!=null">
            and productName like CONCAT('%',#{productName},'%')
        </if>
        <if test="providerId!=null">
            and isPayment=#{isPayment}
        </if>
    </select>
    <delete id="deleteBillById" parameterType="int">
        delete from smbms_bill where id=#{id}
    </delete>
    <select id="getBillById" resultType="cn.smbms.pojo.Bill">
        select b.*,p.proName as providerName
        from smbms_bill b, smbms_provider p
  where b.providerId = p.id and b.id=#{id}
    </select>
    <update id="modify" parameterType="cn.smbms.pojo.Bill">
        update smbms_bill set billCode=#{billCode}, productName=#{productName}, productDesc=#{productDesc},
        productUnit=#{productUnit},productCount=#{productCount},totalPrice=#{totalPrice},
  isPayment=#{isPayment},providerId=#{providerId},modifyBy=#{modifyBy},modifyDate=#{modifyDate}
  where id = #{id}
    </update>
    <select id="getBillCountByProviderId" resultType="int">
        select count(1) as billCount
        from smbms_bill
        where providerId = #{providerId}
    </select>
</mapper>


第五步:创建service层接口、实现类


1、BillService接口

package cn.smbms.service.bill;
import java.util.List;
import cn.smbms.pojo.Bill;
public interface BillService {
  /**
  * 增加订单
  * @param bill
  * @return
  */
  public boolean add(Bill bill);
  /**
  * 通过条件获取订单列表-模糊查询-billList
  * @param bill
  * @return
  */
  public List<Bill> getBillList(Bill bill);
  /**
  * 通过billId删除Bill
  * @param delId
  * @return
  */
  public boolean deleteBillById(String delId);
  /**
  * 通过billId获取Bill
  * @param id
  * @return
  */
  public Bill getBillById(String id);
  /**
  * 修改订单信息
  * @param bill
  * @return
  */
  public boolean modify(Bill bill);
}


2、BillServiceImpl实现类

package cn.smbms.service.bill;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import cn.smbms.dao.BaseDao;
import cn.smbms.dao.bill.BillMapper;
import cn.smbms.dao.bill.BillMapperImpl1;
import cn.smbms.pojo.Bill;
public class BillServiceImpl implements BillService {
  private BillMapper billMapper;
  public BillServiceImpl(){
  billMapper = new BillMapperImpl1();
  }
  @Override
  public boolean add(Bill bill) {
  // TODO Auto-generated method stub
  boolean flag = false;
  Connection connection = null;
  try {
    connection = BaseDao.getConnection();
    connection.setAutoCommit(false);//开启JDBC事务管理
    if(billMapper.add(bill) > 0)
    flag = true;
    connection.commit();
  } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    try {
    System.out.println("rollback==================");
    connection.rollback();
    } catch (SQLException e1) {
    // TODO Auto-generated catch block
    e1.printStackTrace();
    }
  }finally{
    //在service层进行connection连接的关闭
    BaseDao.closeResource(connection, null, null);
  }
  return flag;
  }
  @Override
  public List<Bill> getBillList(Bill bill) {
  // TODO Auto-generated method stub
  Connection connection = null;
  List<Bill> billList = null;
  System.out.println("query productName ---- > " + bill.getProductName());
  System.out.println("query providerId ---- > " + bill.getProviderId());
  System.out.println("query isPayment ---- > " + bill.getIsPayment());
  try {
    connection = BaseDao.getConnection();
    billList = billMapper.getBillList("","","");
  } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }finally{
    BaseDao.closeResource(connection, null, null);
  }
  return billList;
  }
  @Override
  public boolean deleteBillById(String delId) {
  // TODO Auto-generated method stub
  Connection connection = null;
  boolean flag = false;
  try {
    connection = BaseDao.getConnection();
    if(billMapper.deleteBillById(delId) > 0)
    flag = true;
  } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }finally{
    BaseDao.closeResource(connection, null, null);
  }
  return flag;
  }
  @Override
  public Bill getBillById(String id) {
  // TODO Auto-generated method stub
  Bill bill = null;
  Connection connection = null;
  try{
    connection = BaseDao.getConnection();
    bill = billMapper.getBillById(id);
  }catch (Exception e) {
    // TODO: handle exception
    e.printStackTrace();
    bill = null;
  }finally{
    BaseDao.closeResource(connection, null, null);
  }
  return bill;
  }
  @Override
  public boolean modify(Bill bill) {
  // TODO Auto-generated method stub
  Connection connection = null;
  boolean flag = false;
  try {
    connection = BaseDao.getConnection();
    if(billMapper.modify(bill) > 0)
    flag = true;
  } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }finally{
    BaseDao.closeResource(connection, null, null);
  }
  return flag;
  }
}


第六步:在resource文件夹中编写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>
 <!--这里可以加入类型别名,其他配置已经转到Spring中-->
</configuration>


第七步:在resource文件夹中编写applicationContext.xml


因为测试了三种MyBatis与Spring整合的方法,所以配置文件显得很冗长,请注意注掉的部分代码!


最终采用的是org.mybatis.spring.mapper.MapperScannerConfigurer,这也是在实际工作情况中使用较多的一种整合方式。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd">
    <!--引入properties文件-->
    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location">
            <value>classpath:database.properties</value>
        </property>
    </bean>
    <!--配置DataSource-->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
        <property name="driverClassName" value="${driver}"/>
        <property name="url" value="${url}"/>
        <property name="username" value="${user}"/>
        <property name="password" value="${pwd}"/>
    </bean>
    <!--配置SqlSessionFactoryBean-->
    <bean id="factory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <!--引用数据源组件-->
        <property name="dataSource" ref="dataSource"/>
        <!--引用MyBatis配置文件中的配置,必须有,里面的内容可以为空-->
        <!-- 有关mybatis的特性配置可以写在该文件中,比如插件,setting属性等 -->
        <property name="configLocation" value="classpath:mybatis-config.xml"/>
        <!-- 指定mapper文件位置,当不指定时mapper映射文件默认与接口在一个包下 -->
        <property name="mapperLocations" value="classpath*:cn/smbms/dao/**/*.xml"/>
    </bean>
    <!--
         Mybatis-Spring为我们提供了一个实现了SqlSession接口的SqlSessionTemplate类,它是线程安全的,
         可以被多个Dao同时使用。
         同时它还跟Spring的事务进行了关联,确保当前被使用的SqlSession是一个已经和Spring的事务进行绑定了的。
         而且它还可以自己管理Session的提交和关闭。当使用了Spring的事务管理机制后,
         SqlSession还可以跟着Spring的事务一起提交和回滚。
      -->
    <!--配置SqlSessionTemplate-->
    <bean id="session" class="org.mybatis.spring.SqlSessionTemplate">
        <constructor-arg name="sqlSessionFactory" ref="factory"></constructor-arg>
    </bean>
    <!--配置实现类-->
    <!--<bean id="userMapper" class="cn.smbms.dao.user.UserMapperImpl">-->
        <!--<property name="session" ref="session"/>-->
        <!--<property name="session" ref="session"></property>-->
    <!--</bean>-->
    <!--直接配置接口-->
    <!--<bean id="userMapper" class="org.mybatis.spring.mapper.MapperFactoryBean">-->
        <!--<property name="mapperInterface" value="cn.smbms.dao.user.UserMapper"/>-->
        <!--<property name="sqlSessionFactory" ref="factory"/>-->
    <!--</bean>-->
    <!--直接配置接口-->
    <!--<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">-->
        <!--<property name="basePackage" value="cn.smbms.dao"/>-->
        <!--<property name="sqlSessionFactoryBeanName" value="factory"/>-->
    <!--</bean>-->
    <!--配置扫描包--> <!-- 代理dao层接口实现类 -->
    <bean id="mapConf" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="cn.smbms.dao"/>
    </bean>
    <!--配置扫描注解定义的业务Bean-->
    <context:component-scan base-package="cn.smbms.service"/>
    <!--<context:annotation-config></context:annotation-config>-->
    <!--配置事务管理bean-->
    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--配置对应的方法和事务传播机制-->
    <!--<tx:advice id="txAdvice" transaction-manager="txManager">-->
        <!--<tx:attributes>-->
            <!--<tx:method name="updateTian*" timeout="-1"/>-->
            <!--<tx:method name="*" propagation="REQUIRED"/>-->
        <!--</tx:attributes>-->
    <!--</tx:advice>-->
    <!--配置定义切面-->
    <!--<aop:config>-->
        <!--&lt;!&ndash;定义切入点&ndash;&gt;-->
        <!--<aop:pointcut id="serviceMethod" expression="execution(public int updateTian())"/>-->
        <!--&lt;!&ndash;将事务增强与切入点组合&ndash;&gt;-->
        <!--<aop:advisor advice-ref="txAdvice" pointcut-ref="serviceMethod"/>-->
    <!--</aop:config>-->
    <!--注解-->
    <tx:annotation-driven transaction-manager="txManager"/>
</beans>


第八步:在test文件夹中编写测试方法


一个简单的快捷键:ctrl+shift+T ,我们创建BillMapperImpl类的测试方法,对功能模块进行测试。

package cn.smbms.dao.bill;
import cn.smbms.pojo.Bill;
import org.apache.log4j.Logger;
import org.junit.Test;
import java.math.BigDecimal;
import java.util.Date;
import static org.junit.Assert.*;
public class BillMapperImplTest {
    Logger logger=Logger.getLogger(BillMapperImplTest.class);
    BillMapper mapper=new BillMapperImpl();
    @Test
    public void add() {
        Bill bill=new Bill();
        bill.setBillCode("BILL2016_020");
        bill.setProductName("鞭炮");
        bill.setProductDesc("烟花炮竹");
        bill.setProductUnit("箱");
        bill.setProductCount(BigDecimal.valueOf(500));
        bill.setTotalPrice(BigDecimal.valueOf(1000));
        bill.setIsPayment(1);
        bill.setCreatedBy(1);
        bill.setCreationDate(new Date());
        bill.setProviderId(13);
        try {
            int row=mapper.add(bill);
            if (row>0){
                logger.info("成功插入一条商品信息");
            }else {
                logger.info("插入不成功");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @Test
    public void getBillList() {
        try {
            logger.info(mapper.getBillList("6","油","2"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @Test
    public void deleteBillById() {
        try {
            int row=mapper.deleteBillById("26");
            if (row>0){
                logger.info("删除成功");
            }else {
                logger.info("删除失败");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @Test
    public void getBillById() {
        try {
            logger.info(mapper.getBillById("1"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @Test
    public void modify() {
        Bill bill=new Bill();
        bill.setId(14);
        bill.setBillCode("151654");
        bill.setProductName("西北香米");
        try {
            int row=mapper.modify(bill);
            if (row>0){
                logger.info("成功修改一条商品信息");
            }else {
                logger.info("修改不成功");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    @Test
    public void getBillCountByProviderId() {
        try {
            logger.info("查询供应商数"+mapper.getBillCountByProviderId("1"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}


以上,便是采用MapperScannerConfigurer方式进行的MyBatis与Spring的整合!


目录
相关文章
|
1月前
|
JSON 安全 算法
|
30天前
|
Java API Spring
在 Spring 配置文件中配置 Filter 的步骤
【10月更文挑战第21天】在 Spring 配置文件中配置 Filter 是实现请求过滤的重要手段。通过合理的配置,可以灵活地对请求进行处理,满足各种应用需求。还可以根据具体的项目要求和实际情况,进一步深入研究和优化 Filter 的配置,以提高应用的性能和安全性。
|
11天前
|
SQL Java 数据库连接
【MyBatisPlus·最新教程】包含多个改造案例,常用注解、条件构造器、代码生成、静态工具、类型处理器、分页插件、自动填充字段
MyBatis-Plus是一个MyBatis的增强工具,在 MyBatis 的基础上只做增强不做改变,为简化开发、提高效率而生。本文讲解了最新版MP的使用教程,包含多个改造案例,常用注解、条件构造器、代码生成、静态工具、类型处理器、分页插件、自动填充字段等核心功能。
【MyBatisPlus·最新教程】包含多个改造案例,常用注解、条件构造器、代码生成、静态工具、类型处理器、分页插件、自动填充字段
|
4天前
|
Java 数据库连接 数据库
spring和Mybatis的逆向工程
通过本文的介绍,我们了解了如何使用Spring和MyBatis进行逆向工程,包括环境配置、MyBatis Generator配置、Spring和MyBatis整合以及业务逻辑的编写。逆向工程极大地提高了开发效率,减少了重复劳动,保证了代码的一致性和可维护性。希望这篇文章能帮助你在项目中高效地使用Spring和MyBatis。
7 1
|
1月前
|
前端开发 Java Apache
Springboot整合shiro,带你学会shiro,入门级别教程,由浅入深,完整代码案例,各位项目想加这个模块的人也可以看这个,又或者不会mybatis-plus的也可以看这个
本文详细讲解了如何整合Apache Shiro与Spring Boot项目,包括数据库准备、项目配置、实体类、Mapper、Service、Controller的创建和配置,以及Shiro的配置和使用。
353 1
Springboot整合shiro,带你学会shiro,入门级别教程,由浅入深,完整代码案例,各位项目想加这个模块的人也可以看这个,又或者不会mybatis-plus的也可以看这个
|
1月前
|
缓存 Java 数据库连接
使用MyBatis缓存的简单案例
MyBatis 是一种流行的持久层框架,支持自定义 SQL 执行、映射及复杂查询。本文介绍了如何在 Spring Boot 项目中集成 MyBatis 并实现一级和二级缓存,以提高查询性能,减少数据库访问。通过具体的电商系统案例,详细讲解了项目搭建、缓存配置、实体类创建、Mapper 编写、Service 层实现及缓存测试等步骤。
|
1月前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
98 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库
|
1月前
|
Java 数据库连接 API
springBoot:后端解决跨域&Mybatis-Plus&SwaggerUI&代码生成器 (四)
本文介绍了后端解决跨域问题的方法及Mybatis-Plus的配置与使用。首先通过创建`CorsConfig`类并设置相关参数来实现跨域请求处理。接着,详细描述了如何引入Mybatis-Plus插件,包括配置`MybatisPlusConfig`类、定义Mapper接口以及Service层。此外,还展示了如何配置分页查询功能,并引入SwaggerUI进行API文档生成。最后,提供了代码生成器的配置示例,帮助快速生成项目所需的基础代码。
|
1月前
|
Java 数据库连接 Maven
Spring整合Mybatis
Spring整合Mybatis
|
1月前
|
Java 数据库连接 Maven
mybatis使用一:springboot整合mybatis、mybatis generator,使用逆向工程生成java代码。
这篇文章介绍了如何在Spring Boot项目中整合MyBatis和MyBatis Generator,使用逆向工程来自动生成Java代码,包括实体类、Mapper文件和Example文件,以提高开发效率。
118 2
mybatis使用一:springboot整合mybatis、mybatis generator,使用逆向工程生成java代码。
下一篇
无影云桌面