【备战春招】第20天 MyBatis框架(MyBatis入门2)
2023/2/27 23:21:03
本文主要是介绍【备战春招】第20天 MyBatis框架(MyBatis入门2),对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
课程名称:Java工程师2022版
课程章节: MyBatis框架
课程讲师:IT老齐 悟空 八戒猪 神思者 Leo
课程内容:MyBatis入门2
一、MyBatis基本使用
1.SqlSessionFactory
SqlSessionFactory是MyBatis的核心对象。
用于初始化MyBatis,创建SqlSession对象。
保证SqlSessionFactory在应用中全局唯一。
2.MyBatis数据查询步骤
首先是创建实体类
然后创建Mapper XML
再然后创建SQL标签
开启驼峰命名映射
新增
SqlSession执行select语句。
经过以上6大步骤就可以实现MyBatis数据查询了。
package com.imooc.mybatis; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; import com.imooc.mybatis.dto.GoodsDTO; import com.imooc.mybatis.entity.Goods; import com.imooc.mybatis.entity.GoodsDetail; import com.imooc.mybatis.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.IOException; import java.io.Reader; import java.sql.Connection; import java.util.*; //JUNIT单元测试类 public class MyBatisTestor { /** * 初始化SqlSessionFactory * @throws IOException */ @Test public void testSqlSessionFactory() throws IOException { //利用Reader加载classpath下的mybatis-config.xml核心配置文件 Reader reader = Resources.getResourceAsReader("mybatis-config.xml"); //初始化SqlSessionFactory对象,同时解析mybatis-config.xml文件 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader); System.out.println("SessionFactory加载成功"); SqlSession sqlSession = null; try { //创建SqlSession对象,SqlSession是JDBC的扩展类,用于与数据库交互 sqlSession = sqlSessionFactory.openSession(); //创建数据库连接(测试用) Connection connection = sqlSession.getConnection(); System.out.println(connection); }catch (Exception e){ e.printStackTrace(); }finally { if(sqlSession != null){ //如果type="POOLED",代表使用连接池,close则是将连接回收到连接池中 //如果type="UNPOOLED",代表直连,close则会调用Connection.close()方法关闭连接 sqlSession.close(); } } } /** * MyBatisUtils使用指南 * @throws Exception */ @Test public void testMyBatisUtils() throws Exception { SqlSession sqlSession = null; try { sqlSession = MyBatisUtils.openSession(); Connection connection = sqlSession.getConnection(); System.out.println(connection); }catch (Exception e){ throw e; } finally { MyBatisUtils.closeSession(sqlSession); } } /** * select查询语句执行 * @throws Exception */ @Test public void testSelectAll() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); List<Goods> list = session.selectList("goods.selectAll"); for(Goods g : list){ System.out.println(g.getTitle()); } }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 传递单个SQL参数 * @throws Exception */ @Test public void testSelectById() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Goods goods = session.selectOne("goods.selectById" , 1603); System.out.println(goods.getTitle()); }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 传递多个SQL参数 * @throws Exception */ @Test public void testSelectByPriceRange() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Map param = new HashMap(); param.put("min",100); param.put("max" , 500); param.put("limt" , 10); List<Goods> list = session.selectList("goods.selectByPriceRange", param); for(Goods g:list){ System.out.println(g.getTitle() + ":" + g.getCurrentPrice()); } }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 利用Map接收关联查询结果 * @throws Exception */ @Test public void testSelectGoodsMap() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); List<Map> list = session.selectList("goods.selectGoodsMap"); for(Map map : list){ System.out.println(map); } }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 利用ResultMap进行结果映射 * @throws Exception */ @Test public void testSelectGoodsDTO() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); List<GoodsDTO> list = session.selectList("goods.selectGoodsDTO"); for (GoodsDTO g : list) { System.out.println(g.getGoods().getTitle()); } }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 新增数据 * @throws Exception */ @Test public void testInsert() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Goods goods = new Goods(); goods.setTitle("测试商品"); goods.setSubTitle("测试子标题"); goods.setOriginalCost(200f); goods.setCurrentPrice(100f); goods.setDiscount(0.5f); goods.setIsFreeDelivery(1); goods.setCategoryId(43); //insert()方法返回值代表本次成功插入的记录总数 int num = session.insert("goods.insert", goods); session.commit();//提交事务数据 System.out.println(goods.getGoodsId()); }catch (Exception e){ if(session != null){ session.rollback();//回滚事务 } throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 更新数据 * @throws Exception */ @Test public void testUpdate() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Goods goods = session.selectOne("goods.selectById", 739); goods.setTitle("更新测试商品"); int num = session.update("goods.update" , goods); session.commit();//提交事务数据 }catch (Exception e){ if(session != null){ session.rollback();//回滚事务 } throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 删除数据 * @throws Exception */ @Test public void testDelete() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); int num = session.delete("goods.delete" , 739); session.commit();//提交事务数据 }catch (Exception e){ if(session != null){ session.rollback();//回滚事务 } throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 预防SQL注入 * @throws Exception */ @Test public void testSelectByTitle() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Map param = new HashMap(); /* ${}原文传值 select * from t_goods where title = '' or 1 =1 or title = '【德国】爱他美婴幼儿配方奶粉1段800g*2罐 铂金版' */ /* #{}预编译 select * from t_goods where title = "'' or 1 =1 or title = '【德国】爱他美婴幼儿配方奶粉1段800g*2罐 铂金版'" */ param.put("title","'' or 1=1 or title='【德国】爱他美婴幼儿配方奶粉1段800g*2罐 铂金版'"); param.put("order" , " order by title desc"); List<Goods> list = session.selectList("goods.selectByTitle", param); for(Goods g:list){ System.out.println(g.getTitle() + ":" + g.getCurrentPrice()); } }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 动态SQL语句 * @throws Exception */ @Test public void testDynamicSQL() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Map param = new HashMap(); param.put("categoryId", 44); param.put("currentPrice", 500); //查询条件 List<Goods> list = session.selectList("goods.dynamicSQL", param); for(Goods g:list){ System.out.println(g.getTitle() + ":" + g.getCategoryId() + ":" + g.getCurrentPrice()); } }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 测试一级缓存 * @throws Exception */ @Test public void testLv1Cache() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Goods goods = session.selectOne("goods.selectById" , 1603); Goods goods1 = session.selectOne("goods.selectById" , 1603); System.out.println(goods.hashCode() + ":" + goods1.hashCode()); }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } try{ session = MyBatisUtils.openSession(); Goods goods = session.selectOne("goods.selectById" , 1603); session.commit();//commit提交时对该namespace缓存强制清空 Goods goods1 = session.selectOne("goods.selectById" , 1603); System.out.println(goods.hashCode() + ":" + goods1.hashCode()); }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 测试二级缓存 * @throws Exception */ @Test public void testLv2Cache() throws Exception { SqlSession session = null; try{ session = MyBatisUtils.openSession(); Goods goods = session.selectOne("goods.selectById" , 1603); System.out.println(goods.hashCode()); }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } try{ session = MyBatisUtils.openSession(); Goods goods = session.selectOne("goods.selectById" , 1603); System.out.println(goods.hashCode()); }catch (Exception e){ throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 一对多对象关联查询 * @throws Exception */ @Test public void testOneToMany() throws Exception { SqlSession session = null; try { session = MyBatisUtils.openSession(); List<Goods> list = session.selectList("goods.selectOneToMany"); for(Goods goods:list) { System.out.println(goods.getTitle() + ":" + goods.getGoodsDetails().size()); } } catch (Exception e) { throw e; } finally { MyBatisUtils.closeSession(session); } } /** * 测试多对一对象关联映射 */ @Test public void testManyToOne() throws Exception { SqlSession session = null; try { session = MyBatisUtils.openSession(); List<GoodsDetail> list = session.selectList("goodsDetail.selectManyToOne"); for(GoodsDetail gd:list) { System.out.println(gd.getGdPicUrl() + ":" + gd.getGoods().getTitle()); } } catch (Exception e) { throw e; } finally { MyBatisUtils.closeSession(session); } } @Test /** * PageHelper分页查询 */ public void testSelectPage() throws Exception { SqlSession session = null; try { session = MyBatisUtils.openSession(); /*startPage方法会自动将下一次查询进行分页*/ PageHelper.startPage(2,10); Page<Goods> page = (Page) session.selectList("goods.selectPage"); System.out.println("总页数:" + page.getPages()); System.out.println("总记录数:" + page.getTotal()); System.out.println("开始行号:" + page.getStartRow()); System.out.println("结束行号:" + page.getEndRow()); System.out.println("当前页码:" + page.getPageNum()); List<Goods> data = page.getResult();//当前页数据 for (Goods g : data) { System.out.println(g.getTitle()); } System.out.println(""); } catch (Exception e) { throw e; } finally { MyBatisUtils.closeSession(session); } } /** * 批量插入测试 * @throws Exception */ @Test public void testBatchInsert() throws Exception { SqlSession session = null; try { long st = new Date().getTime(); session = MyBatisUtils.openSession(); List list = new ArrayList(); for (int i = 0; i < 10000; i++) { Goods goods = new Goods(); goods.setTitle("测试商品"); goods.setSubTitle("测试子标题"); goods.setOriginalCost(200f); goods.setCurrentPrice(100f); goods.setDiscount(0.5f); goods.setIsFreeDelivery(1); goods.setCategoryId(43); //insert()方法返回值代表本次成功插入的记录总数 list.add(goods); } session.insert("goods.batchInsert", list); session.commit();//提交事务数据 long et = new Date().getTime(); System.out.println("执行时间:" + (et - st) + "毫秒"); // System.out.println(goods.getGoodsId()); } catch (Exception e) { if (session != null) { session.rollback();//回滚事务 } throw e; } finally { MyBatisUtils.closeSession(session); } } /** * 10000次数据插入对比测试用例 * @throws Exception */ @Test public void testInsert1() throws Exception { SqlSession session = null; try{ long st = new Date().getTime(); session = MyBatisUtils.openSession(); List list = new ArrayList(); for(int i = 0 ; i < 10000 ; i++) { Goods goods = new Goods(); goods.setTitle("测试商品"); goods.setSubTitle("测试子标题"); goods.setOriginalCost(200f); goods.setCurrentPrice(100f); goods.setDiscount(0.5f); goods.setIsFreeDelivery(1); goods.setCategoryId(43); //insert()方法返回值代表本次成功插入的记录总数 session.insert("goods.insert" , goods); } session.commit();//提交事务数据 long et = new Date().getTime(); System.out.println("执行时间:" + (et-st) + "毫秒"); // System.out.println(goods.getGoodsId()); }catch (Exception e){ if(session != null){ session.rollback();//回滚事务 } throw e; }finally { MyBatisUtils.closeSession(session); } } /** * 批量删除测试 * @throws Exception */ @Test public void testBatchDelete() throws Exception { SqlSession session = null; try { long st = new Date().getTime(); session = MyBatisUtils.openSession(); List list = new ArrayList(); list.add(1920); list.add(1921); list.add(1922); session.delete("goods.batchDelete", list); session.commit();//提交事务数据 long et = new Date().getTime(); System.out.println("执行时间:" + (et - st) + "毫秒"); // System.out.println(goods.getGoodsId()); } catch (Exception e) { if (session != null) { session.rollback();//回滚事务 } throw e; } finally { MyBatisUtils.closeSession(session); } } }
package com.imooc.mybatis.entity; import java.util.List; public class Goods { private Integer goodsId;//商品编号 private String title;//标题 private String subTitle;//子标题 private Float originalCost;//原始价格 private Float currentPrice;//当前价格 private Float discount;//折扣率 private Integer isFreeDelivery;//是否包邮 ,1-包邮 0-不包邮 private Integer categoryId;//分类编号 private List<GoodsDetail> goodsDetails; public Integer getGoodsId() { return goodsId; } public void setGoodsId(Integer goodsId) { this.goodsId = goodsId; } public String getTitle() { return title; } public void setTitle(String title) { this.title = title; } public String getSubTitle() { return subTitle; } public void setSubTitle(String subTitle) { this.subTitle = subTitle; } public Float getOriginalCost() { return originalCost; } public void setOriginalCost(Float originalCost) { this.originalCost = originalCost; } public Float getCurrentPrice() { return currentPrice; } public void setCurrentPrice(Float currentPrice) { this.currentPrice = currentPrice; } public Float getDiscount() { return discount; } public void setDiscount(Float discount) { this.discount = discount; } public Integer getIsFreeDelivery() { return isFreeDelivery; } public void setIsFreeDelivery(Integer isFreeDelivery) { this.isFreeDelivery = isFreeDelivery; } public Integer getCategoryId() { return categoryId; } public void setCategoryId(Integer categoryId) { this.categoryId = categoryId; } public List<GoodsDetail> getGoodsDetails() { return goodsDetails; } public void setGoodsDetails(List<GoodsDetail> goodsDetails) { this.goodsDetails = goodsDetails; } }
goods类
package com.imooc.mybatis.entity; public class Category { private Integer categoryId; private String categoryName; private Integer parentId; private Integer categoryLevel; private Integer categoryOrder; public Integer getCategoryId() { return categoryId; } public void setCategoryId(Integer categoryId) { this.categoryId = categoryId; } public String getCategoryName() { return categoryName; } public void setCategoryName(String categoryName) { this.categoryName = categoryName; } public Integer getParentId() { return parentId; } public void setParentId(Integer parentId) { this.parentId = parentId; } public Integer getCategoryLevel() { return categoryLevel; } public void setCategoryLevel(Integer categoryLevel) { this.categoryLevel = categoryLevel; } public Integer getCategoryOrder() { return categoryOrder; } public void setCategoryOrder(Integer categoryOrder) { this.categoryOrder = categoryOrder; } }
Category类
package com.imooc.mybatis.entity; public class GoodsDetail { private Integer gdId; private Integer goodsId; private String gdPicUrl; private Integer gdOrder; private Goods goods; public Integer getGdId() { return gdId; } public void setGdId(Integer gdId) { this.gdId = gdId; } public Integer getGoodsId() { return goodsId; } public void setGoodsId(Integer goodsId) { this.goodsId = goodsId; } public String getGdPicUrl() { return gdPicUrl; } public void setGdPicUrl(String gdPicUrl) { this.gdPicUrl = gdPicUrl; } public Integer getGdOrder() { return gdOrder; } public void setGdOrder(Integer gdOrder) { this.gdOrder = gdOrder; } public Goods getGoods() { return goods; } public void setGoods(Goods goods) { this.goods = goods; } }
GoodsDetail.java类
课程总结:
1.MyBatis基本使用
这篇关于【备战春招】第20天 MyBatis框架(MyBatis入门2)的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-12-25初学者必备:订单系统资料详解与实操教程
- 2024-12-24内网穿透资料入门教程
- 2024-12-24微服务资料入门指南
- 2024-12-24微信支付系统资料入门教程
- 2024-12-24微信支付资料详解:新手入门指南
- 2024-12-24Hbase资料:新手入门教程
- 2024-12-24Java部署资料
- 2024-12-24Java订单系统资料:新手入门教程
- 2024-12-24Java分布式资料入门教程
- 2024-12-24Java监控系统资料详解与入门教程