1、Mybatis实现CRUD

1.1、步骤分为三步

编写接口
编写对应的mapper中的sql语句
测试

注意点:增删改操作都需要提交事务

1.2、select

UserMapper接口

  1. public List<User> getUserList();//查询全部用户
  2. public User getUserById(int id);//根据id查询用户

userMapper.xml

  1. <!-- 查询所有用户-->
  2. <select id="getUserList" resultType="domain.User">
  3. select *from user;
  4. </select>
  5. <!-- 根据id查询用户-->
  6. <select id="getUserById" resultType="domain.User" parameterType="int">
  7. select *from user where id=#{id};
  8. </select>

测试

   //查询所有用户
    @Test
    public void getUserList(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> userList = mapper.getUserList();
        for (User user : userList) {
            System.out.println(user);
        }
        sqlSession.close();
    }

   //根据id查询用户
    @Test
    public void getUserById(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = mapper.getUserById(2);
        System.out.println(user);
        sqlSession.close();
    }

1.3、insert

UserMapper接口

public void insert(User user);//插入一个用户

userMapper.xml

<!--    插入一个用户-->
    <insert id="insert" parameterType="domain.User">
        insert into user(id,name,pwd)values (#{id},#{name},#{pwd});
    </insert>

测试

    //插入用户
    @Test
    public void insert(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = new User(1, "刘某", "123");
        mapper.insert(user);//插入用户
        sqlSession.commit();//提交事务
        sqlSession.close();
    }

1.4、update

UserMapper接口

    public void update(User user);//修改一个用户

userMapper.xml

<!--    修改一个用户-->
    <update id="update" parameterType="domain.User">
        update user set name=#{name},pwd=#{pwd} where id=#{id};
    </update>

测试

    //修改用户
    @Test
    public void update(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = new User(1, "老王", "3");
        mapper.update(user);
        sqlSession.commit();
        sqlSession.close();
    }

1.5、delete

UserMapper接口

    public void delete(int id);//删除一个用户

userMapper.xml

<!--    删除一个用户-->
    <delete id="delete" parameterType="int">
        delete from user where id=#{id};
    </delete>

测试

    //删除一个用户
    @Test
    public void delete(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        mapper.delete(1);
        sqlSession.commit();
        sqlSession.close();
    }

1.6、模糊查询

UserMapper接口

    public List<User> getUserListByName(String name);//模糊查询

userMapper.xml

<!--    模糊查询-->
    <select id="getUserListByName" resultType="domain.User" parameterType="String">
        select *from user where name like #{name};
    </select>

测试(注意传参)

    //模糊查询
    @Test
    public void getUserList2(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> list = mapper.getUserListByName("%老%");//注意传参
        for (User user : list) {
            System.out.println(user);
        }
        sqlSession.close();
    }

1.8、万能Map

假设,我们的实体类,或者数据库中的表,字段或者参数过多,我们应当考虑使用Map!

UserMapper接口

    public void updateByMap(Map<String,Object> map);//使用万能Map修改用户

userMapper.xml

<!--    使用万能Map修改用户-->
    <update id="updateByMap" parameterType="map">
        update user set pwd=#{password} where id=#{id};
    </update>

测试(注意传参)

//使用万能Map修改用户
    @Test
    public void update2(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        //创建一个Map集合
        Map<String,Object> map=new HashMap<>();
        //设置map中键的值
        map.put("password","12333");//给xml中的·password设置值
        map.put("id",1);//给xml中的id设置值
        //调用方法,把map传进去
        mapper.updateByMap(map);
        sqlSession.commit();
        sqlSession.close();
    }

2、配置解析

2.1、核心配置文件

mybatis-config.xml
MyBatis 的配置文件包含了会深深影响 MyBatis 行为的设置和属性信息。

configuration(配置)
properties(属性)
settings(设置)
typeAliases(类型别名)
typeHandlers(类型处理器)
objectFactory(对象工厂)
plugins(插件)
environments(环境配置)
environment(环境变量)
transactionManager(事务管理器)
dataSource(数据源)
databaseIdProvider(数据库厂商标识)
mappers(映射器)

2.2、环境配置(environments)

  • MyBatis 可以配置成适应多种环境。
  • 不过要记住:尽管可以配置多个环境,但每个 SqlSessionFactory 实例只能选择一种环境。
  • Mybatis默认的事务管理器就是JDBC,连接池—>POOLED

2.3、属性(properties)

我们可以通过properties属性来实现引用配置文件

这些属性都是可外部配置且可动态替换的,既可以在典型的属性文件中配置,也可以通过properties元素的子元素来传递。【db.properties】

编写一个配置文件db.properties

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mybatis?useSSL=true&useUnicode=true&characterEncoding=UTF-8
userName=root
password=123456

在核心配置文件中引入
Snipaste_2021-07-11_17-03-28.jpg

注意点:

  • 可以直接引入外部文件
  • 可以在其中增加一些属性设置

    <properties resource="db.properties">
          <property name="password" value="11111"/>
      </properties>
    
  • 如果两个文件有同一个字段,优先使用内部配置文件里面的!

Snipaste_2021-07-11_17-03-28.jpg

2.4、类型别名(typeAliases)

  • 类型别名可为 Java 类型设置一个短名字。
  • 意在降低冗余的全限定类名书写。
    <!--    可以给实体类取别名-->
      <typeAliases>
          <typeAlias type="domain.User" alias="User"></typeAlias>
      </typeAliases>
    

也可以指定一个包,MyBatis会在包名下面搜索需要的JavaBean,比如扫描实体类的包,它的默认别名就为这个类的类名,首字母小写!

 <!--    扫描包-->
<typeAliases>
        <package name="domain"/>
    </typeAliases>

在实体类比较少的时候,使用第一种方式。
如果实体类十分多,建议使用第二种。
第一种可以自定义别名,第二种则不行,如果非要改,需要在实体类是增加注解:@Alias

2.5、设置(settings)

这是 MyBatis 中极为重要的调整设置,它们会改变 MyBatis 的运行时行为。

  • 开启日志记录

    <settings>
      <setting name="logImpl" value="STDOUT_LOGGING"/>
    </settings>
    
  • 开启驼峰式命名的支持

    <settings>
      <setting name="mapUnderscoreToCamelCase" value="true"/> 
    </settings>
    

2.6、其他配置(这辈子都用不到)

2.7、映射器(mapper)

MapperRegistry:绑定我们的Mapper文件

方式一(推荐使用)

  <mappers>
        <mapper resource="mapper/userMapper.xml"/>
    </mappers>

方式二(使用class文件绑定注册)

注意点:

  • 接口和他的Mapper配置文件必须同名。
  • 接口和他的Mapper配置文件必须在同一个包下。
       <mappers>
          <mapper class="mapper.UserMapper"></mapper>
      </mappers>
    

方式三(使用扫描包进行注入绑定)

注意点与方式二一样

 <mappers>
        <package name="mapper"/>
    </mappers>

tips:可以在resources下面建立一个与接口所在包名一样的包。
Snipaste_2021-07-12_07-26-07.jpg

2.8、生命周期和作用域

生命周期和作用域是至关重要的,因为错误的使用会导致非常严重的并发问题

Snipaste_2021-07-12_07-26-07.jpg

SqlSessionFactoryBuilder

  • 一旦创建了SqlSessionFactory,就不再需要了。
  • 局部变量。

SqlSessionFactory

  • 可以想象为数据库连接池。
  • SqlSessionFactoey一旦被创建就应该在应用的运行期间一直存在,没有如何理由丢弃它或者重新创建另一个实例。
  • SqlSessionFactory的最佳作用域是全局作用域。
  • 最简单的就是使用单例模式或者静态单例模式。

SqlSession

  • 连接到连接池的一个请求。
  • SqlSession的实例不是线程安全的,因此是不能被共享的,所以它的最佳作用域是请求或方法作用域。
  • 用完之后需要赶紧关闭,否则资源被占用。

3、映射配置文件

3.1、namespace

namespace中的包名要和Dao/Mapper接口的包名一致!
Snipaste_2021-07-11_08-04-35.jpg

3.2、parameterType配置参数类型

parameterType属性的取值可以是基本数据类型,引用类型,还可以是实体类类型,同时也可以使用实体类的包装类。

  1. 使用对象传递参数,直接在sql中取对象的属性即可!
  2. 使用Map传递参数,直接在sql中取出key即可!
  3. 当传递参数为基本类型,并且只有一个时,parameterType可以不写
    <insert id="save" parameterType="user">
       insert into user(username,password) values(#{username},#{password});
    </insert>
    

3.3、resultType配置结果类型

resultType属性可以指定结果集的类型,它支持基本数据类型和实体类类型。需要注意的是,它和parameterType属性一样,如果注册过别名的,可以直接使用别名;没有注册过的必须使用全限定类名。

<select id="findAll" resultType="user">
   select * from user;
</select>

3.4、resultMap配置结果类型

在开发中,实体类中的属性名和数据库表中的字段名不一定都是完全相同的,这样可能会导致用实体类接收返回的结果无法映射到实体类的属性中,那么该如何解决这种字段名和实体类属性名不相同的冲突呢?
答:可以通过resultMap标签来映射字段名和实体类属性名

<!-- 结果集映射 -->
<resultMap id="userMap" type="User">
    <!--column数据库中的字段,property实体类中的属性-->
    <result column="id" property="userId"></result>
    <result column="username" property="userName"></result>
    <result column="password" property="userPwd"></result>
</resultMap>

<select id="findAll" resultMap="userMap">
    select * from user;
</select>

3.5、id

id:就是namespace中对应的接口中的方法名

4、日志

4.1、日志工厂

如果一个数据库操作,出现了异常,我们需要排错,日志就是最好的助手!
曾经:sout、debug
现在:日志工厂!
Snipaste_2021-07-12_07-26-07.jpg
logImpl:

  • SLF4J
  • LOG4J 【掌握】
  • LOG4J2
  • JDK_LOGGING
  • COMMONS_LOGGING
  • STDOUT_LOGGING 【掌握】
  • NO_LOGGING

STDOUT_LOGGING标准日志输出
在mybatis核心配置文件中配置我们的日志!

 <settings>
     <setting name="logImpl" value="STDOUT_LOGGING"/>
  </settings>

4.2、LOG4J

1,导入log4j的jar包

<dependency>
    <groupId>log4j</groupId>
    <artifactId>log4j</artifactId>
    <version>1.2.17</version>
</dependency>

2,创建log4j.properties

#将等级为DEBUG的日志信息输出到console和file这两个目的地,console和file的定义在下面的代码
log4j.rootLogger=DEBUG,console,file

#控制台输出的相关设置
log4j.appender.console = org.apache.log4j.ConsoleAppender
log4j.appender.console.Target = System.out
log4j.appender.console.Threshold=DEBUG
log4j.appender.console.layout = org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=【%c】-%m%n

#文件输出的相关设置
log4j.appender.file = org.apache.log4j.RollingFileAppender
log4j.appender.file.File=./log/kuang.log
log4j.appender.file.MaxFileSize=10mb
log4j.appender.file.Threshold=DEBUG
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=【%p】【%d{yy-MM-dd}】【%c】%m%n

#日志输出级别
log4j.logger.org.mybatis=DEBUG
log4j.logger.java.sql=DEBUG
log4j.logger.java.sql.Statement=DEBUG
log4j.logger.java.sql.ResultSet=DEBUG
log4j.logger.java.sql.PreparedStatement=DEBUG

3,配置log4j为日志的实现

<settings>
   <setting name="logImpl" value="LOG4J"/>
</settings>

5、分页

使用Limit分页

语法:select * from user limit startIndex,pageSize;

接口

  public List<User> getUserListByLimit(Map<String,Integer> map);//分页查询

配置文件

<!--    分页查询-->
    <select id="getUserListByLimit" parameterType="map" resultType="domain.User">
        select *from user limit #{startIndex},#{pageSize}
    </select>

测试

   //分页查询
    @Test
    public void getUserListByLimit(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        Map<String,Integer> map=new HashMap<>();//创建一个Map
        map.put("startIndex",0);//给键赋值
        map.put("pageSize",4);
        List<User> userList = mapper.getUserListByLimit(map);
        for (User user : userList) {
            System.out.println(user);
        }
        sqlSession.close();
    }

使用RowBounds分页(不推荐)

接口

public List<User> getUserListByRowBounds();//使用RowBounds分页查询

配置文件

<!--    分页查询2-->
    <select id="getUserListByRowBounds" resultType="domain.User">
        select *from user
    </select>

测试

   //分页查询2
    @Test
    public void getUserListByRowBounds(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        RowBounds rowBounds = new RowBounds(1, 3);//RowBounds实现
        //通过Java代码层实现分页查询
        List<User> userList = sqlSession.selectList("mapper.UserMapper.getUserListByRowBounds", null, rowBounds);
        for (User user : userList) {
            System.out.println(user);
        }
        sqlSession.close();
    }

6、使用注解开发

使用注解开发,同样,在核心配置文件中也要使用mapper绑定接口

<mappers>
    <mapper class="mapper.UserMapper"></mapper>
</mappers>

注意:如果含有多个参数,需要使用@Param
UserMapper接口

    @Select("select *from user where id=#{id} and name=#{name}")//查询所有用户,里面含有多个参数
    public List<User> getUsers(@Param("id")int id,@Param("name")String name);

    @Delete("delete from user where id=#{id}")//根据id、删除用户,通过注解
    public void deleteById(int id);

测试

//    使用注解查询所有用户
    @Test
    public void getUsers(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> users = mapper.getUsers();
        for (User user : users) {
            System.out.println(user);
        }
        sqlSession.close();
    }

    //通过注解的方式删除用户
    @Test
    public void deleteById(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        mapper.deleteById(4);
        sqlSession.close();
        sqlSession.commit();
    }