Java后端05（初识MyBatis）

Mybatis

举个小栗子

mybatis配置文件（XML配置文件）

1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
4. <configuration>
6.     <typeAliases>
7.         <package name="com.iweb.entity"/>
8.     </typeAliases>
9.     <environments default="development">
10.         <environment id="development">
11.             <transactionManager type="JDBC"/>
12.             <dataSource type="POOLED">
13.                 <property name="url" value="jdbc:mysql://localhost:3306/iweb?characterEncoding=utf-8"/>
14.                 <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
15.                 <property name="username" value="root"/>
16.                 <property name="password" value="123456"/>
17.             </dataSource>
18.         </environment>
19.     </environments>
20.     <mappers>
21.         <mapper resource="mapper/user.xml"/>
22.     </mappers>
23. </configuration>

复制代码

user.xml（实现增删改查的sql语句）

1. <?xml version="1.0" encoding="UTF-8" ?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
4. <mapper namespace="com.iweb.entity">
5.     <select id="listUser" resultType="User">select * from user</select>
7.     <insert id="addUser" parameterType="User">insert into user values (#{userId},#{username},#{password})</insert>
8.     <delete id="deleteUser" parameterType="String">delete from user where userId = #{userId}</delete>
9.     <update id="updateUser" parameterType="User">update user set username = #{username},password = #{password} where userId = #{userId}</update>
10.     <select id="getUser" parameterType="String" resultType="User">select * from user where userId = #{userId}</select>
12.     <select id="listUserByNameLike" parameterType="String" resultType="User">select * from user where username like concat('%',#{0},'%')</select>
14.     <select id="listUserByIdAndNameLike" parameterType="map" resultType="User">select * from user where userId > #{userId} and username like concat('%',#{username},'%')</select>
15. </mapper>

复制代码

使用做sql查询（Test）

1. public void test1() throws IOException {
2.     private SqlSession sqlSession;
3.     @Before
4.     public void init() throws IOException {
5.         // 输入流读取配置文件信息
6.         String resource = "mybatis-config.xml";
7.         InputStream inputStream = Resources.getResourceAsStream(resource);
8.         // 基于配置文件获取 mybatis 的一级缓存对象
9.         SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
10.         // 基于这个一级缓存，创建一个二级缓存
11.         sqlSession = sqlSessionFactory.openSession();
12.     }
14.     @Test
15.     public void test01(){
16.         // 使用二级缓存实现sql语句调用
17.         List<User> userList = sqlSession.selectList("listUser");
18.         // 遍历集合
19.         for (User user : userList) {
20.             System.out.println(user);
21.         }
22.     }
24.     @Test
25.     public void test02(){
26.         User user = new User("3","robot01","123456");
27.         sqlSession.insert("addUser",user);
28.         // mybatis 需要手动提交缓存
29.         sqlSession.commit();
30.         test01();
31.     }
33.     @Test
34.     public void test03(){
35.         User user = new User();
36.         user.setUserId("3");
37.         sqlSession.delete("deleteUser",user);
38.         sqlSession.commit();
39.         test01();
40.     }
42.     @Test
43.     public void test04(){
44.         User user = sqlSession.selectOne("getUser","2");
45.         System.out.println(user);
46.     }
48.     @Test
49.     public void test05(){
50.         User user = new User("2","HSS","123456");
51.         sqlSession.update("updateUser",user);
52.         sqlSession.commit();
53.         test01();
54.     }
56.     @Test
57.     public void test06(){
58.         List<User> users = sqlSession.selectList("listUserByNameLike","ss");
59.         System.out.println(users);
60.     }
62.     @Test
63.     public void test07(){
64.         Map<String,Object> params = new HashMap<>();
65.         params.put("userId",2);
66.         params.put("username","ss");
67.         List<User> users = sqlSession.selectList("listUserByIdAndNameLike",params);
68.         System.out.println(users);
69.     }
70. }

复制代码

一对多关系查询

配置文件（⭐注意：每一个配置文件都需要在 mybatis-config.xml 中进行注册！！！！！！！！！）

1. <resultMap id="productBean" type="Product">
2.     <id column="productId" property="productId"/>
3.     <result column="productName" property="productName"/>
4.     <result column="price" property="price"/>
5.     <result column="stock" property="stock"/>
6.     <association property="user" javaType="User">
7.         <id column="uId" property="userId"/>
8.         <result column="username" property="username"/>
9.     </association>
10. </resultMap>
12. <select id="listProduct" resultMap="productBean">
13.     select productName,productId,price,stock,u.userId 'uId',username from product left join user u on product.userId = u.userId
14. </select>

复制代码

测试类

1. public class TestMybatis {
2.     private SqlSession sqlSession;
3.     @Before
4.     public void init() throws IOException {
5.         // 输入流读取配置文件信息
6.         String resource = "mybatis-config.xml";
7.         InputStream inputStream = Resources.getResourceAsStream(resource);
8.         // 基于配置文件获取 mybatis 的一级缓存对象
9.         SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
10.         // 基于这个一级缓存，创建一个二级缓存
11.         sqlSession = sqlSessionFactory.openSession();
12.     }
14.     @Test
15.     public void test01(){
16.         List<Product> productList = sqlSession.selectList("listProduct");
17.         for (Product product : productList) {
18.             System.out.println(product);
19.         }
20.     }
21. }

复制代码

动态sql查询

配置文件（⭐注意：每一个配置文件都需要在 mybatis-config.xml 中进行注册！！！！！！！！！）

1. <select id="listProduct" resultType="product">
2.     select * from product
3.     <if test="productName != null">
4.         where productName like concat('%',#{productName},'%')
5.     </if>
6. </select>

复制代码

测试类

1. @Test
2. public void test01(){
3.     List<Product> productList = sqlSession.selectList("listProduct");
4.     for (Product product : productList) {
5.         System.out.println(product);
6.     }
7. }
9. @Test
10. public void test02(){
11.     Map<String,String> params = new HashMap<>();
12.     params.put("productName","1");
13.     List<Product> productList = sqlSession.selectList("listProduct",params);
14.     for (Product product : productList) {
15.         System.out.println(product);
16.     }
17. }

复制代码

多条件查询

1. <select id="listProduct" resultType="Product">
2.     select * from product
3.     <where>
4.         <if test="productName != null">
5.             and productName like concat('%',#{productName},'%')
6.         </if>
7.         <if test="price != 0">
8.             and price > #{price}
9.         </if>
10.     </where>
11. </select>

复制代码

测试类

1. @Test
2. public void test01(){
3.     Map<String,Object> params = new HashMap<>();
4.     params.put("productName","1");
5.     params.put("price",0);
6.     List<Product> productList = sqlSession.selectList("listProduct",params);
7.     for (Product product : productList) {
8.         System.out.println(product);
9.     }
10. }

复制代码

动态sql更新

1. <update id="updateProduct">
2.     update product
3.     <set>
4.         <if test="productName != null">
5.             productName = #{productName},
6.         </if>
7.         <if test="price != null">
8.             price = #{price},
9.         </if>
10.         <if test="stock != null">
11.             stock = #{stock},
12.         </if>
13.     </set>
14.     where productId = #{productId}
15. </update>

复制代码

测试类

1. @Test
2. public void test01(){
3.     Map<String,Object> params = new HashMap<>();
4.     params.put("productId","1");
5.     params.put("productName","product");
6.     params.put("price","10086");
7.     params.put("stock","10000");
8.     sqlSession.update("updateProduct",params);
9.     sqlSession.commit();
10. }

复制代码

when otherwise 标签

1. <mapper namespace="com.iweb.entity">
3.     <select id="listProduct" resultType="Product">
4.         select * from product
5.         <where>
6.             <choose>
7.                 <when test="productName != null">
8.                     and name like concat('%',#{productName},'%')
9.                 </when>
10.                 <when test="price != null">
11.                     and price > #{price}
12.                 </when>
13.                 <otherwise>
14.                     and id > 5
15.                 </otherwise>
16.             </choose>
17.         </where>
18.     </select>
19. </mapper>

复制代码

使用注解方式实现简单的sql

mapper接口文件（一定要注册！！！！！！）

1. /**
2. * 通过接口（底层是java的JDK动态代理）实现 mybatis 调用
3. * 开发人员只需要关心接口，实现类由 mybatis 动态生成
4. * 1. 注解开发方式： 适用于简单场景（注解场景下编写一对多 多对一 或者是动态sql非常麻烦）
5. * 2. xml配置文件开发方式：适用于所有场景（推荐）
6. * @author te9uila
7. * @since 2023/8/5
8. */
9. public interface ProductMapper {
10.     @Insert("insert into product values (#{productId},#{productName},#{price},#{stock},#{userId})")
11.     void add(Product product);
12.     @Delete("delete from product where productId = #{productId}")
13.     void delete(String id);
14.     @Select("select * from product where productId = #{productId}")
15.     Product get(String id);
16.     @Update("update product set productName = #{productName},price = #{price},stock = #{stock} where productId = #{productId}")
17.     int update(Product product);
18.     @Select("select * from product")
19.     List<Product> list();
20. }

复制代码

测试类

1. @Test
2. public void test01(){
3.     ProductMapper productMapper = sqlSession.getMapper(ProductMapper.class);
4.     List<Product> productList = productMapper.list();
5.     System.out.println(productList);
6. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！