Skip to content

增删改查操作

在映射文件中进行SQL语句的增删改查操作:

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="userMapper">   <!--设置具体的命名空间-->
	<!--插入数据-->
    <insert id="save" parameterType="com.jlc.domain.User">
    	insert into user values(#{id}, #{username}, #{password})
    </insert>
    
    <!--删除数据,根据id进行删除数据-->
    <delete id="delete" parameterType="java.lang.Integer">
    	delete from user where id=#{id}
    </delete>
    
    <!--修改数据-->
    <update id="update" parameterType="com.jlc.domain.User">
    	update user set username=#{username}, password=#{password} where id=#{id}
    </update>
    
    <!--查询操作-->
    <select id="findAll" resultType="com.jlc.domain.User">  
    	select * from user
    </select>
</mapper>
  • 插入操作的注意问题:
    • 插入语句使用insert标签
    • 在映射文件中使用parameterType属性指定要插入的数据类型
    • Sql语句中使用#{实体属性名}方式引用实体中的属性值
  • 删除操作的注意问题:
    • 删除语句使用delete标签
    • Sql语句中使用#{任意字符串}方式引用传递的单个参数
  • 修改操作的注意问题:
    • 修改语句使用update标签

相应的测试代码:

java
package com.jlc.test;

import org.junit.Test;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class MyBatisTest {
    @Test
    public void testAdd() throws IOException {
        // 模拟user对象
        User user = new User();
        user.setUsername("tom");
        user.setPassword("adc");
        
        // 加载核心配置文件  
        InputStream resourceAsStream = Resources.getResourceAsStream("SqlMapConfig.xml");  
        // 获得 sqlSession 工厂对象(会话工厂对象)  
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);  
        // 获得 sqlSession 对象  (通过工厂对象获得会话对象)
        SqlSession sqlSession = sqlSessionFactory.openSession(); 
     
        // 执行 SQL 语句    参数:namespace+id
        // 插入操作
        sqlSession.insert("userMapper.save", user);
        sqlSession.commit();  // 提交事务
        
        // 释放资源  
        sqlSession.close();  
    }
    
    @Test
    public void testDel() throws IOException {    
        // 加载核心配置文件  
        InputStream resourceAsStream = Resources.getResourceAsStream("SqlMapConfig.xml");  
        // 获得 sqlSession 工厂对象(会话工厂对象)  
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);  
        // 获得 sqlSession 对象  (通过工厂对象获得会话对象)
        SqlSession sqlSession = sqlSessionFactory.openSession(); 
     
        // 执行 SQL 语句    参数:namespace+id
        // 删除操作
        sqlSession.delete("userMapper.delete", 3);
        sqlSession.commit();  // 提交事务
        
        // 释放资源  
        sqlSession.close();  
    }
    
    @Test
    public void testUpdate() throws IOException {
        // 模拟user对象
        User user = new User();
        user.setId(3);
        user.setUsername("tom");
        user.setPassword("123");
        
        // 加载核心配置文件  
        InputStream resourceAsStream = Resources.getResourceAsStream("SqlMapConfig.xml");  
        // 获得 sqlSession 工厂对象(会话工厂对象)  
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);  
        // 获得 sqlSession 对象  (通过工厂对象获得会话对象)
        SqlSession sqlSession = sqlSessionFactory.openSession(); 
     
        // 执行 SQL 语句    参数:namespace+id
        // 修改操作
        sqlSession.update("userMapper.uodate", user);
        sqlSession.commit();  // 提交事务
        
        // 释放资源  
        sqlSession.close();  
    }
    
    @Test
    public void testFind() throws IOException {
        // 加载核心配置文件  
        InputStream resourceAsStream = Resources.getResourceAsStream("SqlMapConfig.xml");  
        // 获得 sqlSession 工厂对象(会话工厂对象)  
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);  
        // 获得 sqlSession 对象  (通过工厂对象获得会话对象)
        SqlSession sqlSession = sqlSessionFactory.openSession(); 
     
        // 执行 SQL 语句    参数:namespace+id
        // 查询操作
        List<User> userList = sqlSession.selectList("userMapper.findAll");  
        System.out.println(userList);  
        
        // 释放资源  
        sqlSession.close();  
    }
}

MyBatis默认事务是不提交的,这和原始的JDBC事务是不同的,因此,MyBatis要执行更新操作,需要提交事务sqlSession.commit();

  • 插入操作的注意问题:

    • 插入操作使用的APIsqlSession.insert("命名空间.id", 实体对象);
  • 删除操作的注意问题:

    • 删除操作使用的APIsqlSession.delete("命名空间.id", Object);
  • 修改操作的注意问题:

    • 修改操作使用的APIsqlSession.update("命名空间.id", 实体对象);

Released under the MIT License.