mybatis的CRUD

1.根据 ID 查询:

  在持久层接口中添加 findById 方法

    User findById(Integer userId);

  在用户的映射配置文件中配置

    <select id="findById" resultType="com.fgy.domain.User" parameterType="int">
      select * from user where id = #{uid}
    </select>
    细节:
      resultType 属性:用于指定结果集的类型
      parameterType 属性:用于指定传入参数的类型

      sql 语句中使用 #{} 字符代表占位符,具体的数据是由 #{} 里面的内容决定

      #{} 中内容的写法:由于数据类型是基本类型,所以此处可以随意写
  测试:

public class UserDaoTest {

    private InputStream in;
    private SqlSession session;
    private UserDao userDao;

    @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接口的代理对象
        userDao = session.getMapper(UserDao.class);
    }

    @After
    public void destory() throws IOException {
        // 6.释放资源
        session.close();
        in.close();
    }

    @Test
    public void testFindById() {
        // 5.执行dao中的方法
        User user = userDao.findById(1);
        System.out.println(user);
    }
}

2.保存操作:

  在持久层接口中添加新增方法

    int saveUser(User user);

  在用户的映射配置文件中配置

    <insert id="saveUser" parameterType="com.fgy.domain.User">
      insert into user(username,birthday,sex,address)
        values(#{username},#{birthday},#{sex},#{address})
    </insert>
  细节:
    parameterType 属性:代表参数的类型,因为要传入的是一个类的对象,所以类型就写类的全名称。
    sql 语句中使用 #{} 字符:代表占位符,具体的数据是由 #{} 里面的内容决定
    #{}中内容的写法:由于保存方法的参数是 一个 User 对象,此处要写 User 对象中的属性名称。
      用的是 ognl 表达式,ognl 表达式是 apache 提供的一种表达式语言,全称是:Object Graphic Navigation Language 对象图导航语言

      它是通过对象的取值方法来获取数据。在写法上把get给省略了。
        比如:我们获取用户的名称
        类中的写法:user.getUsername();
        OGNL表达式写法:user.username

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

  测试:

@Test
public void testSave(){
  User user = new User();
  user.setUsername("lily");
  user.setAddress("广州");
  user.setSex("男");
  user.setBirthday(new Date());
  // 5.执行保存方法
  userDao.saveUser(user);
}

打开 Mysql 数据库发现并没有添加任何记录,原因是什么?
这一点和 jdbc 是一样的,我们在实现增删改时一定要去控制事务的提交,那么在 mybatis 中如何控制事务提交呢?
可以使用:session.commit();来实现事务提交。加入事务提交后的代码如下:
@After
public void destroy() throws Exception{
  session.commit();
  //7.释放资源
  session.close();
  in.close();
}

  新增用户 id 的返回值

    新增用户后,同时还要返回当前新增用户的 id 值,因为 id 是由数据库的自动增长来实现的,所以就相当于我们要在新增后将自动增长 auto_increment 的值返回。

    <insert id="saveUser" parameterType="com.fgy.domain.User">
      <!-- 配置保存时获取插入的 id  order:AFTER插入之后,BEFORE插入之前 -->
      <selectKey keyColumn="id" keyProperty="id" resultType="int" order="AFTER">
        select last_insert_id();
      </selectKey>
      insert into user(username,birthday,sex,address)
      values(#{username},#{birthday},#{sex},#{address})
    </insert>

3.用户更新

  在持久层接口中添加更新方法

    void updateUser(User user);

  在用户的映射配置文件中配置

    <update id="updateUser" parameterType="com.fgy.domain.User">
      update user set username=#{username},birthday=#{birthday},sex=#{sex},
      address=#{address} where id=#{id}
    </update>

  测试:   

    @Test
    public void testUpdateUser()throws Exception{
      // 1.根据 id 查询
      User user = userDao.findById(1);
      // 2.更新操作
      user.setAddress("北京");
      userDao.updateUser(user);
    }

4.用户删除

  在持久层接口中添加删除方法

    void deleteUser(Integer userId);

  在用户的映射配置文件中配置 

    <delete id="deleteUser" parameterType="java.lang.Integer">
      delete from user where id = #{uid}
    </delete>

  测试:   

    @Test
    public void testDeleteUser() throws Exception {
      userDao.deleteUser(2);
    }

5.用户模糊查询

  在持久层接口中添加模糊查询方法

    List<User> findByName(String username);

  在用户的映射配置文件中配置

    <select id="findByName" resultType="com.fgy.domain.User" parameterType="String">
      select * from user where username like #{username}
    </select>

  测试:   

    @Test
    public void testFindByName(){

      // 5.执行查询一个方法
      List<User> users = userDao.findByName("%小%");
      for(User user : users){
        System.out.println(user);
      }
    }

  模糊查询的另一种配置方式(有SQL注入的风险)

    第一步:修改 SQL 语句的配置,配置如下:
      <select id="findByName" parameterType="string" resultType="com.fgy.domain.User">
        select * from user where username like '%${value}%'
      </select>
      将原来的#{}占位符,改成了${value}。注意如果用模糊查询的这种写法,那么${value}的写法就是固定的,不能写成其它名字。
    第二步:测试,如下:
      @Test
      public void testFindByName(){
        // 5.执行查询一个方法
        List<User> users = userDao.findByName("小");
        for(User user : users){
          System.out.println(user);
        }
      }

6.查询使用聚合函数

  在持久层接口中添加查询总记录方法

    int findTotal();

  在用户的映射配置文件中配置

    <select id="findTotal" resultType="int">
      select count(id) from user;

    </select>

  测试:    

  @Test
    public void testFindTotal() throws Exception {
      // 6.执行操作
      int res = userDao.findTotal();
      System.out.println(res);
    }

原文地址:https://www.cnblogs.com/roadlandscape/p/12288893.html