使用MyBatis实现CRUD

MyBatis介绍：

​ mybatis 是一个优秀的基于 java 的持久层框架，它内部封装了 jdbc，使开发者只需要关注 sql 语句本身，而不需要花费精力去处理加载驱动、创建连接、创建 statement 等繁杂的过程。

​ mybatis 通过xml 或注解的方式将执行的各种statement 配置起来，并通过java 对象和statement 中sql的动态参数进行映射生成最终执行的 sql 语句，最后由 mybatis 框架执行 sql并将结果映射为 java 对象并返回。
采用 ORM ( Object relational mapping)思想解决了实体和数据库映射的问题，对jdbc 进行了封装，屏蔽了jdbc api 底层访问细节，使我们不用与 jdbc api打交道，就可以完成对数据库的持久化操作。

ORM ( Object relational mapping)：对象关系映射 javabean–关系型数据库MySQL

​ 通过ORM解决sql语句执行结果映射为java对象 【表中字段–javabean属性 自动完成映射 就要求查询返回的字段和javabean的属性一致。】

​ 官网: http://www.mybatis.org/mybatis-3/

接下来使用MyBatis实现CURD：

环境准备：

添加依赖
pom.xml配置文件：

    4.0.0

    com.Mr_Xu
    dya34
    1.0-SNAPSHOT

    
        
            UTF-8
            1.8
            1.8
        

    
    
        
        
            junit
            junit
            4.12
            test
        
        
        
            org.mybatis
            mybatis
            3.4.6
        
        
        
            mysql
            mysql-connector-java
            5.1.47
        
        
        
            org.projectlombok
            lombok
            1.18.18
        
    

mybatis核心文件配置：

User实体类：

package com.Mr_Xu.bean;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.Date;


@AllArgsConstructor
@NoArgsConstructor
@Data
public class User {
    private Integer uid;
    private String username;
    private String sex;
    private Date birthday;
    private String address;
}

实体类接口：

package com.Mr_Xu.dao;

import com.Mr_Xu.bean.User;

import java.util.List;


public interface UserDao {
    //查询所有用户信息，封装到list集合中
    List findAll();
    int addUser(User user);

    int deleteUser(Integer uid);

    int Update(User user);

    //根据姓氏查询用户列表 方式一：张%  #{}
    List getUserListByName1(String username);

    //根据姓氏查询用户列表 方式二：${value}
    List getUserListByName2(String username);
}

实体类映射文件：

    
    
        SELECT * FROM user
    

    
    
         SELECT * FROM user WHERe username LIKE CONCAt(#{username},'%')
    

    
    
        select * from user where username like '${value}%'
    

    
        insert into user value (null,#{username},#{sex},#{birthday},#{address})
    

    
        delete from user where uid = #{uid}
    

    
        update user set username=#{username},sex=#{sex},address=#{address} where uid=#{uid}
    


 
使用测试方法实现基本CRUD：
 
package com.Mr_Xu;

import com.Mr_Xu.bean.User;
import com.Mr_Xu.dao.UserDao;

import com.Mr_Xu.utils.MyBatisUtils;
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 org.junit.Test;

import java.io.InputStream;
import java.util.Date;
import java.util.List;


public class mybatisTest {

    //添加
    @Test
    public void f2() throws Exception {
        //获得mybatis核心类对象
        InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
        //加载核心配置文件
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        //获得sqlSession对象
        SqlSession SqlSession = sqlSessionFactory.openSession();
        UserDao dao = SqlSession.getMapper(UserDao.class);
        User user = new User();
        user.setUsername("张三");
        user.setSex("男");
        user.setBirthday(new Date());
        user.setAddress("深圳");
        dao.addUser(user);
        SqlSession.commit();

        //释放资源
        SqlSession.close();
    }

    //删除
    @Test
    public void f3() throws Exception {
        //获取mybatis核心对象
        InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        SqlSession sqlSession = sqlSessionFactory.openSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        dao.deleteUser(10   );
        sqlSession.commit();
        sqlSession.close();
    }

    //修改
    @Test
    public void f4() throws Exception {
        InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        SqlSession sqlSession = sqlSessionFactory.openSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        User user = new User(8,"李四","女",new Date(),"北京");
        dao.Update(user);
        sqlSession.commit();
        sqlSession.close();
    }

    //查询
    @Test
    public void f1() throws Exception {
        //得到MyBatis的核心配置文件的文件流
        InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
        //加载MyBatis的核心配置文件 获得SqlSessionFactory对象
        //使用了建造者模式和工厂模式，得到SqlSessionFactory 相当于连接池对象
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        //获得sqlSession对象 相当于Connection对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //获得dao的代理对象  使用了代理模式
        UserDao dao = sqlSession.getMapper(UserDao.class);
        //调用方法操作
        List list = dao.findAll();
        for (User user : list) {
            System.out.println("user = " + user);
        }
        //释放资源
        sqlSession.close();
    }

    //模糊查询,方式1:#{username},'%'
    @Test
    public void f5() throws Exception {
        //得到MyBatis的核心配置文件的文件流
        InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
        //加载MyBatis的核心配置文件 获得SqlSessionFactory对象
        //使用了建造者模式和工厂模式，得到SqlSessionFactory 相当于连接池对象
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        //获得sqlSession对象 相当于Connection对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //获得dao的代理对象  使用了代理模式
        UserDao dao = sqlSession.getMapper(UserDao.class);
        //调用方法操作
        List list = dao.getUserListByName1("张");
        for (User user : list) {
            System.out.println("user = " + user);
        }
        //关闭流
        sqlSession.close();
        is.close();
    }

    //方式二：${value}%
    @Test
    public void f6() throws Exception {
        //获取核心文件流
        InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
        //获取SqlSessionFactory对象
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        //获取SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //调用业务处理
        UserDao dao = sqlSession.getMapper(UserDao.class);
        //获取list集合
        List list = dao.getUserListByName2("z");
        for (User user : list) {
            System.out.println("user = " + user);
        }
        //释放资源
        sqlSession.close();
    }
}
 
提取工具类：
 
package com.Mr_Xu.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;


public class MyBatisUtils {
    private static SqlSessionFactory sqlSessionFactory;
    static {
        try {
            //1.读取MyBatis核心配置文件
            InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
            //2.加载MyBatis配置文件获取 SqlSessionFactory对象
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
        } catch (IOException e) {
            e.printStackTrace();
            System.err.println("加载MyBatis核心配置文件失败！");
        }
    }

    
    public static SqlSession getSqlSession(){
        return sqlSessionFactory.openSession();
    }


    
    public static void getClose(SqlSession sqlSession){
        if (sqlSession != null){
            sqlSession.close();
        }
    }
}


 
使用工具类实现：
 
 //使用工具类改造
    //增加
    @Test
    public void f10() throws Exception {
        //调用dao处理业务
        SqlSession sqlSession = MyBatisUtils.getSqlSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        User user = new User(null,"张三","男",new Date(),"深圳");
        dao.addUser(user);
        //提交事务
        sqlSession.commit();
        //释放资源
        MyBatisUtils.getClose(sqlSession);
    }

    //删除
    @Test
    public void f11(){
        //获得SqlSession对象
        SqlSession sqlSession = MyBatisUtils.getSqlSession();
        //调用业务处理
        UserDao dao = sqlSession.getMapper(UserDao.class);
        dao.deleteUser(8);
        sqlSession.commit();
        //释放资源
        MyBatisUtils.getClose(sqlSession);
    }

    //修改
    @Test
    public void f12(){
        SqlSession sqlSession = MyBatisUtils.getSqlSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        User user = new User(7, "李四", "女", new Date(), "北京");
        dao.Update(user);
        sqlSession.commit();
        MyBatisUtils.getClose(sqlSession);
    }

    //查看
    @Test
    public void f13(){
        SqlSession sqlSession = MyBatisUtils.getSqlSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        List list = dao.findAll();
        for (User user : list) {
            System.out.println("user = " + user);
        }
        sqlSession.commit();
        MyBatisUtils.getClose(sqlSession);
    }

    //模糊查询,方式一：#{username},'%'
    @Test
    public void f14(){
        SqlSession sqlSession = MyBatisUtils.getSqlSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        List list = dao.getUserListByName1("李");
        for (User user : list) {
            System.out.println("user = " + user);
        }
        sqlSession.commit();
        MyBatisUtils.getClose(sqlSession);
    }

    //方式二：${value}%
    @Test
    public void f15(){
        SqlSession sqlSession = MyBatisUtils.getSqlSession();
        UserDao dao = sqlSession.getMapper(UserDao.class);
        List list = dao.getUserListByName2("l");
        for (User user : list) {
            System.out.println("user = " + user);
        }
        sqlSession.commit();
        MyBatisUtils.getClose(sqlSession);
    }




转载请注明：文章转载自 www.mshxw.com
本文地址：https://www.mshxw.com/it/425523.html


   上一篇  冒泡排序 java
 
   下一篇  tomcat加ssl证书
  






Java相关栏目本月热门文章

  
1【Linux驱动开发】设备树详解（二）设备树语法详解
  
2别跟客户扯细节
  
3Springboot+RabbitMQ+ACK机制(生产方确认(全局、局部)、消费方确认)、知识盲区
  
4【Java】对象处理流（ObjectOutputStream和ObjectInputStream）
  
5【分页】常见两种SpringBoot项目中分页技巧
  
6一文带你搞懂OAuth2.0
  
7我要写整个中文互联网界最牛逼的JVM系列教程 | 「JVM与Java体系架构」章节：虚拟机与Java虚拟机介绍
  
8【Spring Cloud】新闻头条微服务项目：FreeMarker模板引擎实现文章静态页面生成
  
9JavaSE - 封装、static成员和内部类
  
10树莓派mjpg-streamer实现监控及拍照功能调试
  
11用c++写一个蓝屏代码
  
12从JDK8源码中看ArrayList和LinkedList的区别
  
13idea 1、报错java: 找不到符号 符号: 变量 log 2、转换成Maven项目
  
14在openwrt使用C语言增加ubus接口（包含C uci操作）
  
15Spring 解决循环依赖
  
16SpringMVC——基于MVC架构的Spring框架
  
17Andy‘s First Dictionary C++ STL set应用
  
18动态内存管理
  
19我的创作纪念日
  
20Docker自定义镜像-Dockerfile







热门相关搜索



路由器设置
木托盘
宝塔面板
儿童python教程
心情低落
朋友圈
vim
双一流学科
专升本
我的学校
日记学校
西点培训学校
汽修学校
情书
化妆学校
塔沟武校
异形模板
西南大学排名
最精辟人生短句
6步教你追回被骗的钱
南昌大学排名
清朝十二帝
北京印刷学院排名
北方工业大学排名
北京航空航天大学排名
首都经济贸易大学排名
中国传媒大学排名
首都师范大学排名
中国地质大学(北京)排名
北京信息科技大学排名
中央民族大学排名
北京舞蹈学院排名
北京电影学院排名
中国戏曲学院排名
河北政法职业学院排名
河北经贸大学排名
天津中德应用技术大学排名
天津医学高等专科学校排名
天津美术学院排名
天津音乐学院排名
天津工业大学排名
北京工业大学耿丹学院排名
北京警察学院排名
天津科技大学排名
北京邮电大学(宏福校区)排名
北京网络职业学院排名
北京大学医学部排名
河北科技大学排名
河北地质大学排名
河北体育学院排名







学习工具
代数计算器
三角函数
解析几何
立体几何


知识解答
教育知识
百科知识
生活知识
常识知识


写作必备
作文大全
作文素材
句子大全

实用范文


关于我们
关于我们
联系我们
网站地图


 
名师互学网交流群


名师互学网客服





名师互学网 版权所有 (c)2021-2022      ICP备案号：晋ICP备2021003244-6号
 






关于我们
文章归档
网站地图
联系我们
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号：晋ICP备2021003244-6号