Java|Mybatis的连接池及事务

2021/06/26 Java 共 8870 字,约 26 分钟

1. 连接池:

  • 我们在实际开发中都会使用连接池。
  • 因为它可以减少我们获取连接所消耗的时间。

    2. mybatis中的连接池

    2.1 mybatis连接池提供了3种方式的配置:

    2.1.1 配置的位置:

    主配置文件SqlMapConfig.xml中的dataSource标签,type属性就是表示采用何种连接池方式。

    2.1.2 type属性的取值:

  • POOLED 采用传统的javax.sql.DataSource规范中的连接池,mybatis中有针对规范的实现
  • UNPOOLED 采用传统的获取连接的方式,虽然也实现Javax.sql.DataSource接口,但是并没有使用池的思想。
  • JNDI 采用服务器提供的JNDI技术实现,来获取DataSource对象,不同的服务器所能拿到DataSource是不一样。
    - 注意:如果不是web或者maven的war工程,是不能使用的。  
    
    • 我们课程中使用的是tomcat服务器,采用连接池就是dbcp连接池。

SqlMapConfig配置

Alt Text 驱动是8.0版本的mysql

jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/eesy_mybatis
jdbc.username=root
jdbc.password=1234
<?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>
    <!-- 配置properties-->
    <properties resource="jdbcConfig.properties"/>

    <!--使用typeAliases配置别名,它只能配置domain中类的别名 -->
    <typeAliases>
        <package name="xyz.slienceme.domain"/>
    </typeAliases>

    <!--配置环境-->
    <environments default="mysql">
        <!-- 配置mysql的环境-->
        <environment id="mysql">
            <!-- 配置事务 -->
            <transactionManager type="JDBC"/>

            <!--配置连接池-->
            <dataSource type="POOLED">
                <property name="driver" value="${jdbc.driver}"/>
                <property name="url" value="${jdbc.url}"/>
                <property name="username" value="${jdbc.username}"/>
                <property name="password" value="${jdbc.password}"/>
            </dataSource>
        </environment>
    </environments>
    <!-- 配置映射文件的位置 -->
    <mappers>
        <package name="xyz.slienceme.dao"/>
    </mappers>
</configuration>

4. mybatis中的多表查询

  • 表之间的关系有几种:
  • 一对多
  • 多对一
  • 一对一
  • 多对多
  • 举例:
  • 用户和订单就是一对多
  • 订单和用户就是多对一
    • 一个用户可以下多个订单
    • 多个订单属于同一个用户
  • 人和身份证号就是一对一
    • 一个人只能有一个身份证号
    • 一个身份证号只能属于一个人
  • 老师和学生之间就是多对多
    • 一个学生可以被多个老师教过
    • 一个老师可以交多个学生
  • 特例:
    • 如果拿出每一个订单,他都只能属于一个用户。
    • 所以Mybatis就把多对一看成了一对一。
  • mybatis中的多表查询:
    • 示例:用户和账户
      • 一个用户可以有多个账户
      • 一个账户只能属于一个用户(多个账户也可以属于同一个用户)
    • 步骤:
      • 1、建立两张表:用户表,账户表 - 让用户表和账户表之间具备一对多的关系:需要使用外键在账户表中添加
      • 2、建立两个实体类:用户实体类和账户实体类 - 让用户和账户的实体类能体现出来一对多的关系
      • 3、建立两个配置文件 - 用户的配置文件 - 账户的配置文件
      • 4、实现配置: - 当我们查询用户时,可以同时得到用户下所包含的账户信息
        • 当我们查询账户时,可以同时得到账户的所属用户信息

  • 示例:用户和角色
    • 一个用户可以有多个角色
    • 一个角色可以赋予多个用户
  • 步骤:
    • 1、建立两张表:用户表,角色表 - 让用户表和角色表具有多对多的关系。需要使用中间表,中间表中包含各自的主键,在中间表中是外键。
    • 2、建立两个实体类:用户实体类和角色实体类 - 让用户和角色的实体类能体现出来多对多的关系
      • 各自包含对方一个集合引用
    • 3、建立两个配置文件 - 用户的配置文件 - 角色的配置文件
    • 4、实现配置: - 当我们查询用户时,可以同时得到用户所包含的角色信息
      • 当我们查询角色时,可以同时得到角色的所赋予的用户信息

一对多

  • xml文件的配置 (采用了)
  • 每个人对应多个账户使用 一对多的关系映射,配置user对象中accounts集合的映射 ```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”>

### 多对一
- 每个账户只对应一个人使用 一对一的关系映射,配置封装user的内容 
```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="xyz.slienceme.dao.IAccountDao">

    <!--  定义封装account和user的resultMap  -->
    <resultMap id="accountUserMap" type="xyz.slienceme.domain.Account">
        <id property="id" column="aid"/>
        <result property="uid" column="uid"/>
        <result property="money" column="money"/>
        <!-- 一对一的关系映射,配置封装user的内容 -->
        <association property="xyz.slienceme.domain.User" column="uid" javaType="xyz.slienceme.domain.User">
            <id property="id" column="id"/>
            <result property="name" column="username"/>
            <result property="address" column="address"/>
            <result property="sex" column="sex"/>
            <result property="birthday" column="birthday"/>
        </association>
    </resultMap>
    <!-- 查询所有 -->
    <select id="findAll" resultMap="accountUserMap">
        select u.*,a.id,a.uid,a.money from account a,user u where u.id = a.uid;
    </select>

    <!-- 查询所有账户同时包含用户名和地址信息 -->
    <select id="findAllAccount" resultType="xyz.slienceme.domain.AccountUser">
        select a.*,u.username,u.address from account a,user u where u.id = a.uid;
    </select>

</mapper>
测试方法模板
package xyz.slienceme.test;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import xyz.slienceme.dao.IAccountDao;
import xyz.slienceme.domain.Account;
import xyz.slienceme.domain.AccountUser;
import java.io.InputStream;
import java.util.List;
public class MybatisTest {
    private InputStream in;
    private SqlSession sqlSession;
    private IAccountDao accountDao;

    @Before//用于在测试方法执行之前执行
    public void init()throws Exception{
        //1.读取配置文件,生成字节输入流
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        //2.获取SqlSessionFactory
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
        //3.获取SqlSession对象
        sqlSession = factory.openSession();
        //4.获取dao的代理对象
        accountDao = sqlSession.getMapper(IAccountDao.class);
    }

    @After//用于在测试方法执行之后执行
    public void destroy()throws Exception{
        //提交事务
        sqlSession.commit();
        //6.释放资源
        sqlSession.close();
        in.close();
    }

    /**
     * 测试查询所有
     */
    @Test
    public void testFindAll(){
        //5.执行查询所有方法
        List<Account> accounts = accountDao.findAll();
        for(Account account : accounts){
            System.out.println("--------每个account信息-----------");
            System.out.println(account);
            System.out.println(account.getUser());
        }
    }

    /**
     * 测试查询所有账户,同时包含用户名和地址
     */
    @Test
    public void testFindAllAccountUser(){
        //5.执行查询所有方法
        List<AccountUser> aus = accountDao.findAllAccount();
        for(AccountUser au : aus){
            System.out.println(au);
        }
    }
}


两个实体类(setter&getter&toString已经去除)
package xyz.slienceme.domain;

import java.io.Serializable;
/**
 * @Time : 2021/6/25  17:26
 * @File : Account.java
 * @Software : IntelliJ IDEA
 */
public class Account implements Serializable {

    private Integer id;
    private Integer uid;
    private Double money;
    //从表实体应该包含一个主表实体的对象引用
    private User user; 
}

package xyz.slienceme.domain;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;


public class User implements Serializable {

    private Integer id;
    private String name;
    private String address;
    private String sex;
    private LocalDateTime birthday;

    //一对多关系映射,主表实体应该包含从表实体的集合引用
    private List<Account> accounts;
}

一个接口
package xyz.slienceme.dao;
import xyz.slienceme.domain.Account;
import xyz.slienceme.domain.AccountUser;
import java.util.List;
public interface IAccountDao {
    /**
     * 查询所有账户
     * @return
     */
    List<Account> findAll();
    /**
     * 查询所有账户,并且带有用户名称和地址信息
     * @return
     */
    List<AccountUser> findAllAccount();
}
———————分割线—————————-

多对多

<?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="xyz.slienceme.dao.IRoleDao">

    <!--  定义封装user的resultMap  -->
    <resultMap id="roleMap" type="role">
        <id property="roleId" column="rid"/>
        <result property="roleName" column="role_name"/>
        <result property="roleDesc" column="role_desc"/>
        <collection property="users" ofType="user">
            <id property="id" column="id"/>
            <result property="name" column="username"/>
            <result property="address" column="address"/>
            <result property="sex" column="sex"/>
            <result property="birthday" column="birthday"/>
        </collection>
    </resultMap>
    <!-- 查询所有 -->
    <select id="findAll" resultMap="roleMap">
        select u.*,r.id as rid,r.role_name,r.role_desc from role r
         left outer join user_role ur on r.id = ur.rid
         left outer join user u on u.id = ur.uid
    </select>
</mapper>
<?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="xyz.slienceme.dao.IUserDao">
    <!--  定义封装user的resultMap  -->
    <resultMap id="userMap" type="xyz.slienceme.domain.User">
        <id property="id" column="id"/>
        <result property="name" column="username"/>
        <result property="address" column="address"/>
        <result property="sex" column="sex"/>
        <result property="birthday" column="birthday"/>
        <!--  配置角色集合的映射 -->
        <collection property="roles" ofType="role">
            <id property="roleId" column="rid"/>
            <result property="roleName" column="role_name"/>
            <result property="roleDesc" column="role_desc"/>
        </collection>
    </resultMap>
    <!-- 查询所有 -->
    <select id="findAll" resultMap="userMap">
        select u.*,r.id as rid,r.role_name,r.role_desc from user u
         left outer join user_role ur on u.id = ur.uid
         left outer join role r on r.id = ur.rid
    </select>
</mapper>
两个实体类(setter&getter&toString已经去除)
package xyz.slienceme.domain;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;

public class User implements Serializable {
    private Integer id;
    private String name;
    private String address;
    private String sex;
    private LocalDateTime birthday;

    //多对多的关系映射,一个角色可以赋予多个用户
    private List<Role> roles;
}

package xyz.slienceme.domain;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;


public class User implements Serializable {

    private Integer roleId;
    private String roleName;
    private String roleDesc;

    //多对多的关系映射,一个角色可以赋予多个用户
    private List<User> users;
}
一个接口
package xyz.slienceme.dao;
import xyz.slienceme.domain.Role;
import java.util.List;

/**
 * @Author slience_me
 * @Time : 2021/6/26  8:35
 * @File : IRoleDao.java
 * @Software : IntelliJ IDEA
 * @MyBlog : https://blog.csdn.net/slience_me
 */
public interface IRoleDao {

    /**
     * 查询所有角色
     * @return
     */
    List<Role> findAll();
}

文档信息

Search

    Table of Contents