阿里云-云小站(无限量代金券发放中)
【腾讯云】云服务器、云数据库、COS、CDN、短信等热卖云产品特惠抢购

MyBatis基于DAO实现CRUD

208次阅读
没有评论

共计 17515 个字符,预计需要花费 44 分钟才能阅读完成。

1、根据 id 查询

1.1、修改 IUserDao.java 文件

package com.tianyi.dao;
import com.tianyi.javabean.User;
import java.util.List;
public interface IUserDao {List<User> findAll();
User findById(Integer uid);
}

1.2、修改 IUserDao.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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
</mapper>

注:

resultType 属性: 用于指定结果集的类型。
**parameterType 属性:** 用于指定传入参数的类型。

sql 语句中使用 #{}字符:
它代表占位符,相当于原来 jdbc 部分所学的?,都是用于执行语句时替换实际的数据。
具体的数据是由 #{}里面的内容决定的。

#{}中内容的写法:

由于数据类型是基本类型,所以此处可以随意写。

1.3、编写测试类 MbTest1.java

package com.tianyi.test;
import com.tianyi.dao.IUserDao;
import com.tianyi.javabean.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.InputStream;
public class MbTest1 {private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindOne() {//6. 执行操作
User user = userDao.findById(1);
System.out.println(user);
}
@Before
// 在测试方法执行之前执行
public void init()throws Exception {//1. 读取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2. 创建构建者对象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3. 创建 SqlSession 工厂对象
factory = builder.build(in);
// 4. 创建 SqlSession 对象
session = factory.openSession();
//5. 创建 Dao 的代理对象
userDao = session.getMapper(IUserDao.class);
}
@After// 在测试方法执行完成之后执行
public void destroy() throws Exception{session.commit();
//7. 释放资源
session.close();
in.close();}
}

单元测试导包

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>

注意:

执行测试时出现:不再支持源选项 1.5。请使用 1.6 或更高版本。

在 pom.xml 加入

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.9</maven.compiler.source>
<maven.compiler.target>1.9</maven.compiler.target>
</properties>

2、保存操作

2.1、修改 IUserDao.java 文件

package com.tianyi.dao;
import com.tianyi.javabean.User;
import java.util.List;
public interface IUserDao {List<User> findAll();
User findById(Integer uid);
int addUser(User user);
}

2.2、修改 IUserDao.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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
<insert id="addUser" parameterType="com.tianyi.javabean.User" >
insert into user(username,birthday,sex,address)values(#{username},#{birthday},#{sex},#{address})
</insert>
</mapper>

注:

{}中内容的写法:

由于我们保存方法的参数是 一个 User 对象,此处要写 User 对象中的属性名称。它用的是 ognl 表达式。

ognl 表达式:
它是 apache 提供的一种表达式语言,全称是:Object Graphic Navigation Language 对象图导航语言, 它是按照一定的语法格式来获取数据的。

语法格式就是使用 #{对象. 对象}的方式

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

2.3、修改 MbTest1.java 文件

package com.tianyi.test;
import com.tianyi.dao.IUserDao;
import com.tianyi.javabean.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.InputStream;
import java.util.Date;
public class MbTest1 {private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindOne() {//6. 执行操作
User user = userDao.findById(1);
System.out.println(user);
}
@Test
public void testAddUser(){// 增加操作
User user=new User();
user.setUsername("王小红");
user.setBirthday(new Date());
user.setAddress("北京昌平");
user.setSex("女");
System.out.println("保存前:"+user);
userDao.addUser(user);
System.out.println("保存后:"+user);
}
@Before
// 在测试方法执行之前执行
public void init()throws Exception {//1. 读取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2. 创建构建者对象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3. 创建 SqlSession 工厂对象
factory = builder.build(in);
// 4. 创建 SqlSession 对象
session = factory.openSession();
//5. 创建 Dao 的代理对象
userDao = session.getMapper(IUserDao.class);
}
@After// 在测试方法执行完成之后执行
public void destroy() throws Exception{session.commit();
//7. 释放资源
session.close();
in.close();}
}

2.4、设置新增加记录 id 返回值

<?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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
<insert id="addUser" parameterType="com.tianyi.javabean.User" >
<selectKey keyColumn="id" keyProperty="id" resultType="java.lang.Integer" >
select last_insert_id()
</selectKey>
insert into user(username,birthday,sex,address)values(#{username},#{birthday},#{sex},#{address});
</insert>
</mapper>

注:

selectKey 标签表示子查询中主键的提取问题
keyColumn 表示查询语句返回结果的列名
SELECT LAST_INSERT_ID():得到刚 insert 进去记录的主键值,只适用与自增主键
keyProperty:将查询到主键值设置到 parameterType 指定的对象的那个属性
order:SELECT LAST_INSERT_ID() 执行顺序,相对于 insert 语句来说它的执行顺序(after,before)
resultType:指定 SELECT LAST_INSERT_ID() 的结果类型

3、用户更新

3.1、修改 IUserDao.java 文件

package com.tianyi.dao;
import com.tianyi.javabean.User;
import java.util.List;
public interface IUserDao {List<User> findAll();
User findById(Integer uid);
int addUser(User user);
int updateUser(User user);
}

3.2、修改 IUserDao.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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
<insert id="addUser" parameterType="com.tianyi.javabean.User" >
<selectKey keyColumn="id" keyProperty="id" resultType="java.lang.Integer" >
select last_insert_id()
</selectKey>
insert into user(username,birthday,sex,address)values(#{username},#{birthday},#{sex},#{address});
</insert>
<update id="updateUser" parameterType="com.tianyi.javabean.User">
update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} where id=#{id}
</update>
</mapper>

3.3、修改 MbTest1.java 文件

package com.tianyi.test;
import com.tianyi.dao.IUserDao;
import com.tianyi.javabean.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.InputStream;
import java.util.Date;
public class MbTest1 {private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindOne() {//6. 执行操作
User user = userDao.findById(1);
System.out.println(user);
}
@Test
public void testAddUser(){User user=new User();
user.setUsername("王小红");
user.setBirthday(new Date());
user.setAddress("北京昌平");
user.setSex("女");
System.out.println("保存前:"+user);
int id=userDao.addUser(user);
System.out.println("保存后:"+user);
System.out.println(user.getId());
}
@Test
public void updateUser(){User user=userDao.findById(6);
user.setSex("男");
userDao.updateUser(user);
}
@Before
// 在测试方法执行之前执行
public void init()throws Exception {//1. 读取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2. 创建构建者对象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3. 创建 SqlSession 工厂对象
factory = builder.build(in);
// 4. 创建 SqlSession 对象
session = factory.openSession();
//5. 创建 Dao 的代理对象
userDao = session.getMapper(IUserDao.class);
}
@After// 在测试方法执行完成之后执行
public void destroy() throws Exception{session.commit();
//7. 释放资源
session.close();
in.close();}
}

4、用户删除

4.1、修改 IUserDao.java 文件

package com.tianyi.dao;
import com.tianyi.javabean.User;
import java.util.List;
public interface IUserDao {List<User> findAll();
User findById(Integer uid);
int addUser(User user);
int updateUser(User user);
int deleteUser(Integer uid);
}

4.2、修改 IUserDao.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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
<insert id="addUser" parameterType="com.tianyi.javabean.User" >
<selectKey keyColumn="id" keyProperty="id" resultType="java.lang.Integer" >
select last_insert_id()
</selectKey>
insert into user(username,birthday,sex,address)values(#{username},#{birthday},#{sex},#{address});
</insert>
<update id="updateUser" parameterType="com.tianyi.javabean.User">
update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} where id=#{id}
</update>
<delete id="deleteUser" parameterType="int">
delete from user where id=#{id}
</delete>
</mapper>

4.3、修改 MbTest1.java 文件

package com.tianyi.test;
import com.tianyi.dao.IUserDao;
import com.tianyi.javabean.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.InputStream;
import java.util.Date;
public class MbTest1 {private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindOne() {//6. 执行操作
User user = userDao.findById(1);
System.out.println(user);
}
@Test
public void testAddUser(){User user=new User();
user.setUsername("王小红");
user.setBirthday(new Date());
user.setAddress("北京昌平");
user.setSex("女");
System.out.println("保存前:"+user);
int id=userDao.addUser(user);
System.out.println("保存后:"+user);
System.out.println(user.getId());
}
@Test
public void updateUser(){User user=userDao.findById(6);
user.setSex("男");
int n=userDao.updateUser(user);
System.out.println("n="+n);
}
@Test
public void deleteUser(){int n=userDao.deleteUser(12);
System.out.println("n="+n);
}
@Before
// 在测试方法执行之前执行
public void init()throws Exception {//1. 读取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2. 创建构建者对象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3. 创建 SqlSession 工厂对象
factory = builder.build(in);
// 4. 创建 SqlSession 对象
session = factory.openSession();
//5. 创建 Dao 的代理对象
userDao = session.getMapper(IUserDao.class);
}
@After// 在测试方法执行完成之后执行
public void destroy() throws Exception{session.commit();
//7. 释放资源
session.close();
in.close();}
}

5、用户模糊查询

5.1、修改 IUserDao.java 文件

package com.tianyi.dao;
import com.tianyi.javabean.User;
import java.util.List;
public interface IUserDao {List<User> findAll();
User findById(Integer uid);
int addUser(User user);
int updateUser(User user);
int deleteUser(Integer uid);
List<User> findByName(String username);
}

5.2、修改 IUserDao.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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
<insert id="addUser" parameterType="com.tianyi.javabean.User" >
<selectKey keyColumn="id" keyProperty="id" resultType="java.lang.Integer" >
select last_insert_id()
</selectKey>
insert into user(username,birthday,sex,address)values(#{username},#{birthday},#{sex},#{address});
</insert>
<update id="updateUser" parameterType="com.tianyi.javabean.User">
update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} where id=#{id}
</update>
<delete id="deleteUser" parameterType="int">
delete from user where id=#{id}
</delete>
<select id="findByName" resultType="com.tianyi.javabean.User" parameterType="java.lang.String">
select * from user where username like #{username}
</select>
</mapper>

5.3、修改 MbTest1.java 文件

package com.tianyi.test;
import com.tianyi.dao.IUserDao;
import com.tianyi.javabean.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.InputStream;
import java.util.Date;
import java.util.List;
public class MbTest1 {private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindOne() {//6. 执行操作
User user = userDao.findById(1);
System.out.println(user);
}
@Test
public void testAddUser(){User user=new User();
user.setUsername("王小红");
user.setBirthday(new Date());
user.setAddress("北京昌平");
user.setSex("女");
System.out.println("保存前:"+user);
int id=userDao.addUser(user);
System.out.println("保存后:"+user);
System.out.println(user.getId());
}
@Test
public void updateUser(){User user=userDao.findById(6);
user.setSex("男");
int n=userDao.updateUser(user);
System.out.println("n="+n);
}
@Test
public void deleteUser(){int n=userDao.deleteUser(12);
System.out.println("n="+n);
}
@Test
public void findByName(){List<User> users=userDao.findByName("% 王 %");
for(User u:users){System.out.println(u.getId()+":"+u.getUsername());
}
}
@Before
// 在测试方法执行之前执行
public void init()throws Exception {//1. 读取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2. 创建构建者对象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3. 创建 SqlSession 工厂对象
factory = builder.build(in);
// 4. 创建 SqlSession 对象
session = factory.openSession();
//5. 创建 Dao 的代理对象
userDao = session.getMapper(IUserDao.class);
}
@After// 在测试方法执行完成之后执行
public void destroy() throws Exception{session.commit();
//7. 释放资源
session.close();
in.close();}
}

5.4、模糊查询的另一种配置方式

修改 IUserDao.xml 文件

<select id="findByName" resultType="com.tianyi.javabean.User" parameterType="java.lang.String">
select * from user where username like '%${value}%'
</select>

注:

将原来的 #{}占位符,改成了 ${value}。注意如果用模糊查询的这种写法,那么​{value}的写法就是固定的,不能写成其它名字。

5.5、#{}与 ${}区别

#{}表示一个占位符号

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

6、查询中的函数使用

6.1、修改 IUserDao.java 文件

package com.tianyi.dao;
import com.tianyi.javabean.User;
import java.util.List;
public interface IUserDao {List<User> findAll();
User findById(Integer uid);
int addUser(User user);
int updateUser(User user);
int deleteUser(Integer uid);
List<User> findByName(String username);
int allCount();
}

6.2、修改 IUserDao.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.tianyi.dao.IUserDao">
<!-- 配置查询所有操作 -->
<select id="findAll" resultType="com.tianyi.javabean.User">
select * from user
</select>
<select id="findById" resultType="com.tianyi.javabean.User" parameterType="int">
select * from user where id=#{uid}
</select>
<insert id="addUser" parameterType="com.tianyi.javabean.User" >
<selectKey keyColumn="id" keyProperty="id" resultType="java.lang.Integer" >
select last_insert_id()
</selectKey>
insert into user(username,birthday,sex,address)values(#{username},#{birthday},#{sex},#{address});
</insert>
<update id="updateUser" parameterType="com.tianyi.javabean.User">
update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} where id=#{id}
</update>
<delete id="deleteUser" parameterType="int">
delete from user where id=#{id}
</delete>
<select id="findByName" resultType="com.tianyi.javabean.User" parameterType="java.lang.String">
select * from user where username like '%${value}%'
</select>
<select id="allCount" resultType="int">
select count(*) from user
</select>
</mapper>

6.3、修改 MbTest1.java 文件

package com.tianyi.test;
import com.tianyi.dao.IUserDao;
import com.tianyi.javabean.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.InputStream;
import java.util.Date;
import java.util.List;
public class MbTest1 {private InputStream in ;
private SqlSessionFactory factory;
private SqlSession session;
private IUserDao userDao;
@Test
public void testFindOne() {//6. 执行操作
User user = userDao.findById(1);
System.out.println(user);
}
@Test
public void testAddUser(){User user=new User();
user.setUsername("王小红");
user.setBirthday(new Date());
user.setAddress("北京昌平");
user.setSex("女");
System.out.println("保存前:"+user);
int id=userDao.addUser(user);
System.out.println("保存后:"+user);
System.out.println(user.getId());
}
@Test
public void updateUser(){User user=userDao.findById(6);
user.setSex("男");
int n=userDao.updateUser(user);
System.out.println("n="+n);
}
@Test
public void deleteUser(){int n=userDao.deleteUser(12);
System.out.println("n="+n);
}
@Test
public void findByName(){List<User> users=userDao.findByName("王");
for(User u:users){System.out.println(u.getId()+":"+u.getUsername());
}
}
@Test
public void allCount(){int n=userDao.allCount();
System.out.println(n);
}
@Before
// 在测试方法执行之前执行
public void init()throws Exception {//1. 读取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2. 创建构建者对象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3. 创建 SqlSession 工厂对象
factory = builder.build(in);
// 4. 创建 SqlSession 对象
session = factory.openSession();
//5. 创建 Dao 的代理对象
userDao = session.getMapper(IUserDao.class);
}
@After// 在测试方法执行完成之后执行
public void destroy() throws Exception{session.commit();
//7. 释放资源
session.close();
in.close();}
}

正文完
星哥玩云-微信公众号
post-qrcode
 0
星锅
版权声明:本站原创文章,由 星锅 于2022-06-06发表,共计17515字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。
【腾讯云】推广者专属福利,新客户无门槛领取总价值高达2860元代金券,每种代金券限量500张,先到先得。
阿里云-最新活动爆款每日限量供应
评论(没有评论)
验证码
【腾讯云】云服务器、云数据库、COS、CDN、短信等云产品特惠热卖中