【MyBatis】mabatis的CRUD操作

2023-10-11 20:40
文章标签 操作 mybatis crud mabatis

本文主要是介绍【MyBatis】mabatis的CRUD操作,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

【MyBatis】mabatis的CRUD操作

  • 1. OGNL 表达式
  • 2. 增加
  • 3. 删除
  • 4. 更改
  • 5. 查询
  • 6. 用户模糊查询
    • 6.1 第一种配置方法
    • 6.2 第二种配置方式
    • 6.3 #{}与${}的区别

1. OGNL 表达式

它是 apache 提供的一种表达式语言, 全称是:Object Graphic Navigation Language 对象图导航语言。

它是按照一定的语法格式来获取数据的。
语法格式就是使用 #{对象.对象}的方式#{user.username}它会先去找 user 对象,然后在 user 对象中找到 username 属性,并调用getUsername()方法把值取出来。但是我们在 parameterType 属性上指定了实体类名称,所以可以省略 user.而直接写 username

2. 增加

  • 在持久层接口中添加新增方法
package com.siyi.dao;import com.siyi.domain.User;import java.util.List;/*** 用户持久层接口*/
public interface IUSerDao {/*** 保存用户* @param user*/public void saveUser(User user);
}
  • 在用户的映射配置文件中配置
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.siyi.dao.IUSerDao"><!-- 保存用户 --><insert id="saveUser" parameterType="com.siyi.domain.User">insert into user(username,address,sex,birthday) value(#{username},#{address},#{sex},#{birthday});</insert>
</mapper>

细节注意:

  1. parameterType 属性:
    代表参数的类型,因为我们要传入的是一个类的对象,所以类型就写类的全名称。
  2. sql 语句中使用#{}字符:
    它代表占位符, 相当于原来 jdbc 部分所学的?,都是用于执行语句时替换实际的数据。具体的数据是由#{}里面的内容决定的。
  3. #{}中内容的写法:
    由于我们保存方法的参数是 一个 User 对象,此处要写 User 对象中的属性名称。
  • 添加测试类中的测试方法
package com.siyi.test;import com.siyi.dao.IUSerDao;
import com.siyi.domain.QueryVo;
import com.siyi.domain.User;
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 java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;public class MbatisTest {private InputStream in;private SqlSession session;private IUSerDao iuSerDao;@Before//用于在测试方法执行之前执行public void init() throws IOException {//1.读取配置文件生成字节输入流in = Resources.getResourceAsStream("SqlMapConfig.xml");//2.获取SqlSessionFactory对象SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();SqlSessionFactory factory = builder.build(in);//3.获取SqlSession对象session = factory.openSession();//4.获取DAO的代理对象iuSerDao = session.getMapper(IUSerDao.class);}@After//用于在测试方法之后执行public void destroy() throws IOException {//事务提交session.commit();//释放资源session.close();in.close();}/*** 测试保存操作*/@Testpublic void testSave() throws IOException {User user = new User();user.setUsername("私忆一秒钟");user.setAddress("中国四川");user.setSex("男");user.setBirthday(new Date());System.out.println(user);iuSerDao.saveUser(user);System.out.println(user);}
}

注意:
如果没有添加session.commit();打开 Mysql 数据库发现并没有添加任何记录,原因是什么?
这一点和 jdbc 是一样的,我们在实现增删改时一定要去控制事务的提交,否则可能会出现事务回滚的情况。可以使用:session.commit();来实现事务提交。

  • 新增用户 id 的返回值
    新增用户后, 同时还要返回当前新增用户的 id 值,因为 id 是由数据库的自动增长来实现的,所以就相当于我们要在新增后将自动增长 auto_increment 的值返回。
    <!-- 保存用户 --><insert id="saveUser" parameterType="com.siyi.domain.User"><!-- 配置插入操作后,获取插入数据的id --><selectKey keyProperty="id" keyColumn="id" resultType="Integer" order="AFTER">select last_insert_id();</selectKey>insert into user(username,address,sex,birthday) value(#{username},#{address},#{sex},#{birthday});</insert>

3. 删除

  • 在持久层接口中添加删除方法
package com.siyi.dao;import com.siyi.domain.QueryVo;
import com.siyi.domain.User;import java.util.List;/*** 用户持久层接口*/
public interface IUSerDao {/*** 根据Id删除用户* @param userId*/public void deleteUser(Integer userId);
}
  • 在用户的映射配置文件中配置
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.siyi.dao.IUSerDao"><!-- 删除用户 --><delete id="deleteUser" parameterType="Integer">delete from user where id = #{id}</delete>
</mapper>
  • 加入删除的测试方法
package com.siyi.test;import com.siyi.dao.IUSerDao;
import com.siyi.domain.QueryVo;
import com.siyi.domain.User;
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 java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;public class MbatisTest {private InputStream in;private SqlSession session;private IUSerDao iuSerDao;@Before//用于在测试方法执行之前执行public void init() throws IOException {//1.读取配置文件生成字节输入流in = Resources.getResourceAsStream("SqlMapConfig.xml");//2.获取SqlSessionFactory对象SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();SqlSessionFactory factory = builder.build(in);//3.获取SqlSession对象session = factory.openSession();//4.获取DAO的代理对象iuSerDao = session.getMapper(IUSerDao.class);}@After//用于在测试方法之后执行public void destroy() throws IOException {//事务提交session.commit();//释放资源session.close();in.close();}@Testpublic void testDelete(){iuSerDao.deleteUser(43);}
}

4. 更改

  • 在持久层接口中添加更新方法
package com.siyi.dao;import com.siyi.domain.QueryVo;
import com.siyi.domain.User;import java.util.List;/*** 用户持久层接口*/
public interface IUSerDao {/*** 更新用户* @param user*/public void updateUser(User user);
}
  • 在用户的映射配置文件中配置
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.siyi.dao.IUSerDao"><!-- 更新用户 --><update id="updateUser" parameterType="com.siyi.domain.User">update user set username=#{username},address=#{address},sex=#{sex},birthday=#{birthday} where id=#{id};</update>
</mapper>
  • 加入更新的测试方法
package com.siyi.test;import com.siyi.dao.IUSerDao;
import com.siyi.domain.QueryVo;
import com.siyi.domain.User;
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 java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;public class MbatisTest {private InputStream in;private SqlSession session;private IUSerDao iuSerDao;@Before//用于在测试方法执行之前执行public void init() throws IOException {//1.读取配置文件生成字节输入流in = Resources.getResourceAsStream("SqlMapConfig.xml");//2.获取SqlSessionFactory对象SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();SqlSessionFactory factory = builder.build(in);//3.获取SqlSession对象session = factory.openSession();//4.获取DAO的代理对象iuSerDao = session.getMapper(IUSerDao.class);}@After//用于在测试方法之后执行public void destroy() throws IOException {//事务提交session.commit();//释放资源session.close();in.close();}@Testpublic void testUpadate(){User user = new User();user.setId(42);user.setUsername("siyiyimiaozhong");user.setAddress("中国四川");user.setSex("男");user.setBirthday(new Date());iuSerDao.updateUser(user);}
}

5. 查询

  • 在持久层接口中添加查询方法
package com.siyi.dao;import com.siyi.domain.QueryVo;
import com.siyi.domain.User;import java.util.List;/*** 用户持久层接口*/
public interface IUSerDao {/*** 查询所有用户* @return*/public List<User> findAll();/*** 根据id查询用户信息* @param userId* @return*/public User findById(Integer userId);/*** 查询总用户数* @return*/public int findTotal();
}
  • 在用户的映射配置文件中配置
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.siyi.dao.IUSerDao"><!-- 查询所有 --><select id="findAll" resultType="com.siyi.domain.User">select * from user;</select><!-- 根据id查询用户 --><select id="findById" parameterType="Integer" resultType="com.siyi.domain.User">select * from user where id=#{id}</select><!-- 获取用户的总记录条数 --><select id="findTotal" resultType="Integer">select count(*) from user;</select>
</mapper>
  • resultType 属性:
    用于指定结果集的类型。

  • parameterType 属性:
    用于指定传入参数类型

  • 在测试类添加测试

package com.siyi.test;import com.siyi.dao.IUSerDao;
import com.siyi.domain.QueryVo;
import com.siyi.domain.User;
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 java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;public class MbatisTest {private InputStream in;private SqlSession session;private IUSerDao iuSerDao;@Before//用于在测试方法执行之前执行public void init() throws IOException {//1.读取配置文件生成字节输入流in = Resources.getResourceAsStream("SqlMapConfig.xml");//2.获取SqlSessionFactory对象SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();SqlSessionFactory factory = builder.build(in);//3.获取SqlSession对象session = factory.openSession();//4.获取DAO的代理对象iuSerDao = session.getMapper(IUSerDao.class);}@After//用于在测试方法之后执行public void destroy() throws IOException {//事务提交session.commit();//释放资源session.close();in.close();}@Testpublic void testFindAll() throws IOException {//5.执行查询所有方法List<User> users = iuSerDao.findAll();for (User user : users) {System.out.println(user);}}@Testpublic void testFind(){User user = iuSerDao.findById(42);System.out.println(user);}@Testpublic void testFindTotal(){System.out.println(iuSerDao.findTotal());}
}

6. 用户模糊查询

6.1 第一种配置方法

  • 在持久层接口中添加模糊查询方法
package com.siyi.dao;import com.siyi.domain.QueryVo;
import com.siyi.domain.User;import java.util.List;/*** 用户持久层接口*/
public interface IUSerDao {/*** 根据名称模糊查询用户信息* @return*/public List<User> findByName(String name);
}
  • 在用户的映射配置文件中配置
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.siyi.dao.IUSerDao"><!-- 根据名称模糊查询的语法 --><select id="findByName" parameterType="String" resultType="com.siyi.domain.User">select * from user where username like #{name}</select>
</mapper>
  • 加入模糊查询的测试方法
package com.siyi.test;import com.siyi.dao.IUSerDao;
import com.siyi.domain.QueryVo;
import com.siyi.domain.User;
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 java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;public class MbatisTest {private InputStream in;private SqlSession session;private IUSerDao iuSerDao;@Before//用于在测试方法执行之前执行public void init() throws IOException {//1.读取配置文件生成字节输入流in = Resources.getResourceAsStream("SqlMapConfig.xml");//2.获取SqlSessionFactory对象SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();SqlSessionFactory factory = builder.build(in);//3.获取SqlSession对象session = factory.openSession();//4.获取DAO的代理对象iuSerDao = session.getMapper(IUSerDao.class);}@After//用于在测试方法之后执行public void destroy() throws IOException {//事务提交session.commit();//释放资源session.close();in.close();}@Testpublic void testFindByName(){List<User> users = iuSerDao.findByName("%王%");for (User user : users){System.out.println(user);}}
}

在控制台输出的执行 SQL 语句如下:

我们在配置文件中没有加入%来作为模糊查询的条件,所以在传入字符串实参时,就需要给定模糊查询的标识%。 配置文件中的#{username}也只是一个占位符,所以 SQL 语句显示为“?”。

6.2 第二种配置方式

  • 模糊查询的另一种配置方式。
    第一步: 修改 SQL 语句的配置,配置如下:
    <!-- 根据名称模糊查询的语法 --><select id="findByName" parameterType="String" resultType="com.siyi.domain.User">select * from user where username like '%${value}%' <!--第二种写法参数固定为value--></select>

第二步:测试,如下:

    @Testpublic void testFindByName(){List<User> users = iuSerDao.findByName("王");for (User user : users){System.out.println(user);}}

在控制台输出的执行 SQL 语句如下:

可以发现,我们在程序代码中就不需要加入模糊查询的匹配符%了,这两种方式的实现效果是一样的,但执行的语句是不一样的。这样一看我们当然会选择第一种方法了,第二种方法不常用。

6.3 #{}与${}的区别

* #{}表示一个占位符号
通过#{}可以实现 preparedStatement 向占位符中设置值,自动进行 java 类型和 jdbc 类型转换,
#{}可以有效防止 sql 注入。 #{}可以接收简单类型值或 pojo 属性值。 
如果 parameterType 传输单个简单类型值, #{}括号中可以是 value 或其它名称。* ${}表示拼接 sql 串
通过${}可以将 parameterType 传入的内容拼接在 sql 中且不进行 jdbc 类型转换,${}可以接收简单类型值或 pojo 属性值,如果 parameterType 传输单个简单类型值, ${}括号中只能是 value。

为什么只能${}种只能时value呢?
我们来看下源码:

这就说明了源码中指定了读取的 key 的名字就是”value”,所以我们在绑定参数时就只能叫 value 的名字
了。

这篇关于【MyBatis】mabatis的CRUD操作的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/190679

相关文章

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE

MyBatisPlus如何优化千万级数据的CRUD

《MyBatisPlus如何优化千万级数据的CRUD》最近负责的一个项目,数据库表量级破千万,每次执行CRUD都像走钢丝,稍有不慎就引起数据库报警,本文就结合这个项目的实战经验,聊聊MyBatisPl... 目录背景一、MyBATis Plus 简介二、千万级数据的挑战三、优化 CRUD 的关键策略1. 查

c++中的set容器介绍及操作大全

《c++中的set容器介绍及操作大全》:本文主要介绍c++中的set容器介绍及操作大全,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录​​一、核心特性​​️ ​​二、基本操作​​​​1. 初始化与赋值​​​​2. 增删查操作​​​​3. 遍历方

MySQL追踪数据库表更新操作来源的全面指南

《MySQL追踪数据库表更新操作来源的全面指南》本文将以一个具体问题为例,如何监测哪个IP来源对数据库表statistics_test进行了UPDATE操作,文内探讨了多种方法,并提供了详细的代码... 目录引言1. 为什么需要监控数据库更新操作2. 方法1:启用数据库审计日志(1)mysql/mariad

springboot如何通过http动态操作xxl-job任务

《springboot如何通过http动态操作xxl-job任务》:本文主要介绍springboot如何通过http动态操作xxl-job任务的问题,具有很好的参考价值,希望对大家有所帮助,如有错... 目录springboot通过http动态操作xxl-job任务一、maven依赖二、配置文件三、xxl-

Oracle 数据库数据操作如何精通 INSERT, UPDATE, DELETE

《Oracle数据库数据操作如何精通INSERT,UPDATE,DELETE》在Oracle数据库中,对表内数据进行增加、修改和删除操作是通过数据操作语言来完成的,下面给大家介绍Oracle数... 目录思维导图一、插入数据 (INSERT)1.1 插入单行数据,指定所有列的值语法:1.2 插入单行数据,指

SQL中JOIN操作的条件使用总结与实践

《SQL中JOIN操作的条件使用总结与实践》在SQL查询中,JOIN操作是多表关联的核心工具,本文将从原理,场景和最佳实践三个方面总结JOIN条件的使用规则,希望可以帮助开发者精准控制查询逻辑... 目录一、ON与WHERE的本质区别二、场景化条件使用规则三、最佳实践建议1.优先使用ON条件2.WHERE用

MyBatis ResultMap 的基本用法示例详解

《MyBatisResultMap的基本用法示例详解》在MyBatis中,resultMap用于定义数据库查询结果到Java对象属性的映射关系,本文给大家介绍MyBatisResultMap的基本... 目录MyBATis 中的 resultMap1. resultMap 的基本语法2. 简单的 resul

Mybatis的分页实现方式

《Mybatis的分页实现方式》MyBatis的分页实现方式主要有以下几种,每种方式适用于不同的场景,且在性能、灵活性和代码侵入性上有所差异,对Mybatis的分页实现方式感兴趣的朋友一起看看吧... 目录​1. 原生 SQL 分页(物理分页)​​2. RowBounds 分页(逻辑分页)​​3. Page