做网站网站要找谁,中国十大门窗品牌排行榜前十名,站长收录,文案发布平台Mybatis
JDBC操作数据库的缺点 存在大量的冗余代码。手工创建 Connection、Statement 等#xff0c;效率低下。手工将结果集封装成实体对象。查询效率低#xff0c;没有对数据访问进行优化。 Mybatis框架
简介 MyBatis 本是 apache 的一个开源项目 iBatis, 2010年这个项目由…Mybatis
JDBC操作数据库的缺点 存在大量的冗余代码。手工创建 Connection、Statement 等效率低下。手工将结果集封装成实体对象。查询效率低没有对数据访问进行优化。 Mybatis框架
简介 MyBatis 本是 apache 的一个开源项目 iBatis, 2010年这个项目由 apache software foundation 迁移到了google code并且改名为MyBatis 。2013年11月迁移到Github。 iBatis 一词来源于 “internet” 和 “abatis” 的组合是一个基于Java的持久层框架。iBatis 提供的持久层框架包括 SQL Maps 和 Data Access ObjectsDAOs MyBatis 是一款优秀的持久层框架它支持自定义 SQL、存储过程以及高级映射。MyBatis 免除了几乎所有的 JDBC 代码以及设置参数和获取结果集的工作。MyBatis 可以通过简单的 XML 或注解来配置和映射原始类型、接口和 POJOPlain Ordinary Java Objects普通 Java 对象为数据库中的记录。 Mybatis获取 官网https://mybatis.org/mybatis-3/ Maven配置 dependency
groupIdorg.mybatis/groupId
artifactIdmybatis/artifactId
version3.5.13/version
/dependency使用Mybatis
工程搭建 引入依赖库 dependency
groupIdorg.mybatis/groupId
artifactIdmybatis/artifactId
version3.5.7/version
/dependency
dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.17/version
/dependencyconfig配置文件 在resources目录下创建config.xml 1.配置JDBC环境 2.注册Mapper。 ?xml version1.0 encodingUTF-8 ?
!DOCTYPE configuration PUBLIC -//mybatis.org//DTD Config 3.0//ENhttp://mybatis.org/dtd/mybatis-3-config.dtd
!--MyBatis配置--
!--常用配置标签的先后顺序properties,settings,typeAliases,typeHandlers,plugins,environments,mappers如果配置文件中同时存在这些配置标签它们之间的顺序必须按照上述列表排列--
configuration!--JDBC环境配置选中默认环境--environments defaultdev!--Mysql数据库环境配置--environment iddev!--事务管理这里的JDBC是一个类的别名org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory--transactionManager typeJDBC/!--连接池这里的POOLED也是一个类的别名org.apache.ibatis.datasource.pooled.PooledDataSourceFactory--dataSource typePOOLEDproperty namedriver valuecom.mysql.cj.jdbc.Driver/property nameurl valuejdbc:mysql://localhost:3306/lesson?serverTimezoneAsia/Shanghaiamp;tinyInt1isBitfalse/property nameusername valueroot/property namepassword value123456//dataSource/environment/environments!--Mapper注册--mappers!--注册Mapper文件的所在位置--/mappers
/configuration创建userMapper接口以及接口的映射文件 userMapper: public interface UserMapper {User getUserByUsername(String username);
}userMapper.xml: !--userMapper.xml--
?xml version1.0 encodingUTF-8 ?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//ENhttp://mybatis.org/dtd/mybatis-3-mapper.dtd
!--namespace 所需实现的接口全限定名--
mapper namespacecom.qf.mybatis.mapper.UserMapper!--id表示接口中的方法名resultType表示查询结果每一行数据对应的转换类型--select idgetUserByUsername resultTypecom.qf.mybatis.pojo.User!--#{arg0}表示获取方法参数列表中的第一个参数值--!--#{param1}表示获取方法参数列表中的第一个参数值--SELECT username,password,name,sex FROM user where username#{arg0}/select
/mapper注册Mapper接口 mappers!--注册Mapper文件的所在位置--mapper resourcemapper/userMapper.xml//mappers测试 构建SqlSessionFactory的构建者获取配置文件信息根据配置文件信息构建SqlSessionFactory工厂工厂开启sqlsession会话。 以上是程序性操作 然后从会话中获得接口的代理对象底层是动态代理。 Test
public void getUserByUserNameTest() throws IOException {//构建SqlSessionFactory的构建者SqlSessionFactoryBuilder builder new SqlSessionFactoryBuilder();//获取配置文件信息InputStream is Resources.getResourceAsStream(config.xml);//根据配置信息构建工厂SqlSessionFactory factory builder.build(is);//工厂开启sql会话SqlSession session factory.openSession();//从会话中获得userMapper接口的代理对象原理是动态代理UserMapper userMapper session.getMapper(UserMapper.class);//调用方法User user userMapper.getUserByUsername(zs);System.out.println(user);
}properties文件配置 Mybatis支持properties文件的引入这样做的目的就是为了区分配置不同的文件中描述不同的配置这样方便管理。 在 resources 目录下新建 jdbc.properties 文件: #jdbc.properties
jdbc.driverClassNamecom.mysql.cj.jdbc.Driver
jdbc.urljdbc:mysql://localhost:3306/lesson?characterEncodingutf8tinyInt1isBitfalse
jdbc.usernameroot
jdbc.passwordroot然后在 config.xml 中引入 ?xml version1.0 encodingUTF-8 ?
!DOCTYPE configuration PUBLIC -//mybatis.org//DTD Config 3.0//ENhttp://mybatis.org/dtd/mybatis-3-config.dtd
!--MyBatis配置--
configuration!--引入jdbc.properties文件--properties resourcejdbc.properties/!--JDBC环境配置选中默认环境--environments defaultdev!--Mysql数据库环境配置--environment iddev!--事务管理这里的JDBC是一个类的别名org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory--transactionManager typeJDBC/!--连接池这里的POOLED也是一个类的别名org.apache.ibatis.datasource.pooled.PooledDataSourceFactory--dataSource typePOOLED
!-- property namedriver valuecom.mysql.cj.jdbc.Driver/--
!-- property nameurl valuejdbc:mysql://localhost:3306/lesson?serverTimezoneAsia/Shanghaiamp;tinyInt1isBitfalse/--
!-- property nameusername valueroot/--
!-- property namepassword value123456/--property namediver value${jdbc.driverClassName}/property nameurl value${jdbc.url}/property nameusername value${jdbc.username}/property namepassword value${jdbc.password}//dataSource/environment/environments!--Mapper注册--mappers!--注册Mapper文件的所在位置--mapper resourcemapper/userMapper.xml//mappers
/configuration类型别名 在Mapper接口映射文件userMapper.xml文件中 !--id表示接口中的方法名resultType表示查询结果每一行数据对应的转换类型--select idgetUserByUsername resultTypecom.qf.mybatis.pojo.UserresultType属性配置很繁琐当方法很多的时候开发效率大大降低因此Mybatis提供了为类型定义别名的功能。该功能需要在config.xml中配置 !--配置类型的别名typeAlias方式和package方式只能选择其一--
typeAliases!-- lt;!ndash;配置单个类的别名ndash;gt;--!-- typeAlias typecom.qf.mybatis.pojo.User aliasuser /--!--配置需要取别名的类的包该包中所有类的别名均为类名--package namecom.qf.mybatis.pojo/
/typeAliasesuserMapper.xml: select idgetUserByUsername resultTypeUser日志配置 Mybatis本身有提供日志功能开启日志需要在 config.xml 进行配置 !-- 打印SQL语句 STDOUT_LOGGING是一个类的别名org.apache.ibatis.logging.stdout.StdOutImpl--setting namelogImpl valueSTDOUT_LOGGING/注常用配置标签的先后顺序 properties, settings, typeAliases, typeHandlers, plugins, environments, mappers 如果配置文件中同时存在这些配置标签它们之间的顺序必须按照上述列表排列。 Mybatis增删改查 由于每次实现方法都需要构建SqlSessionFactory的构建者获取配置文件信息根据配置文件信息构建SqlSessionFactory工厂工厂开启sqlsession会话。 因此把这部分封装起来作为工具类 FactoryUtil: public class FactoryUtil {private static SqlSessionFactory factory;static {//构建SqlSessionFactory的构建者SqlSessionFactoryBuilder builder new SqlSessionFactoryBuilder();//获取配置文件信息InputStream is null;try {is Resources.getResourceAsStream(config.xml);//根据配置信息构建工厂factory builder.build(is);} catch (IOException e) {throw new RuntimeException(e);}}public static SqlSession getSqlSession() {return factory.openSession();}
}标签 select idgetUser/
insert idaddUser/
delete iddeleteUser/
update idupdateUser/参数取值 在Mybatis中参数取值有两种方式一种是#{表达式}, 另一种是 **${表达式} ** ; #{表达式} 采用的是JDBC中的预编译来实现因此可以防止SQL注入。 **${表达式} ** 采用的是字符串拼接因此常用在排序字段变化、分组字段变化、查询表名变化等场景。 常用数据类型作为参数 使用arg参数下标或者param参数位置获取参数 如 User getUserByUsername(String username);select idgetUserByUsername resultTypeUserSELECT username,password,name,sex FROM user where username#{arg0}
/selectpublic void getUserByUserNameTest() throws IOException {SqlSession session FactoryUtil.getSqlSession();UserMapper userMapper session.getMapper(UserMapper.class);User user userMapper.getUserByUsername(zs);System.out.println(user);
}实体对象作为参数 使用#{属性名}获取对象属性参数 单个对象 接口方法 int addUser(User user);xml映射 insert idaddUserINSERT into user values (#{username},#{password},#{name},#{sex})
/insertpublic void addUser(){SqlSession session FactoryUtil.getSqlSession();UserMapper userMapper session.getMapper(UserMapper.class);User user new User();user.setName(吉吉);user.setSex(1);user.setUsername(jj);user.setPassword(123456);int i userMapper.addUser(user);try {session.commit();//不提交事务就不会对数据库中的数据进行修改} catch (Exception e) {session.rollback();//如果提交失败回滚事务}System.out.println(i);
}多个对象 int updateUserPassword(User user1,User user2);update idupdateUserPasswordupdate user set password#{arg0.password} where username#{arg1.username}
/updatepublic void updateUser(){SqlSession session FactoryUtil.getSqlSession();UserMapper userMapper session.getMapper(UserMapper.class);User user1 new User();User user2 new User();user1.setUsername(zs);user2.setUsername(ls);user1.setPassword(123456);int i userMapper.updateUserPassword(user1, user2);try {session.commit();} catch (Exception e) {session.rollback();}System.out.println(i);
}Map作为参数 由于Map中存放的数据是通过键值对实现的因此可以将Map当做一个实体类对象来看待。Map中的键就相当于实体类中的属性名Map中的值就相当于实体类中的属性值。因此其取值方式与实体类对象作为参数一样。 int deleteUser(MapString,Object params);delete iddeleteUserDELETE from user where username#{username} and password#{password}
/deletepublic void deleteUser(){SqlSession session FactoryUtil.getSqlSession();UserMapper userMapper session.getMapper(UserMapper.class);MapString, Object params new HashMap();params.put(username,jj);params.put(password,123456);int i userMapper.deleteUser(params);try {session.commit();} catch (Exception e) {session.rollback();}System.out.println(i);
}参数注解 为了方便开发Mybatis对参数提供了注解从而可以给参数指定名称方便在对应的Mapper映射文件中使用 ListUser retrieveUsers(Param(condition)MapString,Object params);select idretrieveUsers resultTypeUserselect * from user where password#{condition.password} and sex#{condition.sex}/selectpublic void retriveUsers(){SqlSession session FactoryUtil.getSqlSession();UserMapper userMapper session.getMapper(UserMapper.class);MapString, Object params new HashMap();params.put(password,321321);params.put(sex,1);ListUser users userMapper.retrieveUsers(params);try {session.commit();} catch (Exception e) {session.rollback();}users.forEach(System.out::println);}主键回填 当保存一条数据时我们需要该数据的IDID生成有两种方式一种是数据库自动生成一种是程序通过编码生成。Mybatis也提供了这两种方式来生成IDID生成后可以设置到给定的属性上这个过程称之为主键回填。 一般采用数据库自动生成的ID而不是程序编码生成的因为程序生成的意义不大无法从数据库中查询。 创建表 -- 创建表
DROP TABLE IF EXISTS score;
CREATE TABLE score (-- 主键自增id bigint(20) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 主键,name varchar(20) NOT NULL COMMENT 姓名,score double(5,2) DEFAULT NULL COMMENT 成绩
) ENGINEInnoDB CHARSETUTF8;对应实体类 Data
public class Score {private long id;private String name;private Double score;}映射文件 ?xml version1.0 encodingUTF-8 ?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//ENhttp://mybatis.org/dtd/mybatis-3-mapper.dtd
mapper namespacecom.qf.mybatis.mapper.ScoreMapperinsert idaddScore!-- selectKey表示选择键 通常都是用于主键回填功能 keyProperty表示回填的值设置到哪个属性上
resultType表示回填的值的数据类型 order表示主键回填的时机 AFTER表示数据保存后 BEFORE表示数据插入之前--selectKey keyPropertyscore.id resultTypelong orderAFTERSELECT LAST_INSERT_ID()/selectKeyINSERT INTO score(name,score)VALUES(#{score.name},#{score.score})/insert
/mapper注册 mapper resourcemapper/scoreMapper.xml/测试 public void addScore(){SqlSession session FactoryUtil.getSqlSession();ScoreMapper mapper session.getMapper(ScoreMapper.class);Score score new Score();score.setName(zs);score.setScore(99.0);int i mapper.addScore(score);try {session.commit();} catch (Exception e) {session.rollback();}System.out.println(i);
}关键点 使用 SELECT LAST_INSERT_ID() 获取自动生成的主键值并将其回填到 score 对象的 id 属性中 结果映射 在SQL查询时我们经常会遇到数据库表中设计的字段名与对应的实体类中的属性名不匹配的情况针对这种情况Mybatis 提供了结果集映射供用户自己实现数据库表中字段与实体类中属性进行匹配。 DROP TABLE IF EXISTS employee;
CREATE TABLE employee(id int NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 员工编号,name varchar(30) NOT NULL COMMENT 姓名,entry_time datetime NOT NULL COMMENT 入职时间,leave_time datetime DEFAULT NULL COMMENT 离职时间
) ENGINEInnoDB CHARSETUTF8;// 创建实体类 员工
public class Employee {private long id;private String name;private Date entryTime;private Date leaveTime;//省略getter和setter//构造方法要么无参要么全参
}// 创建Mapper接口
public interface EmployeeMapper {ListEmployee getAllEmployees();
}?xml version1.0 encodingUTF-8 ?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//ENhttp://mybatis.org/dtd/mybatis-3-mapper.dtd
mapper namespacecom.qf.mybatis.mapper.EmployeeMapperresultMap idempMap typecom.qf.mybatis.model.Employeeid propertyid columnid /result propertyname columnname /!--数据表中列名与实体类中的属性名匹配--result propertyentryTime columnentry_time /!--数据表中列名与实体类中的属性名匹配--result propertyleaveTime columnleave_time //resultMapselect idgetAllEmployees resultMapempMapSELECT id,name,entry_time,leave_time FROM employee/select
/mapper也可以直接对表中字段重命名。 Mybatis级联查询
1. 一对一级联查询 创建签证表和乘客表其中一个乘客有多个签证而一个签证只对应一个乘客 DROP TABLE IF EXISTS passenger;
CREATE TABLE passenger (id bigint NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 乘客编号,name varchar(50) NOT NULL COMMENT 姓名,sex tinyint(1) NOT NULL DEFAULT 0 COMMENT 性别,birthday date NOT NULL COMMENT 生日
) ENGINEInnoDB CHARSETUTF8;DROP TABLE IF EXISTS passport;
CREATE TABLE passport (id bigint NOT NULL AUTO_INCREMENT COMMENT 护照编号,office varchar(50) NOT NULL COMMENT 签证机关,valid_time tinyint NOT NULL COMMENT 有效期限,nationality varchar(50) NOT NULL COMMENT 国籍,passenger_id bigint NOT NULL COMMENT 乘客编号,PRIMARY KEY (id),FOREIGN KEY (passenger_id) REFERENCES passenger (id)
) ENGINEInnoDB CHARSETUTF8;创建对应的实体类属性名采用驼峰命名法 Data
public class Passenger {private long id;private String name;private int sex;private Date birthday;}//----------------------------------------------------
Data
public class Passport {private long id;private String nationality;private int validTime;private String office;private Passenger passenger;
} 现在要通过查询签证表的同时查询出乘客表 因此要写是PassportMapper接口其中的方法为获取所有签证对象 public interface PassportMapper {ListPassport getAllPassports();
}然后写映射文件因为是通过查询签证表查到乘客表的一对一级联所以只用写签证表的映射文件。 方式一 签证表的passenger字段和乘客表的id字段由一个参数passengerId进行连接先查passport表然后将参数作为索引查passenger表. 因此要写PassengerMapper接口其中的方法为获取所有乘客对象。 public interface PassengerMapper {ListPassenger getPassengers();
}映射文件 ?xml version1.0 encodingUTF-8 ?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//ENhttp://mybatis.org/dtd/mybatis-3-mapper.dtd
mapper namespacecom.qf.mybatis.mapper.PassportMapperresultMap idpassportMap typePassport!--查询单张表可以只写实体类属性和数据库字段名不同的部分--result propertyvalidTime columnvalid_time/!--一对一的级联查询使用的是association标签--!--级联查询也支持传递参数传递参数需要通过column属性来传递定义参数的语法{参数名列名,...,参数名n列名n}--association propertypassenger column{passengerId passenger_id} selectgetPassengers//resultMapselect idgetAllPassports resultMappassportMapselect * from passport/selectselect idgetPassengers resultTypePassengerselect * from passenger where id#{passengerId}/select
/mapper 方式二 将两个表连接起来查询连接后的表 注意在查询复杂关系的表的时候需要在结果映射中将所有属性和数据字段名都写出来 mapper namespacecom.qf.mybatis.mapper.PassportMapperresultMap idpassportMap typePassportid columnid propertyid /result columnnationality propertynationality /result columnoffice propertyoffice /result columnvalid_time propertyvalidTime /association propertypassenger javaTypepassengerid columnpassengerId propertyid /result columnname propertyname /result columnsex propertysex /result columnbirthday propertybirthday //association/resultMapselect idgetAllPassports resultMappassportMapselect a.id,a.nationality,a.office,a.valid_time,b.id passengerId,b.name,b.sex,b.birthday from passport a inner join passenger b on a.passenger_id b.id/select
/mapper2. 一对多级联查询 association改为collection 创建班级表和学生表 DROP TABLE IF EXISTS class;
CREATE TABLE class (id int NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 班级编号,name varchar(50) NOT NULL COMMENT 名称
) ENGINEInnoDB CHARSETUTF8;DROP TABLE IF EXISTS student;
CREATE TABLE student (id bigint NOT NULL AUTO_INCREMENT COMMENT 学号,name varchar(50) NOT NULL COMMENT 姓名,class_id int NOT NULL COMMENT 班级编号,PRIMARY KEY (id),FOREIGN KEY (class_id) REFERENCES class (id)
) ENGINEInnoDB CHARSETUTF8;public class Student {private long id;private String name;
}
public class Clazz {private int id;private String name;private ListStudent students; //集合作为属性
}public interface ClazzMapper {ListClazz getClazzList();
}方式一查询两次 因此还需要StudentMapper接口 public interface StudentMapper {ListStudent getStudents();
}映射文件 mapper namespacecom.qf.mybatis.mapper.ClazzMapperresultMap idclazzMap typeClazzid propertyid columnid/result propertyname columnname/!--一对多 级联 方式--collection propertystudents selectgetStudents column{sidid}//resultMapselect idgetClazzList resultMapclazzMapselect * from class/selectselect idgetStudents resultTypeStudentselect * from student where class_id #{sid}/select/mapper方式二 查询两个表的连接表 mapper namespacecom.qf.mybatis.mapper.ClazzMapperresultMap idclazzMap typeClazzid columnid propertyid/result columnname propertyname/collection propertystudents ofTypeStudentid columnsid propertyid/result columnsname propertyname//collection/resultMapselect idgetClazzList resultMapclazzMapselecta.id,a.name,b.id sid,b.name snamefrom class a inner join student bon a.idb.class_id/select
/mapper注意重复的名字需要重命名。 3.RBAC权限模型查询
RBAC权限模型介绍 RBACRole Based Access Control基于角色的访问控制就是用户通过角色与权限进行关联而不是直接将权限赋予用户。 如现在有以下表 数据表
用户表
username varchar(50) primary key
password varchar(200)
name varchar(50)角色表
id int(11) primary key auto_increment
name varchar(50)用户角色表
username varchar(50)
role_id int(11)菜单表
id int(11) primary key auto_increment
name varchar(50)
parent_id int(11)角色菜单表
role_id int(11)
menu_id int(11)关系如下 RBAC模型中用户与角色之间、角色与权限之间一般是多对多的关系。 现在有一个需求根据用户查询到对应的菜单。 这里采用非级联查询和级联查询均采用查询一次的方式 实体类 Data
public class User {private String username;private String password;private String name;private ListMenu menus;
}
//----------------------------------
Data
public class Menu {private int id;private String name;
}非级联查询 接口方法 ListMenu getMenus(String username);映射文件 resultMap idmenuMap typeMenuid columnmid propertyid/result columnmname propertyname/
/resultMap
select idgetMenus resultMapmenuMapselect m.id mid,m.name mname from menu m join role_menu rm on m.idrm.menu_idjoin roles r on rm.role_idr.idjoin user_role ur on r.idur.role_idjoin user u on ur.username u.usernamewhere u.username#{username}
/select测试 Test
public void getMenusByUsername() throws IOException {SqlSession session getSession();UserMapper mapper session.getMapper(UserMapper.class);ListMenu menus mapper.getMenus(jj);try {session.commit();} catch (Exception e) {session.rollback();}menus.forEach(System.out::println);
}private SqlSession getSession() throws IOException {SqlSessionFactoryBuilder builder new SqlSessionFactoryBuilder();InputStream is Resources.getResourceAsStream(config.xml);SqlSessionFactory factory builder.build(is);SqlSession session factory.openSession();return session;
}级联查询 接口方法 ListUser getUsers();映射文件 resultMap iduserMap typeUserid propertyusername columnusername/result propertypassword columnpassword/result propertyname columnuname/result propertysex columnsex/collection propertymenus ofTypeMenuid propertyid columnid/result propertyname columnmname/result propertyparentId columnparent_id//collection
/resultMapselect idgetUsers resultMapuserMapselect u.username,u.password,u.name uname,m.id,m.name mnamefrom user uleft join user_role ur on u.username ur.usernameleft join roles r on ur.role_id r.idleft join role_menu rm on r.id rm.role_idleft join menu m on rm.menu_id m.parent_id
/select测试 Test
public void getMenusByUser() throws IOException {SqlSession session getSession();UserMapper mapper session.getMapper(UserMapper.class);ListUser users mapper.getUsers();try {session.commit();} catch (Exception e) {session.rollback();}users.forEach(System.out::println);
}private SqlSession getSession() throws IOException {SqlSessionFactoryBuilder builder new SqlSessionFactoryBuilder();InputStream is Resources.getResourceAsStream(config.xml);SqlSessionFactory factory builder.build(is);SqlSession session factory.openSession();return session;
}级联查询与非级联查询的区别 级联查询查到的结果是包含其他类的集合作为属性的类这里就是UserUser中含有menu的集合属性因此sql查询中查询的目标含有user表外的其他表的字段内容且这些表之间有连接关系。而非级联查询只能查询当前表中的内容返回的是查询对象的类。 动态SQL
sql标签 将特定的SQL代码封装起来方便进行重用 !--多条SQL都会使用的字段可以使用sql标签来定义使用时通过include标签来引入--
sql idfieldsusername,password,name
/sql
select idgetUser resultTypeUserselect include refidfields/ from user where username#{username}
/selectif标签 满足标签的验证内容时才将标签内的内容拼接至sql语句中 !--if标签--
!--直接在sql语句中插入--
select idgetUserList resultTypeUserselect * from user where 11if testconditions.name!null and conditions.name!and name like concat(%,#{conditions.name},%)/if
/selectwhere标签 代替sql语句中的where可以与if联合使用。当 where 标签内存在查询条件时 where 标签会在SQL代码中添加 WHERE 关键字 当 where 标签内不不存在查询条件时 where 标签将忽略 WHERE 关键字的添加。除此之外where 标签还将自动忽略其后的 AND 或者 OR 关键字。 select idgetUserList resultTypeUserselect * from user!--where标签会自动添加where并忽略后面的and或者or关键字--whereif testconditions.name!null and conditions.name!and name like concat(%,#{conditions.name},%)/if/where
/selectset标签 代替sql语句中的update xxx set这里的set实现动态更新。 set标签会忽略最后一个sql子句的后缀比如逗号。 update idupdateUserPasswordupdate usersetif testconditions.password!null and conditions.password!password #{conditions.password}/ifwhereif testconditions.username!null and conditions.username! and username #{conditions.username}/if/where/set
/updatetrim标签 Mybatis 提供了 trim 标签来代替 where 标签和 set 标签。 !-- 其中 prefixOverrides 属性表示要被重写的前缀prefix 属性表示用来替换重写的前缀内容。suffix和suffixOvverdides 属性表示对后缀的处理--
trim prefix prefixOverrides suffix suffixOverrides/trimselect idgetScores resultTypescoreSELECT id,name,score FROM scoretrim prefixWHERE prefixOverridesANDif testparams.name ! null and params.name ! AND name LIKE CONCAT(%, #{params.name}, %)/ifif testparams.scoreFrom ! null and params.scoreFrom ! AND score #{params.scoreFrom}/ifif testparams.scoreTo ! null and params.scoreTo ! ![CDATA[AND score #{params.scoreTo}]]/if/trim
/selectupdate idupdateScoreUPDATE scoretrim suffixOverrides, suffixif tests.name ! null and s.name ! name #{s.name},/ifif tests.score ! null and s.score ! score #{s.score},/if/trimwhereif tests.id ! null and s.id ! AND id #{s.id}/if/where
/updateforeach标签 collection表示遍历的元素类型如果参数没有使用注解命名那么该属性值只能是list,array,map其中之一如果参数使用了注解命名那么该属性值直接使用注解指定的名称即可。 item表示每次遍历时使用的对象名 open表示前面添加的内容 close表示最后添加的内容 seperator表示每次遍历时内容组装使用的分割符 index表示遍历时的下标 foreach collection item open seperator close index/foreach例 delete iddeleteUserByUsernamedelete from user where username inforeach collectionusernames itemusername open( separator, close)#{username}/foreach
/deleteMybatis缓存
什么是缓存 缓存是存储在内存中的临时数据将用户经常查询的数据放在缓存内存中用户再次查询数据的时候就不用从磁盘上关系型数据库数据文件查询从缓存中查询能够提高查询效率解决了高并发系统的性能问题。 为什么使用缓存 减少和数据库的交互次数提高效率 缓存的对象 经常查询并且很少改变的数据 一级缓存没用 又名Session缓存简单地说整个缓存的管理都由Session完成开发者不需要做任何的事情这个缓存本身就存在但是这个一级缓存不能跨越Session所以没用。 public void getUserByUserNameTest() throws IOException {SqlSession session FactoryUtil.getSqlSession();//从会话中获得userMapper接口的代理对象原理是动态代理UserMapper userMapper session.getMapper(UserMapper.class);//调用方法userMapper.getUserByUsername(zs);userMapper.getUserByUsername(zs);//清空session中的缓存session.clearCache();userMapper.getUserByUsername(zs);userMapper.getUserByUsername(zs);// System.out.println(user);
}在这个测试中日志中只会打印出两遍sql语句第一遍是第一次调用方法进行查询的时候使用sql语句后session会利用一级缓存将查询结果保存因此再次查询不会再次用sql去查。第二次是由于清空了session中的缓存所以会重新去查询。 二级缓存 能跨越session可以使用mybatis默认的简单的二级缓存 一个简单的、非持久化的内存缓存也可以引入外部缓存库。 使用外部缓存库 导入ehcache-core包和mybatis-ehcache包这是个中间包承上启下用于整合ehcache框架和mybatis.cache框架。 dependencygroupIdnet.sf.ehcache/groupIdartifactIdehcache-core/artifactIdversion2.6.11/version/dependencydependencygroupIdorg.mybatis.caches/groupIdartifactIdmybatis-ehcache/artifactIdversion1.2.1/version/dependency创建ehcache.xml文件不用记只需要根据官方文档改数据就行。这里需要改diskStore中数据在硬盘上的存储位置。 ehcachediskStore pathjava.io.tmpdir/cache namecom.example.MyMappermaxEntriesLocalHeap10000eternalfalsetimeToIdleSeconds300timeToLiveSeconds600overflowToDisktruediskPersistentfalsediskExpiryThreadIntervalSeconds120/cache
/ehcache 然后再配置文件中的settings中需要开启二级缓存 sesstings namecacheEnabled valuetrue/哪个Mapper.xml的查询中需要使用二级缓存就在哪里进行配置 cache typeorg.mybatis.caches.EhcacheCache/cache使用默认的二级缓存 不用导入依赖全局缓存相同 sesstings namecacheEnabled valuetrue/在mapper.xml中 !-- cache标签表示使用缓存flushInterval:表示缓存刷新时间单位是毫秒readyOnly:表示是否只读true 只读MyBatis 认为所有从缓存中获取数据的操作都是只读操作不会修改数据。MyBatis 为了加快获取数据直接就会将数据在缓存中的引用交给用户。不安全速度快。读写(默认)MyBatis 觉得数据可能会被修改size:表示存放多少条数据eviction: 缓存回收策略有这几种回收策略LRU - 最近最少回收移除最长时间不被使用的对象FIFO - 先进先出按照缓存进入的顺序来移除它们SOFT - 软引用移除基于垃圾回收器状态和软引用规则的对象WEAK - 弱引用更积极的移除基于垃圾收集器和弱引用规则的对象--
cache flushInterval300000 readOnlytrue size10000 evictionLRU/测试 Test
public void getUserByUserNameTest() throws IOException {SqlSession session FactoryUtil.getSqlSession();UserMapper userMapper session.getMapper(UserMapper.class);userMapper.getUserByUsername(zs);//需要提交并关闭才能进入二级缓存session.commit();session.close();//------------------------------------------------SqlSession session1 FactoryUtil.getSqlSession();UserMapper userMapper1 session1.getMapper(UserMapper.class);userMapper1.getUserByUsername(zs);session1.commit();session1.close();//这时日志中只有一次sql语句
}注意 二级缓存失效 二级缓存缓存数据的前提是查询的 SqlSession 关闭如果 SqlSession 没有关闭那么数据将不会进入二级缓存再次进行同构查询时二级缓存由于没有数据查询将进入数据库造成二级缓存失效的现象。 另一种情况是当前查询的 SqlSession 已经关闭数据也进入了二级缓存但在下一次查询之前如果中间发生了更新操作该操作更新的数据在的二级缓存中存在那么二级缓存也将失效。 分页插件 PageHelper Mybatis中的拦截器 MyBatis的拦截器可以拦截Executor、ParameterHandler、ResultSetHandler和StatementHandler这四种类型的方法。 1.Executor负责执行SQL语句是MyBatis中最核心的组件之一。它负责管理缓存、执行SQL语句、处理缓存中的数据等。 2.ParameterHandler负责处理SQL语句中的参数将Java对象转换为JDBC Statement所需的参数。 3.ResultSetHandler负责处理SQL查询结果集将JDBC返回的ResultSet对象转换为Java对象。 4.StatementHandler负责处理SQL语句的生成和执行包括SQL语句的预编译、参数设置等操作。 这个插件本质上也是一个拦截器要实现分页就可以拦截Executor中的Query方法然后取出这个SQL语句取出表名通过表名构建统计的SQL语句 **select count(*) from 表名**于是向数据库发送一次请求拿到数据的条目数 total然后取出要查询的页码和每一页数据的个数计算应该从哪里查询查询多少条数据于是构建第二个SQL语句**原来的SQL语句 limit 查询的开始位置查询的条目数**得到查询数据的结果然后将total和数据封装到一个类中进行数据的返回… 使用 导入分页插件的包pagehelper dependencygroupIdcom.github.pagehelper/groupIdartifactIdpagehelper/artifactIdversion5.3.0/version
/dependency配置文件中进行分页插件配置plugins !-- config.xml中进行配置 --
pluginsplugin interceptorcom.github.pagehelper.PageInterceptor/plugin
/plugins测试 Test
public void getAllUsers(){SqlSession session FactoryUtil.getSqlSession();UserMapper mapper session.getMapper(UserMapper.class);PageHelper.startPage(2,3);//查询第二页每页三条数据,这句必须在查询前ListUser allUsers mapper.getAllUsers();PageInfoUser pageInfo new PageInfo(allUsers);//将查询结果保存到PageInfo对象中System.out.println(总条数 pageInfo.getTotal());System.out.println(总页数 pageInfo.getPages());pageInfo.getList().forEach(System.out::println);//展示查询结果try {session.commit();} catch (Exception e) {session.rollback();} finally {session.close();}
}注意设置查询页码和每页条数的语句必须在调用查询方法之前否则查询的结果将不会实现分页效果。 配置数据源 Druid Druid 是阿里巴巴开源平台上的一个项目是性能最好的数据库连接池如何在Mybatis中配置该数据源呢 dependencygroupIdcom.alibaba/groupIdartifactIddruid/artifactIdversion1.2.8/version
/dependency创建 DruidDataSourceFactory 并继承 PooledDataSourceFactory并替换数据源 public class DruidDataSourceFactory extends PooledDataSourceFactory {public DruidDataSourceFactory() {this.dataSource new DruidDataSource();//替换数据源}
}!--config.xml--
dataSource typecom.qf.mybatis.datasource.DruidSourceFactory!-- property namedriverClassName valuecom.mysql.cj.jdbc.Driver/--!-- property nameurl valuejdbc:mysql://localhost:3306/lesson?serverTimezoneAsia/Shanghaiamp;tinyInt1isBitfalse/--!-- property nameusername valueroot/--!-- property namepassword value123456/--property namedriverClass value${jdbc.driverClassName}/property namejdbcUrl value${jdbc.url}/property nameusername value${jdbc.username}/property namepassword value${jdbc.password}//dataSource注意 在 Druid 数据源中属性名称是 driverClass和jdbcUrl而不是 driver和url。因此需要使用 driverClassName 进行配置。
