优秀的编程知识分享平台

网站首页 > 技术文章 正文

Mybatis介绍与入门

nanyue 2025-02-15 16:45:39 技术文章 4 ℃

1.官方文档

Mybatis中文手册:mybatis – MyBatis 3 或者 MyBatis中文网

Maven仓库:Maven Repository: org.mybatis ? mybatis ? 3.5.7 (mvnrepository.com)

2.概述

2.1传统Java程序操作DB

传统方式操作数据库的问题:

  1. 需要自己去连接数据库,这段代码由程序员编写(不一定标准)
  2. 程序不是OOP的方式来操作DB(我们希望在代码层面上是以对象的形式来操作,如insert(Object))
  3. SQL语句写在程序中,属于硬编码,没有解耦

2.2Mybatis基本介绍

  1. Mybatis 是一个持久层框架
  2. 前身是 ibatis,在ibatis3.x 时,更名为Mybatis
  3. Mybatis 在 Java 和 sql 之间提供更加灵活的映射方案
  4. mybatis 可以对数据库表的操作(sql,方法)等等直接剥离,写到 xml 配置文件,实现和 java 代码的解耦
  5. mybatis 通过 SQL 操作 DB,建库建表的操作仍需要程序员完成

2.3Mybatis工作原理

相对于传统方式,Mybatis的优势:

  1. 数据库的连接/连接池,只需要配置即可,标准可以统一
  2. 程序以OOP的方式来操作数据库
  3. sql语句可以写在xml文件中,实现了解耦
  4. Mybatis可以对DB操作进行优化,提高效率,比如配置缓存

3.Mybatis快速入门

3.1需求说明

要求:开发一个Mybatis项目,通过Mybatis的方式可以对monster表进行crud操作。

3.2环境搭建

(1)创建maven父项目,方便项目的jar包管理

    4.0.0     com.li    mybatis    1.0-SNAPSHOT             8        8                                         mysql            mysql-connector-java            5.1.49                                    org.mybatis            mybatis            3.5.7                                    junit            junit            4.12                        test            

(2)创建maven父项目的Module,视为子项目


此时父项目的pom.xml文件如下:

    4.0.0         com.li    mybatis    pom    1.0-SNAPSHOT            mybatis_quickstart                 8        8                                            

子模块的pom.xml文件:

                 mybatis        com.li        1.0-SNAPSHOT        4.0.0         mybatis_quickstart             8        8     

3.2代码实现

(1)创建数据库和表

-- 创建数据库CREATE DATABASE `mybatis`;USE `mybatis`;-- 创建monster表CREATE TABLE `monster`(`id` INT NOT NULL AUTO_INCREMENT,`age` INT NOT NULL,`birthday` DATE DEFAULT NULL,`email` VARCHAR(255) NOT NULL,`gender` TINYINT NOT NULL,-- 1 male, 0 female`name` VARCHAR(255) NOT NULL,`salary` DOUBLE NOT NULL,PRIMARY KEY(`id`))CHARSET=utf8

(2)在子模块 mybatis_quickstart 的 resources 目录创建配置文件 mybatis-config.xml(名称随意)

mybatis配置文件模板

                                                                                                                                                                                                                                        

(3)创建实体类 Monster.java

package com.li.entity; import java.util.Date; /** * @author 李 * @version 1.0 * 1.Monster和 monster表有对应关系 * 2.原生的sql语句查询结果还是要封装成对象 * 3.因此要求这里的实体类属性名和表的字段名保持相同 */public class Monster {    //属性和表的字段对应    private Integer id;    private Integer age;    private String name;    private String email;    private Date birthday;    private double salary;    private Integer gender;     public Monster() {    }     public Monster(Integer id, Integer age, String name, String email,                   Date birthday, double salary, Integer gender) {        this.id = id;        this.age = age;        this.name = name;        this.email = email;        this.birthday = birthday;        this.salary = salary;        this.gender = gender;    }     public Integer getId() {        return id;    }     public void setId(Integer id) {        this.id = id;    }     public Integer getAge() {        return age;    }     public void setAge(Integer age) {        this.age = age;    }     public String getName() {        return name;    }     public void setName(String name) {        this.name = name;    }     public String getEmail() {        return email;    }     public void setEmail(String email) {        this.email = email;    }     public Date getBirthday() {        return birthday;    }     public void setBirthday(Date birthday) {        this.birthday = birthday;    }     public double getSalary() {        return salary;    }     public void setSalary(double salary) {        this.salary = salary;    }     public Integer getGender() {        return gender;    }     public void setGender(Integer gender) {        this.gender = gender;    }     @Override    public String toString() {        return "Monster{" +                "id=" + id +                ", age=" + age +                ", name='" + name + '\'' +                ", email='" + email + '\'' +                ", birthday=" + birthday +                ", salary=" + salary +                ", gender=" + gender +                '}';    }}

(4)创建MonsterMapper接口

package com.li.mapper; import com.li.entity.Monster; /** * @author 李 * @version 1.0 * 1.MonsterMapper接口用于声明操作monster表的方法 * 2.这些方法可以通过注解或者xml文件来实现 */public interface MonsterMapper {    //添加monster    public void addMonster(Monster monster);}

(5)创建接口对应的映射文件,实现方法

mybatis – MyBatis 3 | XML 映射器

                INSERT INTO `monster`        (`age`,`birthday`,`email`,`gender`,`name`,`salary`)        VALUES (#{age},#{birthday},#{email},#{gender},#{name},#{salary})    

(6)工具类MybatisUtils,用于获取连接

package com.li.util; 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 java.io.IOException;import java.io.InputStream; /** * @author 李 * @version 1.0 * MybatisUtils工具类可以得到 SqlSession */public class MybatisUtils {    private static SqlSessionFactory sqlSessionFactory;     //静态代码块中初始化 SqlSessionFactory-会话工厂    static {        try {            //指定资源文件(配置文件)            String resource = "mybatis-config.xml";            //获取配置文件对应的inputStream            //说明:加载文件时,默认到resource目录对应的==>运行后的工作目录target/classes找            InputStream resourceAsStream = Resources.getResourceAsStream(resource);            sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);            System.out.println("sqlSessionFactory=" + sqlSessionFactory.getClass());        } catch (IOException e) {            e.printStackTrace();        }    }     //编写方法,返回一个SqlSession对象-会话    public static SqlSession getSqlSession() {        return sqlSessionFactory.openSession();    }}

3.3测试

3.3.1添加

test 目录中创建测试类 MonsterMapperTest.java

package com.li.mapper; import com.li.entity.Monster;import com.li.util.MybatisUtils;import org.apache.ibatis.session.SqlSession;import org.junit.Before;import org.junit.Test; import java.util.Date; /** * @author 李 * @version 1.0 */public class MonsterMapperTest {    //属性    private SqlSession sqlSession;    private MonsterMapper monsterMapper;     /**     * 编写方法,完成初始化     * 当一个A方法标注了注解 @Before时,表示在执行你的目标测试方法前会先执行A方法     */    @Before    public void init() {        sqlSession = MybatisUtils.getSqlSession();        //获取到 monsterMapper对象 =class com.sun.proxy.$Proxy7代理对象)        //底层使用了动态代理机制,返回一个代理对象,通过这个对象去执行你的方法        monsterMapper = sqlSession.getMapper(MonsterMapper.class);        System.out.println("monsterMapper的类型=" + monsterMapper.getClass());    }     @Test    public void addMonster() {        for (int i = 0; i < 2; i++) {            Monster monster = new Monster();            monster.setAge(10 + i);            monster.setBirthday(new Date());            monster.setEmail("kate@qq.com");            monster.setGender(1);            monster.setName("松鼠精" + i + "号");            monster.setSalary(1000 + i * 10);            monsterMapper.addMonster(monster);            System.out.println("添加对象--" + monster);        }        //如果是增删改,需要提交事务,因为它默认不提交        if (sqlSession != null) {            sqlSession.commit();            //将连接释放回连接池            sqlSession.close();        }        System.out.println("保存成功....");    }}

上面的代码一般会出现找不到xxxmapper.xml错误,原因是加载的资源文件时是到target目录下加载的,当maven项目运行时,源工程的MonsterMapper.xml并没有被拷贝到target目录下。

解决方法:在父工程的pom.xml加入build配置,作用是配置resource,防止资源导出失败

                        src/main/java                            **/*.xml                                        src/main/resources                            **/*.xml                **/*.properties                        

然后选择build project

如果不行,可能是maven版本冲突,在setting中切换maven版本,然后点击父工程的maven的clean重新构建。



测试结果:

数据库monster表增加了两条记录:

3.3.2返回自增长

有时候我们需要获取数据库中自动生成(AUTO_INCREMENT)的主键,这时候可以使用Mybatis的useGeneratedKeys(开启新增主键返回功能)和 keyProperty(实体的主键属性)来配合获取。

(1)修改映射文件MonsterMapper.xml,在该文件中的方法映射中添加 useGenerateKeys 和 keyProperty

            INSERT INTO `monster`        (`age`,`birthday`,`email`,`gender`,`name`,`salary`)        VALUES (#{age},#{birthday},#{email},#{gender},#{name},#{salary})    

(2)修改测试类,输出主键

(3)测试结果:

数据库表格:

3.3.3删除

(1)修改 MonsterMapper.java 接口,声明 delMonster() 方法

//根据id删除一个Monsterpublic void delMonster(Integer id);

(2)在映射文件 MonsterMapper.xml 中实现 delMonster() 方法

    DELETE FROM `monster` WHERE `id`=#{id};

(3)修改测试类,添加测试方法

package com.li.mapper; import com.li.entity.Monster;import com.li.util.MybatisUtils;import org.apache.ibatis.session.SqlSession;import org.junit.Before;import org.junit.Test; import java.util.Date; /** * @author 李 * @version 1.0 */public class MonsterMapperTest {    //属性    private SqlSession sqlSession;    private MonsterMapper monsterMapper;     @Before    public void init() {        sqlSession = MybatisUtils.getSqlSession();        monsterMapper = sqlSession.getMapper(MonsterMapper.class);        System.out.println("monsterMapper的类型=" + monsterMapper.getClass());    }     @Test    public void delMonster() {        //删除id=2的记录        monsterMapper.delMonster(2);        //如果是增删改操作,需要提交事务,因为它默认不提交        if (sqlSession != null) {            sqlSession.commit();            //将连接释放回连接池            sqlSession.close();        }        System.out.println("删除成功....");    }}

测试结果:

数据库id=2的记录成功被删除:

3.3.4修改&查询

(1)修改 MonsterMapper.java 接口,声明修改和查询的方法

//修改Monsterpublic void updateMonster(Monster monster);//查询-根据idpublic Monster getMonsterById(Integer id);//查询所有的Monsterpublic List findAllMonster();

(2) 映射文件 MonsterMapper.xml 中实现方法

    UPDATE `monster`    SET `age`=#{age},`birthday`=#{birthday},`email`=#{email},    `gender`=#{gender},`name`=#{name},`salary`=#{salary}    WHERE `id`=#{id};  

(3)配置别名

(4)修改测试类,添加测试方法

package com.li.mapper; import com.li.entity.Monster;import com.li.util.MybatisUtils;import org.apache.ibatis.session.SqlSession;import org.junit.Before;import org.junit.Test; import java.util.Date;import java.util.List; /** * @author 李 * @version 1.0 */public class MonsterMapperTest {    //属性    private SqlSession sqlSession;    private MonsterMapper monsterMapper;     @Before    public void init() {        sqlSession = MybatisUtils.getSqlSession();        monsterMapper = sqlSession.getMapper(MonsterMapper.class);        System.out.println("monsterMapper的类型=" + monsterMapper.getClass());    }        @Test    public void updateMonster() {        Monster monster = new Monster();        monster.setAge(50);        monster.setBirthday(new Date());        monster.setEmail("king@qq.com");        monster.setGender(0);        monster.setName("白骨精");        monster.setSalary(20000);        monster.setId(3);        monsterMapper.updateMonster(monster);        if (sqlSession != null) {            sqlSession.commit();            sqlSession.close();        }        System.out.println("修改成功..");    }     @Test    public void getMonsterById() {        Monster monster = monsterMapper.getMonsterById(3);        System.out.println("monster=" + monster);        if (sqlSession != null) {            sqlSession.close();        }    }     @Test    public void findAllMonster() {        List monsters = monsterMapper.findAllMonster();        for (Monster monster : monsters) {            System.out.println("monster="+monster);        }        if (sqlSession != null) {            sqlSession.close();        }    }}

测试updateMonster()方法:

测试getMonsterById()方法:

测试findAllMonster()方法:

4.日志输出-查看SQL

在开发Mybatis程序时,比如执行测试方法,程序员往往需要查看底层发给MySql的SQL语句到底长什么样,这时应该如何查看?

解决方案:日志输出。

(1)修改Mybatis-config.xml文件,加入日志输出配置,方便分析SQL语句

(2)比如测试updateMonster() 方法时,输出的结果为:

Logging initialized using 'class org.apache.ibatis.logging.stdout.StdOutImpl' adapter.PooledDataSource forcefully closed/removed all connections.PooledDataSource forcefully closed/removed all connections.PooledDataSource forcefully closed/removed all connections.PooledDataSource forcefully closed/removed all connections.sqlSessionFactory=class org.apache.ibatis.session.defaults.DefaultSqlSessionFactorymonsterMapper的类型=class com.sun.proxy.$Proxy7Opening JDBC ConnectionWed Feb 22 19:09:14 CST 2023 WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.Created connection 1475491159.Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@57f23557]==>  Preparing: UPDATE `monster` SET `age`=?,`birthday`=?,`email`=?, `gender`=?,`name`=?,`salary`=? WHERE `id`=?;==> Parameters: 50(Integer), 2023-02-22 19:09:14.079(Timestamp), king333@qq.com(String), 0(Integer), 白骨精(String), 20000.0(Double), 3(Integer)<==    Updates: 1Committing JDBC Connection [com.mysql.jdbc.JDBC4Connection@57f23557]Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@57f23557]Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@57f23557]Returned connection 1475491159 to pool.修改成功.. Process finished with exit code 0

当进行多表联查的时候,日志输出对我们的调试很有帮助。

5.练习

Tags:

最近发表
标签列表