AI 助理
备案控制台
开发者社区 数据库 文章 正文

79.【Mybatis】（六）

2023-09-22 120
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 79.【Mybatis】

3.Mybaitis的详细流程

4.CRUD

我们可以在工具类创建的时候实现自动提交事务。

设置增删改的时候们就不用手动提交事务了，会自动帮助我们提交事务

package Com.Jsxs.utils;
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;
import java.io.InputStream;
//  SqlSessionFactory---->sqlSession
public class MybatisUtils {
    private static SqlSessionFactory sqlSessionFactory;
    static {
        try {
            String resource = "mybatis-config.xml";
//  第一步:     获取SqlSessionFactory对象
            InputStream inputStream = Resources.getResourceAsStream(resource);
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
//    既然有了sqlSessionFactory,顾名思义,我们就可以从中获得SqlSession的实列了
//    sqlSession完全包含了面向数据库执行SQL命令所需要的所有方法
    public static SqlSession getSqlSession(){
        SqlSession sqlSession = sqlSessionFactory.openSession(true);
        return sqlSession;
    }
}

设置事务的提交在工具类中

(1).通过id和姓名进行查询数据

这里的占位符号，要和Parpam(“”)里的参数相一致。

package Com.Jsxs.Dao;
import Com.Jsxs.pojo.User;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import javax.naming.Name;
import java.util.List;
public interface UserMapper {
    @Select("select *from user")
List<User> getUser();
    @Select("select *from user where id=#{id} and name=#{nam}")
    List<User> getUserByIdName(@Param("id") int id,@Param("nam") String nam);
}

如果是基本数据类型，在使用注解开发的时候我们就添加N个 @Param(“”)

(2).通过引用对象对数据进行插入（不用提交数据了）
@Insert("insert into user values(#{id},#{name},#{password})")
    int addUser(User user);

接口

package Com.Jsxs.Dao;
import Com.Jsxs.pojo.User;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import javax.naming.Name;
import java.util.List;
public interface UserMapper {
    /*
     进行全表信息的查询
     */
    @Select("select *from user")
    List<User> getUser();
    /*
    根据id 和 name 进行字段的查询
     */
    @Select("select *from user where id=#{id} and name=#{name}")
    List<User> getUserByIdName(@Param("id") int id,@Param("name") String nam);
    /*
        通过对象的引用对数据的信息进行操作
     */
  @Insert("insert into user values(#{id},#{name},#{password})")
    int addUser(User user);
}

实现

package Com.Jsxs.Dao;
import Com.Jsxs.pojo.User;
import Com.Jsxs.utils.MybatisUtils;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
import java.util.List;
public class UserDaoTest {
 /**
  * 查询全部的用户信息
     */
    @Test
    public void test(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> user = mapper.getUser();
        for (User user1 : user) {
            System.out.println(user1);
        }
    }
    /*
    *  通过ID Name进行数据的查询
     */
    @Test
    public void test_id_name(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> name = mapper.getUserByIdName(1, "吉士先生");
        for (User user : name) {
            System.out.println(user);
        }
    }
    /*
     随用户进行增加，通过注解的操作
     */
    @Test
    public void test_add(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.addUser(new User(7, "小时候", "123456"));
        if (i>0){
            System.out.println("恭喜您数据进行插入成功!!");
        }
        sqlSession.close();
    }
}

(3).通过引用对象对数据进行修改
@Update("update user set name=#{name},pwd=#{password} where id=#{id}")
    int updateUser(User user);

接口

package Com.Jsxs.Dao;
import Com.Jsxs.pojo.User;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import javax.naming.Name;
import java.util.List;
public interface UserMapper {
    /*
     进行全表信息的查询
     */
    @Select("select *from user")
    List<User> getUser();
    /*
    根据id 和 name 进行字段的查询
     */
    @Select("select *from user where id=#{id} and name=#{name}")
    List<User> getUserByIdName(@Param("id") int id,@Param("name") String nam);
    /*
        通过对象的引用对数据的信息进行操作
     */
  @Insert("insert into user values(#{id},#{name},#{password})")
    int addUser(User user);
  /*
        通过引用对象对数据进行修改
   */
    @Update("update user set name=#{name},pwd=#{password} where id=#{id}")
    int updateUser(User user);
}

实现

@Test
    public void test_update(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.updateUser(new User(1, "是吉士先生", "11111"));
        if (i>0){
            System.out.println("恭喜您，数据进行修改成功!!!");
        }
        sqlSession.close();
    }
}

(4).通过引用对象对数据进行删除
@Delete("delete from user where id=#{id} and name=#{name} and pwd=#{password}")
    int deleteUser(User user);

接口

package Com.Jsxs.Dao;
import Com.Jsxs.pojo.User;
import org.apache.ibatis.annotations.*;
import javax.naming.Name;
import java.util.List;
public interface UserMapper {
    /*
     进行全表信息的查询
     */
    @Select("select *from user")
    List<User> getUser();
    /*
    根据id 和 name 进行字段的查询
     */
    @Select("select *from user where id=#{id} and name=#{name}")
    List<User> getUserByIdName(@Param("id") int id,@Param("name") String nam);
    /*
        通过对象的引用对数据的信息进行操作
     */
  @Insert("insert into user values(#{id},#{name},#{password})")
    int addUser(User user);
  /*
        通过引用对象对数据进行修改
   */
    @Update("update user set name=#{name},pwd=#{password} where id=#{id}")
    int updateUser(User user);
/*
        通过对象引用对数据进行删除
 */
    @Delete("delete from user where id=#{id} and name=#{name} and pwd=#{password}")
    int deleteUser(User user);
}

实现

package Com.Jsxs.Dao;
import Com.Jsxs.pojo.User;
import Com.Jsxs.utils.MybatisUtils;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
import java.util.List;
public class UserDaoTest {
 /**
  * 查询全部的用户信息
     */
    @Test
    public void test(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> user = mapper.getUser();
        for (User user1 : user) {
            System.out.println(user1);
        }
    }
    /*
    *  通过ID Name进行数据的查询
     */
    @Test
    public void test_id_name(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        List<User> name = mapper.getUserByIdName(1, "吉士先生");
        for (User user : name) {
            System.out.println(user);
        }
    }
    /*
     随用户进行增加，通过注解的操作
     */
    @Test
    public void test_add(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.addUser(new User(7, "小时候", "123456"));
        if (i>0){
            System.out.println("恭喜您数据进行插入成功!!");
        }
        sqlSession.close();
    }
    /*
    对用户信息进行修改
     */
    @Test
    public void test_update(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.updateUser(new User(1, "是吉士先生", "11111"));
        if (i>0){
            System.out.println("恭喜您，数据进行修改成功!!!");
        }
        sqlSession.close();
    }
    /*
    对用户信息进行删除的操作
     */
@Test
    public void test_delete(){
        SqlSession sqlSession = MybatisUtils.getSqlSession();
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        int i = mapper.deleteUser(new User(7, "小时候", "123456"));
        if (i>0){
            System.out.println("恭喜您，数据进行删除失败!!");
        }
    }
}


文章标签：
Java
mybatis
数据库连接
吉士先生
目录
相关文章
君临沂
|
小程序 前端开发 网络协议
微信小程序开发之后台数据交互及wxs应用
微信小程序开发之后台数据交互及wxs应用
君临沂
308 0
达芬奇要当程序员
|
Java Shell Docker
Docker启动后怎样运行jar包文件
Docker启动后怎样运行jar包文件
达芬奇要当程序员
600 1
小目标青年
getReader() has already been called for this request
getReader() has already been called for this request
小目标青年
1888 0
getReader() has already been called for this request
Echo_Wish
|
10月前
|
运维 安全 Linux
全面提升系统安全：禁用不必要服务、更新安全补丁、配置防火墙规则的实战指南
全面提升系统安全：禁用不必要服务、更新安全补丁、配置防火墙规则的实战指南
Echo_Wish
446 12
dlwlrma-晴子
|
11月前
|
SQL 缓存 Java
MyBatis系列
MyBatis系列
dlwlrma-晴子
139 4
众所周知
|
11月前
|
缓存 测试技术 Apache
告别卡顿！Python性能测试实战教程，JMeter&Locust带你秒懂性能优化💡
【10月更文挑战第1天】告别卡顿！Python性能测试实战教程，JMeter&Locust带你秒懂性能优化💡
众所周知
263 4
热爱技术的小郑
|
前端开发 Java 应用服务中间件
一文讲明SpringMVC 【爆肝整理一万五千字】
文章提供了一份全面的SpringMVC教程，涵盖了SpringMVC的简介、创建实例、注解、获取请求参数的不同方式、域对象共享数据、视图渲染、RESTful风格、拦截器使用、异常处理以及文件上传下载等内容，并包含了相应的代码示例和测试结果。
热爱技术的小郑
169 1
一文讲明SpringMVC 【爆肝整理一万五千字】
香吧香
|
Java Spring
ApplicationContextAware 的理解和应用
ApplicationContextAware 的理解和应用
香吧香
225 2
游客wkxim4agoo6le
|
SQL HIVE
Hive中collect_list()排序问题详解
笔记
游客wkxim4agoo6le
3664 0
我是廖志伟
|
存储 消息中间件 关系型数据库
解密分布式事务：CAP理论、BASE理论、两阶段提交（2PC）、三阶段提交（3PC）、补偿事务（TCC）、MQ事务消息、最大努力通知
解密分布式事务：CAP理论、BASE理论、两阶段提交（2PC）、三阶段提交（3PC）、补偿事务（TCC）、MQ事务消息、最大努力通知
我是廖志伟
381 0

热门文章

最新文章

  • 1
    殷浩详解DDD：领域层设计规范
  • 2
    ACP认证考试-必须要了解的那点事
  • 3
    PostgreSQL Huge Page 使用建议 - 大内存主机、实例注意
  • 4
    马尔科夫链（Markov Chain, MC）算法详解及Python实现
  • 5
    阿里云虚拟主机HTTPS（HTTP+SSL）加密开通了
  • 6
    从零开始学_JavaScript_系列（一）初步概念、工具选择、简单内容输出、加载js文件
  • 7
    定位网络攻击一例
  • 8
    方向与执行
  • 9
    关于遗留系统维护的讨论
  • 10
    [百度]数组A中任意两个相邻元素大小相差1，在其中查找某个数
  • 1
    《云原生深坑实录：让团队卡壳的不是配置，是底层逻辑盲区》
    28
  • 2
    《ConfigMap热更新失效的深度解剖与重构实践》
    17
  • 3
    【UAV四旋翼的PD控制】使用AscTec Pelican四旋翼无人机的PD控制器研究（Matlab代码实现）
    22
  • 4
    【UAV】【倾斜旋翼六旋翼飞行器】激活多体系统动力学的重力补偿和最优控制研究（Matlab代码实现）
    20
  • 5
    【SVPWM的模型】基于三相VSC的空间矢量PWM方法研究（Simulink仿真实现）
    19
  • 6
    【IMU数据与GPS融合的预积分方法】基于流形的IMU预积分，用于高效的视觉惯性最大后验估计、SE3姿势区分为IMU（Matlab代码实现）
    19
  • 7
    【图像增强】局部对比度增强的CLAHE算法直方图增强研究（Matlab代码实现）
    18
  • 8
    【AC/DC微电网的能源管理策略】微电网仿真模型包括光伏发电机、燃料电池系统、超级电容器和直流侧的电池，包括电压源变换器（VSC），用于将微电网的直流侧与交流侧相连接Simulink仿真实现
    24

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    OSS存储类型概述