devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

第六章 初识mybatis_博客系统之初识mybatis

作者：知新_RL | 2024-04-26 11:23:05

赞

踩

博客系统之初识mybatis

（一）知识点梳理：

1.什么是Mybatis?
mybatis是一个支持普通sql查询，存储过程以及高级映射的持久层框架。
mybatis也称为ORM（对象关系映射框架），ORM就是一种为了解决面向对象与关系数据库中数据类型不匹配的技术，通过描述Java对象与数据库表之间的映射关系，自动地将应用程序中的对象持久化到关系数据库的表中。
2.Mybatis的工作原理？
（1）读取配置文件mybatis-config.xml;
（2）加载映射文件xxxMapper.xml;
（3）构建会话工厂SqlSession;
（4）构建会话对象SqlSession;
（5）Executor执行器，执行相关操作；
（6）MappedStatement对象；
（7）输入映射；
（8）输出映射；
3.查询客户，分为单条客户数据的精确查询和多条数据的模糊查询；
（1）精确查询：
例：select * from t_customer where id=#{id}
（2）模糊查询：
例：select * from t_customer where username like concat(’%’,#{username},’%’)
4.添加、更新、删除客户都需要在对应的测试方法中进行事物的提交commit()操作。
5.实际在单元测试中分5步完成mybatis框架的使用：
（1）读取配置文件mybatis-config.xml;
（2）根据配置文件创建会话工厂SqlSessionFactory;
（3）根据会话工厂创建会话SqlSession;
（4）会话执行相应的操作；
（5）关闭会话（若是增删改操作需要先提交事务）；

（二） 实例：

（1）database.sql

#创建一个名称为mybatis的数据库
create database mybatis;
#使用mybatis数据库
use mybatis;
#创建t_customer的表
create table t_customer(
                           id int(32) primary key auto_increment,
                           username varchar(50),
                           jobs varchar(50),
                           phone varchar(16)
);
#插入数据

insert into t_customer values('1','joy','doctor','17339821917');
insert into t_customer values('2','jack','teacher','17339821916');
insert into t_customer values('3','rose','student','17339821911');
insert into t_customer values('4','tom','cooker','17339821910');






  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22

（2）日志信息log4j.properties

# Global logging configuration
log4j.rootLogger=ERROR, stdout
# MyBatis logging configuration...
log4j.logger.com.wds=DEBUG
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

（3）配置文件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>
    <!--1.配置环境-->
    <environments default="mysql">
        <environment id="mysql">
            <!--只用JDBC的事务管理-->
            <transactionManager type="JDBC"></transactionManager>
            <!--数据库连接池-->
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/mybatis"/>
                <property name="username" value="root"/>
                <property name="password" value="12345678"/>
            </dataSource>
        </environment>
    </environments>
    <!--2.映射文件-->
    <mappers>
        <mapper resource="com/wds/po/CustomerMapper.xml"/>
    </mappers>
</configuration>

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

（4）实体类Customer.java

package com.wds.po;

public class Customer {
    private Integer id;
    private String username;
    private String jobs;
    private String phone;

    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 getJobs() {
        return jobs;
    }

    public void setJobs(String jobs) {
        this.jobs = jobs;
    }

    public String getPhone() {
        return phone;
    }

    public void setPhone(String phone) {
        this.phone = phone;
    }

    @Override
    public String toString() {
        return "Customer{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", jobs='" + jobs + '\'' +
                ", phone='" + phone + '\'' +
                '}';
    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51

（5）映射文件CustomerMapper.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="com.wds.po.Customer">
    <select id="findCustomerById" parameterType="Integer" resultType="com.wds.po.Customer">
        <!--#{id}相当于占位符？-->
        select * from t_customer where id = #{id}
    </select>
    <select id="findCustomerByName" parameterType="String" resultType="com.wds.po.Customer">
        <!--select * t_customer where username like '%${value}%'-->
        <!--使用concat('%',#{username},'%')防止sql注入问题-->
        select * from t_customer where username like concat('%',#{username},'%')
    </select>
    <insert id="addCustomer" parameterType="com.wds.po.Customer">
        insert into t_customer(username, jobs, phone)
        values (#{username}, #{jobs}, #{phone})
    </insert>
    <update id="updateCustomer" parameterType="com.wds.po.Customer">
        update t_customer
        set username = #{username},
            jobs = #{jobs},
            phone = #{phone}
        where id = #{id}
    </update>
    <delete id="deleteCustomer" parameterType="com.wds.po.Customer">
        delete
        from t_customer
        where id = #{id}
    </delete>
</mapper>

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31

（6）测试类MybatisTest

package com.wds.test;

import com.wds.po.Customer;
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.Test;

import java.io.InputStream;
import java.util.List;

public class MybatisTest {
    @Test
    /**
     * 单个客户数据的精确查询
     */
    public void findCustomerById() throws Exception{
        //1.读取配置文件
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //2.根据配置文件构建会话工厂SqlSessionFactory
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //3.根据sqlSessionFactory会话工厂创建对象SqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //4.sqlSession执行sql语句，返回结果
        //第一个参数是sql的id，第二个参数是传入给sql的占位符的参数
        Customer customer = sqlSession.selectOne("com.wds.po.Customer.findCustomerById",1);
        //5.输出结果
        System.out.println(customer.toString());
        //6.关闭sqlSession
        sqlSession.close();
    }

    /**
    根据客户名称模糊查询用户列表
     */
    @Test
    public void findCustomerByName() throws Exception{
        //1.读取配置文件
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //2.根据配置问价构建会话工厂SqlSessionFactory
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //3.根据sqlSessionFactory创建会话
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //4.执行sqlSession
        List<Customer> customers = sqlSession.selectList("com.wds.po.Customer.findCustomerByName","j");
        //5.输出结果
        for(Customer customer:customers){
            System.out.println(customer.toString());
        }
        //6.关闭流
        sqlSession.close();
    }
    /**
     * 添加客户
     */
    @Test
    public void addCustomer() throws Exception{
        //1.读取配置问价
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //2.根据配置文件创建会话工厂
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //3.根据会话工厂创建会话对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //4.执行SqlSession
        //4.1 创建客户对象
        Customer customer = new Customer();
        customer.setUsername("东生");
        customer.setJobs("coder");
        customer.setPhone("18139954468");
        //4.2 执行添加方法
        //4.3第一个参数是sql的id，第二个是传给sql的占位符参数
        int num = sqlSession.insert("com.wds.po.Customer.addCustomer", customer);
        if(num>0){
            System.out.println("插入操作执行成功！！！");
        }else
        {
            System.out.println("执行失败！！！");
        }
        //4.4执行事务，提交事务
        sqlSession.commit();
        //5.关闭流
        sqlSession.close();
    }

    /**
     * 更新客户
     */
    @Test
    public void updateCustomer() throws Exception{
        //1.读取配置问价
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //2.根据配置文件创建会话工厂
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //3.根据SqlSessionFactory创建会话
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //4.执行操作
        //4.1创建对象
        Customer customer = new Customer();
        customer.setId(1);
        customer.setUsername("吕憨憨");
        customer.setJobs("doctor");
        customer.setPhone("110256");
        int num = sqlSession.update("com.wds.po.Customer.updateCustomer",customer);
        if(num>0){
            System.out.println("您的修改已经成功！！");
        }
        //4.3提交事务
        sqlSession.commit();
        //5.关闭
        sqlSession.close();
    }

    /**
     * 删除客户操作
     */
    @Test
    public void deleteCustomer() throws Exception{
        //1.读取配置问价
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //2.根据配置问价创建会话工厂
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //3.根据会话工厂创建会话对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //4.执行操作
        int num = sqlSession.delete("com.wds.po.Customer.deleteCustomer",4);
        if(num>0){
            System.out.println("删除操作执行成功！！！");
        }else{
            System.out.println("删除操作执行失败！！！");
        }
        //提交事务，增删改都需要事务
        sqlSession.commit();
        //5.关闭会话
        sqlSession.close();
    }
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143

（三）运行结果

（1）精确查询
在这里插入图片描述
（2）模糊查询
在这里插入图片描述
（3）添加客户
在这里插入图片描述
（4）更新客户
在这里插入图片描述
（6）删除客户
在这里插入图片描述

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/490663
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号