脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → mybatis实现增删改查CRUD

如何使用MyBatis框架实现增删改查（CRUD）操作

 更新时间：2023年05月05日 08:18:39   作者：xiezhr  
本文主要介绍了如何使用MyBatis框架实现增删改查（CRUD）操作。首先介绍了MyBatis框架的基本概念和使用方法，然后分别介绍了如何使用MyBatis实现增删改查操作。最后，通过一个简单的示例演示了如何使用MyBatis框架实现CRUD操作。

mybatis 介绍

  • mybatis 本是apache的一个开源项目iBatis,
    2010年这个项目由apache迁移到了googlecode，并且改名为MyBatis，2013年11月迁移到Github。
  • MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。
  • MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。
  • MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(普通的 Java对象)映射成数据库中的记录

Mybatis官方文档 :
http://www.mybatis.org/mybatis-3/zh/index.html

GitHub :https://github.com/mybatis/mybatis-3

代码演示

  • 所需环境
  • jdk1.8.0_91
  • mysql-5.7.29
  • apache-maven-3.6.3
  • 创建数据库
CREATE DATABASE `mybatis`;

USE `mybatis`;

DROP TABLE IF EXISTS `user`;

CREATE TABLE `user` (
`id` int(20) NOT NULL,
`name` varchar(30) DEFAULT NULL,
`pwd` varchar(30) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

insert  into `user`(`id`,`name`,`pwd`) values (1,'张三','123456'),(2,'李四','abcdef'),(3,'王五','987654');
  • 使用idea创建项目并导入导入mybatis所需jar包
<dependencies>
        <!--mysql驱动-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.46</version>
        </dependency>
        <!--mybatis包-->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.2</version>
        </dependency>
        <!--junit 测试包-->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
    </dependencies>
  • 编写mybatis核心配置文件

该配置文件主要是配置连接mysql的基本信息及注册mapper(具体配置参考官方文档)

<?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>
    <environments default="development">
        <environment id="development">
            <transactionManager type="JDBC"/>
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useUnicode=true&amp;characterEncoding=utf-8"/>
                <property name="username" value="root"/>
                <property name="password" value="123456"/>
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <mapper resource="com/xiezhr/Dao/UserMapper.xml"></mapper>
    </mappers>
</configuration>
  • 编写mybatis工具类

查看官方文档,我们这里要封装一个工具类生成SqlSession对象，SqlSession用于后面的执行sql

package com.xiezhr.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;

public class MysqlUtil {

    private static SqlSessionFactory sqlSessionFactory;
    static {
        String resource = "mybatis-config.xml";
        InputStream inputStream = null;
        try {
            inputStream = Resources.getResourceAsStream(resource);
        } catch (IOException e) {
            e.printStackTrace();
        }
         sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

    }

    public static SqlSession getSqlSession(){
        return sqlSessionFactory.openSession();
    }


}
  • 创建对应数据库表的实体类

各个属性得命名必须与数据库字段一一对应，具体如下所示，数据库对应字段为id,name,pwd

package com.xiezhr.pojo;

public class User {
    private int id;
    private String name;
    private String pwd;

    public String getPwd() {
        return pwd;
    }

    public void setPwd(String pwd) {
        this.pwd = pwd;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public User() {
    }

    public User(int id, String name, String pwd) {
        this.id = id;
        this.name = name;
        this.pwd = pwd;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", pwd='" + pwd + '\'' +
                '}';
    }
}
  • 编写Mapper接口

该接口对应原来的dao,具体代码如下

package com.xiezhr.dao;

import com.xiezhr.pojo.User;

import java.util.List;

public interface UserMapper {
    List<User> getUserList();
}
  • 编写Mapper.xml 文件

由于我们使用了mybatis,所以这的xml文件相当于我们原来dao得实现类daoimpl。namespace属性对应着接口，不能写错，标签表示是个查询语句。id 属性对应着接口的方法，result Type代表返回得类型，即对应这pojo实体。具体代码如下

<?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.xiezhr.dao.UserMapper">
    <select id="getUserList" resultType="com.xiezhr.pojo.User">
     select * from mybatis.user;
    </select>
</mapper>
  • 到这一步我们第一个mybatis实现查询就基本大功告成了，接下来就要编写测试类测试我们写得代码
package com.xiezhr.dao;

import com.xiezhr.pojo.User;
import com.xiezhr.util.MysqlUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

import java.util.List;

public class TestUserDao {
    @Test
    public void selectUser(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> userList = mapper.getUserList();

        for (User user : userList) {
            System.out.println(user);
        }

    }
}

经过测试后输出测试结果

D:\Java\jdk1.8.0_91\bin\java.exe -ea -Didea.test.cyclic.buffer.size=1048576 "-javaagent:D:\JetBrains\IntelliJ IDEA 2019.3.3\lib\idea_rt.jar=54576:D:\JetBrains\IntelliJ IDEA 2019.3.3\bin" -Dfile.encoding=UTF-8 -classpath "D:\JetBrains\IntelliJ IDEA 2019.3.3\lib\idea_rt.jar;D:\JetBrains\IntelliJ IDEA 2019.3.3\plugins\junit\lib\junit5-rt.jar;D:\JetBrains\IntelliJ IDEA 2019.3.3\plugins\junit\lib\junit-rt.jar;D:\Java\jdk1.8.0_91\jre\lib\charsets.jar;D:\Java\jdk1.8.0_91\jre\lib\deploy.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\access-bridge-64.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\cldrdata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\dnsns.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jaccess.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jfxrt.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\localedata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\nashorn.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunec.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunjce_provider.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunmscapi.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunpkcs11.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\zipfs.jar;D:\Java\jdk1.8.0_91\jre\lib\javaws.jar;D:\Java\jdk1.8.0_91\jre\lib\jce.jar;D:\Java\jdk1.8.0_91\jre\lib\jfr.jar;D:\Java\jdk1.8.0_91\jre\lib\jfxswt.jar;D:\Java\jdk1.8.0_91\jre\lib\jsse.jar;D:\Java\jdk1.8.0_91\jre\lib\management-agent.jar;D:\Java\jdk1.8.0_91\jre\lib\plugin.jar;D:\Java\jdk1.8.0_91\jre\lib\resources.jar;D:\Java\jdk1.8.0_91\jre\lib\rt.jar;F:\workspace_idea\Mybatis-test\mybatis-01\target\test-classes;F:\workspace_idea\Mybatis-test\mybatis-01\target\classes;D:\maven\repository\mysql\mysql-connector-java\5.1.46\mysql-connector-java-5.1.46.jar;D:\maven\repository\org\mybatis\mybatis\3.5.2\mybatis-3.5.2.jar;D:\maven\repository\junit\junit\4.12\junit-4.12.jar;D:\maven\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar" com.intellij.rt.junit.JUnitStarter -ideVersion5 -junit4 com.xiezhr.dao.TestUserDao,selectUser
Tue Apr 14 22:54:48 CST 2020 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.
User{id=1, name='张三', pwd='322334'}
User{id=2, name='李四', pwd='123456'}
User{id=3, name='王五', pwd='123456'}

扩展

  • 根据id查询用户
  • 1.在UserMapper接口中添加相应的方法selectUserById(id)
public interface UserMapper {
    //根据ID查询用户
    User selectUserById(int id);
}
  • 2.在UserMapper.xml 中添加相应select 语句
<mapper namespace="com.xiezhr.dao.UserMapper">
    <select id="selectUserById" parameterType="int" resultType="com.xiezhr.pojo.User">
        select * from mybatis.user where id = #{id}
    </select>
</mapper>
  • 3.添加测试类
@Test
    public void selectUserByid(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = mapper.selectUserById(1);
        System.out.println(user);
    }

测试通过

Wed Apr 15 23:08:00 CST 2020 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.
User{id=1, name='张三', pwd='322334'}
  • 根据用户姓名密码查询用户信息
  • 1.在UserMapper接口中添加方法
public interface UserMapper {
    //根据用户名密码查询用户信息
    User selectUserByNP(@Param("name") String name,@Param("pwd") String pwd);
}
  • 2.在UserMapper.xml 中添加select语句
<mapper namespace="com.xiezhr.dao.UserMapper">
    <select id="selectUserByNP" resultType="com.xiezhr.pojo.User">
        select * from mybatis.user where name=#{name} and pwd=#{pwd}
    </select>
</mapper>
  • 3.添加测试类
    @Test
    public void selectUserByNP(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = mapper.selectUserByNP("张三","322334");
        System.out.println(user);
    }

测试成功

Wed Apr 15 23:24:02 CST 2020 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.
User{id=1, name='张三', pwd='322334'}

以上通过用户名和密码查询用户，传参还可以通过万能的map实现，具体代码如下

  • 1.向UserMapper接口中添加方法
public interface UserMapper {
    //根据用户名和密码查询用户信息
    User queryUserByNP(Map<String,Object> map);
}
  • 2.向UserMapper.xml 中添加select语句，其中参数类型为map
<mapper namespace="com.xiezhr.dao.UserMapper">
    <select id="queryUserByNP" parameterType="map" resultType="com.xiezhr.pojo.User">
        select * from mybatis.user where name=#{name} and pwd=#{pwd}
    </select>
</mapper>
  • 添加测试，在使用过程中，map的key对应着UserMapper.xml中取值,map在put值时候没有先后顺序
 @Test
    public void queryUserByNp(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("name","张三");
        map.put("pwd","322334");
        User user = mapper.queryUserByNP(map);
        System.out.println(user);
    }
  • 模糊查询实现
  • 1.在Java代码中添加sql通配符
string wildcardname = “%smi%”;
list<name> names = mapper.selectlike(wildcardname);
<select id=”selectlike”>
select * from foo where bar like #{value}
</select>
  • 2.在sql语句中拼接通配符，会引起sql注入
string wildcardname = “smi”;
list<name> names = mapper.selectlike(wildcardname);
<select id=”selectlike”>
    select * from foo where bar like "%"#{value}"%"
</select>

接下来我们分别来实现insert、update、delete

insert

  • 在之前编写的UserMapper 接口中添加增加方法
public interface UserMapper {
    //添加一条用户信息
    int addUser(User user);
}

2.在UserMapper.xml 中写insert 语句

<insert id="addUser" parameterType="com.xiezhr.pojo.User">
        insert into mybatis.user values(#{id},#{name},#{pwd})
</insert>
  • 添加测试类
    insert、update、delete 一定要提交事务，千万千万不能忘记了
@Test
    public void addUser(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        User user = new User(4, "大头儿子", "123456");
        mapper.addUser(user);
        sqlSession.commit();  //增删改一定要提交事务
        sqlSession.close();
    }

update

  • 在之前编写的UserMapper 接口中添加update方法
public interface UserMapper {
    //修改一条记录
    int updateUserById(int id);
}

2.在UserMapper.xml 中写insert 语句

<update id="updateUserById" parameterType="int">
        update mybatis.user set name='小头爸爸' where id=#{id}
</update>
  • 添加测试类
    insert、update、delete 一定要提交事务，千万千万不能忘记了
    @Test
    public void updateUserById(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        mapper.updateUserById(4);
        sqlSession.commit();  //增删改一定要提交事务
        sqlSession.close();
    }

delete

  • 在之前编写的UserMapper 接口中添加delete方法
public interface UserMapper {
    //根据ID删除一条记录
    int deleteUserById(int id);
}
}

2.在UserMapper.xml 中写insert 语句

<delete id="deleteUserById" parameterType="int">
        delete from mybatis.user where id=#{id}
</delete>
  • 添加测试类
    insert、update、delete 一定要提交事务，千万千万不能忘记了
    @Test
    public void deletUserById(){
        SqlSession sqlSession = MysqlUtil.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        mapper.deleteUserById(4);
        sqlSession.commit();  //增删改一定要提交事务
        sqlSession.close();
    }

注意

  • 所有的insert、update、delete 必须要提交事务
  • 接口中所有的普通参数尽量写上@Param 参数，尤其是多个参数的时候一定要写上
  • 有些时候由于业务需要需要可通过map传值
  • 为了规范在sql配置文件中即本例的UserMapper.xml 中select inset delete update 尽量写上Parameter参数和resultType

可能出现问题说明：Maven静态资源过滤问题

<build>
        <resources>
            <resource>
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
            <resource>
                <directory>src/main/resources</directory>
                <includes>
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
        </resources>
    </build>

在静态资源的过滤中，基本的元素有三种：

  • directory：指定资源所在的目录，这个目录的路径是相对于pom.xml文件；
  • includes：指定要包含哪些文件，其中包括inlcude子节点来指定匹配的模式；
  • excludes：指定要排除哪些文件，其中包括exclude子节点来指定匹配的模式；
  • filtering：指定哪些文件需要过滤，这个过滤的目的是为了替换其中的占位符${}，其中的占位符属性在pom.xml文件中的中指定；

MyBatis是一款优秀的持久层框架，它可以帮助我们简化数据库操作的代码。本文介绍了MyBatis框架的基本概念和使用方法，以及如何使用MyBatis实现增删改查操作。在使用MyBatis进行开发时，需要注意一些细节问题，比如如何处理事务、如何使用Mapper接口等。此外，MyBatis还提供了一些高级特性，比如动态SQL、缓存等，可以帮助我们更加灵活地进行数据库操作。MyBatis是一款非常优秀的持久层框架，值得我们深入学习和使用。

到此这篇关于如何使用MyBatis框架实现增删改查（CRUD）操作的文章就介绍到这了,更多相关mybatis实现增删改查CRUD内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Java实战之在线寄查快递系统的实现

    Java实战之在线寄查快递系统的实现

    这篇文章主要介绍了如何利用Java制作一个在线寄查快递系统，文中采用的技术有java、SpringBoot、FreeMarker、Mysql，需要的可以参考一下
    2022-02-02
  • SpringBoot实现统一封装返回前端结果集的示例代码

    SpringBoot实现统一封装返回前端结果集的示例代码

    在实际项目开发过程中，我们经常将返回数据的基本形式统一为JSON格式的数据。但项目可能是由很多人开发的，所以我们最好将返回的结果统一起来。本文介绍了SpringBoot实现统一封装返回前端结果集的示例代码，需要的可以参考一下
    2022-06-06
  • Java实现多线程中的静态代理模式

    Java实现多线程中的静态代理模式

    静态代理属于设计模式中的代理模式。这篇文章主要介绍了Java实现多线程中的静态代理模式，详细的介绍了静态代理的使用，需要的朋友们下面随着小编来一起学习学习吧
    2021-05-05
  • 解决一个JSON反序列化问题的办法(空字符串变为空集合)

    解决一个JSON反序列化问题的办法(空字符串变为空集合)

    在平时的业务开发中,经常会有拿到一串序列化后的字符串要来反序列化,下面这篇文章主要给大家介绍了如何解决一个JSON反序列化问题的相关资料,空字符串变为空集合,需要的朋友可以参考下
    2024-03-03
  • 在SpringBoot项目中实现给所有请求加固定前缀

    在SpringBoot项目中实现给所有请求加固定前缀

    这篇文章主要介绍了在SpringBoot项目中实现给所有请求加固定前缀，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-02-02
  • 浅谈java里的EL表达式在JSP中不能解析的问题

    浅谈java里的EL表达式在JSP中不能解析的问题

    下面小编就为大家带来一篇浅谈java里的EL表达式在JSP中不能解析的问题。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • JAVA实现读取txt文件内容的方法

    JAVA实现读取txt文件内容的方法

    本篇文章主要介绍了JAVA实现读取txt文件内容的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-01-01
  • JPA之@EnableJpaAuditing注解使用

    JPA之@EnableJpaAuditing注解使用

    这篇文章主要介绍了JPA之@EnableJpaAuditing注解使用，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-12-12
  • jxl操作excel写入数据不覆盖原有数据示例

    jxl操作excel写入数据不覆盖原有数据示例

    网上很多例子，都是用Jxl读或者写excel，本文实现的功能就是将数据源in.xls的第几行第几列数据写入到out.xls的第几行第几列，不覆盖out.xls其他原有的数据。
    2014-03-03
  • Java并发编程ThreadLocalRandom类详解

    Java并发编程ThreadLocalRandom类详解

    这篇文章主要介绍了Java并发编程ThreadLocalRandom类详解，通过提出问题为什么需要ThreadLocalRandom展开详情，感兴趣的朋友可以参考一下
    2022-06-06

最新评论