Mybatis由浅入深 - 03动态SQL 源码

package com.tiangang; import com.tiangang.dao.MyBatisManager; import com.tiangang.dao.mapper.UserMapper; import com.tiangang.dao.po.User; import org.apache.ibatis.session.SqlSession; import org.junit.Test; import java.util.List; /** * Mybatis由浅入深 - 02 增删改查CRUD：原文链接：https://blog.csdn.net/scm_2008/article/details/126574504 * @author 天罡gg */ public class UserMapperTest02 { @Test public void insertTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行insert User user = new User(); user.setName("天罡666"); user.setAge(28); int rows = mapper.insert(user); System.out.println("受影响行数:" + rows); System.out.println("新插入User:" + user); sqlSession.commit(); } catch (Exception e) { e.printStackTrace(); sqlSession.rollback(); } finally { sqlSession.close(); } } @Test public void updateByIdTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行update User user = new User(); user.setId(2L); user.setName("天罡666"); user.setAge(38); int rows = mapper.updateById(user); System.out.println("受影响行数:" + rows); System.out.println("修改后的User:" + user); sqlSession.commit(); } catch (Exception e) { e.printStackTrace(); sqlSession.rollback(); } finally { sqlSession.close(); } } @Test public void deleteByIdTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行delete int rows = mapper.deleteById(2L); System.out.println("受影响行数:" + rows); sqlSession.commit(); } catch (Exception e) { e.printStackTrace(); sqlSession.rollback(); } finally { sqlSession.close(); } } @Test public void selectByIdTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行select User user = mapper.selectById(1); System.out.println(user); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } @Test public void selectListByNameTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行select List<User> userList = mapper.selectListByName("天罡"); System.out.println(userList); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } @Test public void selectListByNameAgeTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行select List<User> userList = mapper.selectListByNameAge("天罡", 1); System.out.println(userList); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } @Test public void selectByAnyOneColumnTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行select List<User> userList = mapper.selectByAnyOneColumn("name", "=", "天罡666"); System.out.println(userList); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } @Test public void selectAllTest() { // 1. 打开SqlSession SqlSession sqlSession = MyBatisManager.openSession(); try { // 2. 得到UserMapper UserMapper mapper = sqlSession.getMapper(UserMapper.class); // 3. 执行select List<User> userList = mapper.selectAll("age"); System.out.println(userList); } catch (Exception e) { e.printStackTrace(); } finally { sqlSession.close(); } } }