[MyBatis]-07 增删改(DML)操作

prtyaa 2023-12-27 16:26:19  63094

分类专栏：资讯

事务是操作数据库的最小单元,应该保证一个事物中的sql语句要么同时成功,要么同时不成功

MyBatis 中配置了事务管理器，type 属性设置为JDBC.表示MyBatis采用和原生JDBC相同的事务管理机制

一般mybatis 会关闭自动提交,所以在执行DML操作时需要手动提交

这里就涉及到事务管理(ACID)

谈到事务一般都是以下四点

原子性（Atomicity）

原子性是指事务是一个不可分割的工作单位，事务中的操作要么都发生，要么都不发生。

一致性（Consistency）

事务前后数据的完整性必须保持一致。

隔离性（Isolation）

事务的隔离性是多个用户并发访问数据库时，数据库为每一个用户开启的事务，不能被其他事务的操作数据所干扰，多个并发事务之间要相互隔离。

持久性（Durability）

持久性是指一个事务一旦被提交，它对数据库中数据的改变就是永久性的，接下来即使数据库发生故障也不应该对其有任何影响

提取一个工具类

package com.lin.util;

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 java.io.IOException;

public class MyBatisUtil {
    private static SqlSessionFactory factory = null;
    static {
        try {
            //工厂一个就够了,所以用静态代码块,运行一次就够了
            factory = new SqlSessionFactoryBuilder().build(Resources.getResourceAsStream("mybatis.xml"));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static SqlSession getSession(){
        SqlSession session =null;
        if (factory!=null){//这里openSession默认是false是关闭事务,改为true可开启自动提交
         session = factory.openSession();
    }
        return session;
    }
}

新增INSERT

mapper:

<?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">
<!-- 
	namespace: 命名空间, 可以随意定义, 一般情况下要写全限定路径
	MyBatis管理SQL语句是通过namespace+id来定位的
 -->
<mapper namespace="com.lin.mapper.UserMapper">

<!--新增操作 没有返回类型默认返回数字-->
	<insert id="insUser" parameterType="User">
		insert into tb_user values(default,#{username},#{password})
	</insert>
</mapper>

test类:

package com.lin.test;

import com.lin.pojo.User;
import com.lin.util.MyBatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

public class TestMyBatisDML {
    @Test
    public void insUser(){
        SqlSession session = MyBatisUtil.getSession();
        User user = new User();
        user.setUsername("小强");
        user.setPassword("123");
        int flag = session.insert("com.lin.mapper.UserMapper.insUser", user);
        if (flag>0){
            //成功提交事务
            session.commit();
            System.out.println("SUCCESS");
        }else {
            //失败事务回滚
            session.rollback();
            System.out.println("FAILED");
        }
        //关闭资源
        session.close();
    }
}

更新

<?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">
<!-- 
	namespace: 命名空间, 可以随意定义, 一般情况下要写全限定路径
	MyBatis管理SQL语句是通过namespace+id来定位的
 -->
<mapper namespace="com.lin.mapper.UserMapper">


<!--更新-->
	<update id="updUser" parameterType="User">
		update tb_user set username=#{username} ,password=#{password} where id= #{id}
	</update>

</mapper>

package com.lin.test;

import com.lin.pojo.User;
import com.lin.util.MyBatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

public class TestMyBatisDML {


    @Test
    //更新
    public void updUser(){
        SqlSession session = MyBatisUtil.getSession();
        User user = new User();
        user.setUsername("小小");
        user.setPassword("123");
        user.setId(1);
        int flag = session.update("com.lin.mapper.UserMapper.updUser", user);
        if (flag>0){
            session.commit();
            System.out.println("更新成功");
        }else {
            session.rollback();
            System.out.println("更新失败");
        }
        session.close();
    }
}

删除

<?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">
<!-- 
	namespace: 命名空间, 可以随意定义, 一般情况下要写全限定路径
	MyBatis管理SQL语句是通过namespace+id来定位的
 -->
<mapper namespace="com.lin.mapper.UserMapper">


<!--删除-->
	<delete id="delUser" parameterType="User">
		delete from tb_user where id=#{0}
	</delete>
</mapper>

package com.lin.test;

import com.lin.pojo.User;
import com.lin.util.MyBatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

public class TestMyBatisDML {

    @Test
    //删除
    public void delUser(){
        SqlSession session = MyBatisUtil.getSession();
        int flag = session.delete("com.lin.mapper.UserMapper.delUser", 5);
        if (flag>0){
            session.commit();
            System.out.println("删除成功");
        }else {
            session.rollback();
            System.out.println("删除失败");
        }
        session.commit();
    }
}

网站声明：如果转载，请联系本站管理员。否则一切后果自行承担。

本文链接：https://www.xckfsq.com/news/show.html?id=31592

赞同 0

评论 0 条

[MyBatis]-07 增删改(DML)操作

相关文章

关注我们