Mybatis 增删改查的注解方式01 MyBatis的常用注解 MyBatis的增删改查 注解开发总结 MyBatis的常用注解@Insert：实现新增@Update：实现更新@Delete：实现删除@Select：实现查询@Result：实现结果集封装@Results：可以与@Result 一起使用，封装多个结果集@One：实现一对一结果集封装@Many：实现一对多结果集封装MyBatis的增删改查注意：数据表以及各种配置参考Mybatis的基本使用案例目录结构MyBatisConfig.xml核心配置<?xml version="1.0" encoding="UTF-8" ?> <!--MyBatis的DTD约束--> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <!--configuration 核心根标签--> <configuration> <!--引入数据库连接的配置文件--> <properties resource="jdbc.properties"/> <!--配置LOG4J--> <settings> <setting name="logImpl" value="log4j"/> </settings> <!--起别名--> <typeAliases> <typeAlias type="com.limei.bean.Student" alias="student"/> <!--<package name="com.itheima.bean"/>--> </typeAliases> <!--environments配置数据库环境，环境可以有多个。default属性指定使用的是哪个--> <environments default="mysql"> <!--environment配置数据库环境 id属性唯一标识--> <environment id="mysql"> <!-- transactionManager事务管理。 type属性，采用JDBC默认的事务--> <transactionManager type="JDBC"></transactionManager> <!-- dataSource数据源信息 type属性 连接池--> <dataSource type="POOLED"> <!-- property获取数据库连接的配置信息 --> <property name="driver" value="${driver}" /> <property name="url" value="${url}" /> <property name="username" value="${username}" /> <property name="password" value="${password}" /> </dataSource> </environment> </environments> <!-- mappers引入映射配置文件 --> <mappers> <!--扫描使用注解的类所在的包--> <package name="com.limei.mapper"></package> </mappers> </configuration>StudentMapper接口//查询全部 @Select("SELECT * FROM student") public abstract List<Student> selectAll(); //新增数据 @Insert(" INSERT INTO student VALUES (#{id},#{name},#{birthday},#{address})") public abstract Integer insert(Student stu); //修改数据 @Update(" UPDATE student SET name = #{name},birthday = #{birthday},address=#{address} WHERE id = #{id}") public abstract Integer update(Student stu); //删除数据 @Delete("DELETE FROM student WHERE id = #{id}") public abstract Integer delete(String id); Test01测试类，查询所有public class Test01 { //String类型转换为Date类型 public Date conversionDate(String s){ String str =s; Date date=null; SimpleDateFormat sdf=null; try { sdf = new SimpleDateFormat ( "yyyy-MM-dd" ); date = sdf.parse ( str ); } catch (ParseException e) { e.printStackTrace (); } return date; } //查询所有 @Test public void selectAll() throws Exception{ //1.加载核心配置文件 InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder ().build(is); //3.通过工厂对象获取SqlSession对象 SqlSession sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper ( StudentMapper.class ); //5.调用实现类对象中的方法，接收结果 List<Student> list = mapper.selectAll (); //6.处理结果 for (Student student: list) { System.out.println(student); } //7.释放资源 sqlSession.close(); is.close(); } }添加操作，只需要改第五步，第六步遍历删除： Date date = conversionDate ( "1998-09-01" ); Student student=new Student ( "10010","张三",date,"北京市" ); Integer insert = mapper.insert ( student );更改操作，只需要改第五步，第六步遍历删除： Date date = conversionDate ( "1998-09-01" ); Student student=new Student ( "10010","李四",date,"北京市" ); Integer update = mapper.update ( student );删除操作，只需要改第五步，第六步遍历删除： Date date = conversionDate ( "1998-09-01" ); Integer delete = mapper.delete ( "10010" );注解开发总结注解可以简化开发操作，省略映射配置文件的编写。常用注解 @Select(“查询的 SQL 语句”)：执行查询操作注解@Insert(“查询的 SQL 语句”)：执行新增操作注解@Update(“查询的 SQL 语句”)：执行修改操作注解@Delete(“查询的 SQL 语句”)：执行删除操作注解配置映射关系<mappers> <package name="接口所在包"/> </mappers>

MyBatis的多表操作 一对一 一对多 多对多 一对一步骤一: sql语句准备CREATE TABLE person( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(20), age INT ); INSERT INTO person VALUES (NULL,'张三',26); INSERT INTO person VALUES (NULL,'李四',36); INSERT INTO person VALUES (NULL,'王五',28); CREATE TABLE card( id INT PRIMARY KEY AUTO_INCREMENT, number VARCHAR(30), pid INT, CONSTRAINT cp_fk FOREIGN KEY (pid) REFERENCES person(id) ); INSERT INTO card VALUES (NULL,'12345',1); INSERT INTO card VALUES (NULL,'23456',2); INSERT INTO card VALUES (NULL,'34567',3);步骤二:配置文件<?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"> <mapper namespace="com.itheima.table01.OneToOneMapper"> <!--配置字段和实体对象属性的映射关系--> <resultMap id="oneToOne" type="card"> <id column="cid" property="id" /> <result column="number" property="number" /> <!-- association：配置被包含对象的映射关系 property：被包含对象的变量名 javaType：被包含对象的数据类型 --> <association property="p" javaType="person"> <id column="pid" property="id" /> <result column="name" property="name" /> <result column="age" property="age" /> </association> </resultMap> <select id="selectAll" resultMap="oneToOne"> SELECT c.id cid,number,pid,NAME,age FROM card c,person p WHERE c.pid=p.id </select> </mapper>步骤三：测试类 @Test public void selectAll() throws Exception{ //1.加载核心配置文件 InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 SqlSession sqlSession = sqlSessionFactory.openSession(true); //4.获取OneToOneMapper接口的实现类对象 OneToOneMapper mapper = sqlSession.getMapper(OneToOneMapper.class); //5.调用实现类的方法，接收结果 List<Card> list = mapper.selectAll(); //6.处理结果 for (Card c : list) { System.out.println(c); } //7.释放资源 sqlSession.close(); is.close(); }3.一对一配置总结:<resultMap>：配置字段和对象属性的映射关系标签。 id 属性：唯一标识 type 属性：实体对象类型 <id>：配置主键映射关系标签。 <result>：配置非主键映射关系标签。 column 属性：表中字段名称 property 属性： 实体对象变量名称 <association>：配置被包含对象的映射关系标签。 property 属性：被包含对象的变量名 javaType 属性：被包含对象的数据类型一对多一对多模型： 一对多模型：班级和学生，一个班级可以有多个学生。代码实现步骤一: sql语句准备CREATE TABLE classes( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(20) ); INSERT INTO classes VALUES (NULL,'网课一班'); INSERT INTO classes VALUES (NULL,'网课二班'); CREATE TABLE student( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(30), age INT, cid INT, CONSTRAINT cs_fk FOREIGN KEY (cid) REFERENCES classes(id) ); INSERT INTO student VALUES (NULL,'张三',23,1); INSERT INTO student VALUES (NULL,'李四',24,1); INSERT INTO student VALUES (NULL,'王五',25,2); INSERT INTO student VALUES (NULL,'赵六',26,2);步骤二:配置文件<mapper namespace="com.itheima.table02.OneToManyMapper"> <resultMap id="oneToMany" type="classes"> <id column="cid" property="id"/> <result column="cname" property="name"/> <!-- collection：配置被包含的集合对象映射关系 property：被包含对象的变量名 ofType：被包含对象的实际数据类型 --> <collection property="students" ofType="student"> <id column="sid" property="id"/> <result column="sname" property="name"/> <result column="sage" property="age"/> </collection> </resultMap> <select id="selectAll" resultMap="oneToMany"> SELECT c.id cid,c.name cname,s.id sid,s.name sname,s.age sage FROM classes c,student s WHERE c.id=s.cid </select> </mapper>步骤三：测试类 @Test public void selectAll() throws Exception{ //1.加载核心配置文件 InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 SqlSession sqlSession = sqlSessionFactory.openSession(true); //4.获取OneToManyMapper接口的实现类对象 OneToManyMapper mapper = sqlSession.getMapper(OneToManyMapper.class); //5.调用实现类的方法，接收结果 List<Classes> classes = mapper.selectAll(); //6.处理结果 for (Classes cls : classes) { System.out.println(cls.getId() + "," + cls.getName()); List<Student> students = cls.getStudents(); for (Student student : students) { System.out.println("\t" + student); } } //7.释放资源 sqlSession.close(); is.close(); }多对多多表模型多对多操作多对多模型：学生和课程，一个学生可以选择多门课程、一个课程也可以被多个学生所选择。代码实现步骤一: sql语句准备CREATE TABLE course( id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(20) ); INSERT INTO course VALUES (NULL,'数学'); INSERT INTO course VALUES (NULL,'英语'); CREATE TABLE stu_cr( id INT PRIMARY KEY AUTO_INCREMENT, sid INT, cid INT, CONSTRAINT sc_fk1 FOREIGN KEY (sid) REFERENCES student(id), CONSTRAINT sc_fk2 FOREIGN KEY (cid) REFERENCES course(id) ); INSERT INTO stu_cr VALUES (NULL,1,1); INSERT INTO stu_cr VALUES (NULL,1,2); INSERT INTO stu_cr VALUES (NULL,2,1); INSERT INTO stu_cr VALUES (NULL,2,2);步骤二:配置文件<?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"> <mapper namespace="com.itheima.table03.ManyToManyMapper"> <resultMap id="manyToMany" type="student"> <id column="sid" property="id"/> <result column="sname" property="name"/> <result column="sage" property="age"/> <collection property="courses" ofType="course"> <id column="cid" property="id"/> <result column="cname" property="name"/> </collection> </resultMap> <select id="selectAll" resultMap="manyToMany"> SELECT sc.sid,s.name sname,s.age sage,sc.cid,c.name cname FROM student s,course c,stu_cr sc WHERE sc.sid=s.id AND sc.cid=c.id </select> </mapper>步骤三：测试类 @Test public void selectAll() throws Exception{ //1.加载核心配置文件 InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 SqlSession sqlSession = sqlSessionFactory.openSession(true); //4.获取ManyToManyMapper接口的实现类对象 ManyToManyMapper mapper = sqlSession.getMapper(ManyToManyMapper.class); //5.调用实现类的方法，接收结果 List<Student> students = mapper.selectAll(); //6.处理结果 for (Student student : students) { System.out.println(student.getId() + "," + student.getName() + "," + student.getAge()); List<Course> courses = student.getCourses(); for (Course cours : courses) { System.out.println("\t" + cours); } } //7.释放资源 sqlSession.close(); is.close(); } 多表模型操作总结 <resultMap>：配置字段和对象属性的映射关系标签。 id 属性：唯一标识 type 属性：实体对象类型 <id>：配置主键映射关系标签。 <result>：配置非主键映射关系标签。 column 属性：表中字段名称 property 属性： 实体对象变量名称 <association>：配置被包含对象的映射关系标签。 property 属性：被包含对象的变量名 javaType 属性：被包含对象的数据类型 <collection>：配置被包含集合对象的映射关系标签。 property 属性：被包含集合对象的变量名 ofType 属性：集合中保存的对象数据类型

Mybatis代理方式的增删改查 代理开发方式介绍 增删改查的实现 总结 代理开发方式介绍采用 Mybatis 的代理开发方式实现 DAO 层的开发，这种方式是我们后面进入企业的主流。Mapper 接口开发方法只需要程序员编写Mapper 接口（相当于Dao 接口），由Mybatis 框架根据接口定义创建接口的动态代理对象，代理对象的方法体同上边Dao接口实现类方法。Mapper 接口开发需要遵循以下规范：1) Mapper.xml文件中的namespace与mapper接口的全限定名相同2) Mapper接口方法名和Mapper.xml中定义的每个statement的id相同3) Mapper接口方法的输入参数类型和mapper.xml中定义的每个sql的parameterType的类型相同4) Mapper接口方法的输出参数类型和mapper.xml中定义的每个sql的resultType的类型相同增删改查的实现*** 案例目录结构 *** 该案例和《Mybatis的基本使用》使用的是同一个数据库以及实体类 1.编写StudentController类 2.编写StudentMapper接口 3.编写StudentService接口 4.编写StudentServiceImpl类 5.编写StudentMapper.xml文件 编写StudentController类 package com.limei.controller; import com.limei.bean.Student; import com.limei.service.StudentService; import com.limei.service.impl.StudentServiceImpl; import org.junit.Test; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; /* 控制层测试类 */ public class StudentController { //创建业务层对象 private StudentService service = new StudentServiceImpl (); //String类型转换为Date类型 public Date conversionDate(String s){ String str =s; Date date=null; SimpleDateFormat sdf=null; try { sdf = new SimpleDateFormat ( "yyyy-MM-dd" ); date = sdf.parse ( str ); } catch (ParseException e) { e.printStackTrace (); } return date; } //查询全部功能测试 @Test public void selectAll() { List<Student> students = service.selectAll(); for (Student stu : students) { System.out.println(stu); } } //根据id查询功能测试 @Test public void selectById() { Student stu = service.selectById("10001"); System.out.println(stu); } //新增功能测试 @Test public void insert() { Date date = conversionDate ( "2011-09-01" ); Student stu = new Student("10010","赵六",date,"上海市"); Integer result = service.insert(stu); System.out.println(result); } //修改功能测试 @Test public void update() { Date date = conversionDate ( "2011-09-01" ); Student stu = new Student("10010","赵五",date,"上海市"); Integer result = service.update(stu); System.out.println(result); } //删除功能测试 @Test public void delete() { Integer result = service.delete("10010"); System.out.println(result); } // 多条件查询 @Test public void selectCondition(){ Student stu = new Student(); stu.setId("10002"); stu.setName("李四"); List<Student> list = service.selectCondition ( stu ); //6.处理结果 for (Student student : list) { System.out.println(student); } } //根据多个id查询 @Test public void selectByIds(){ List<String> ids = new ArrayList<> (); ids.add("10001"); ids.add("10002"); ids.add("10003"); List<Student> list = service.selectByIds ( ids ); for (Student student:list){ System.out.println (student); } } } 编写StudentMapper接口package com.limei.mapper; import com.limei.bean.Student; import java.util.List; public interface StudentMapper { //查询全部 public abstract List<Student> selectAll(); //根据id查询 public abstract Student selectById(String id); //新增数据 public abstract Integer insert(Student stu); //修改数据 public abstract Integer update(Student stu); //删除数据 public abstract Integer delete(String id); //多条件查询 public abstract List<Student> selectCondition(Student stu); //根据多个id查询 public abstract List<Student> selectByIds(List<String> ids); } 编写StudentService接口package com.limei.service; import com.limei.bean.Student; import java.util.List; /* 业务层接口 */ public interface StudentService { //查询全部 public abstract List<Student> selectAll(); //根据id查询 public abstract Student selectById(String id); //新增数据 public abstract Integer insert(Student stu); //修改数据 public abstract Integer update(Student stu); //删除数据 public abstract Integer delete(String id); //多条件查询 public abstract List<Student> selectCondition(Student stu); //根据多个id查询 public abstract List<Student> selectByIds(List<String> ids); } 编写StudentServiceImpl类package com.limei.service.impl; import com.limei.bean.Student; import com.limei.mapper.StudentMapper; import com.limei.service.StudentService; 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; import java.util.ArrayList; import java.util.List; /* 业务层实现类 */ public class StudentServiceImpl implements StudentService { //查询全部 @Override public List<Student> selectAll() { List<Student> list = null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); System.out.println (is); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 list = mapper.selectAll(); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return list; } @Override public Student selectById(String id) { Student stu = null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 stu = mapper.selectById(id); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return stu; } @Override public Integer insert(Student stu) { Integer result = null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 result = mapper.insert(stu); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return result; } @Override public Integer update(Student stu) { Integer result = null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 result = mapper.update(stu); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return result; } @Override public Integer delete(String id) { Integer result = null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 result = mapper.delete(id); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return result; } //多条件查询 @Override public List<Student> selectCondition(Student stu) { List<Student> list=null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 list = mapper.selectCondition ( stu ); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return list; } //根据多个id查询 @Override public List<Student> selectByIds(List<String> ids) { List<Student> list = null; SqlSession sqlSession = null; InputStream is = null; try{ //1.加载核心配置文件 is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 sqlSession = sqlSessionFactory.openSession(true); //4.获取StudentMapper接口的实现类对象 StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl(); //5.通过实现类对象调用方法，接收结果 list = mapper.selectByIds ( ids ); } catch (Exception e) { } finally { //6.释放资源 if(sqlSession != null) { sqlSession.close(); } if(is != null) { try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } //7.返回结果 return list; } } 编写StudentMapper.xml文件<?xml version="1.0" encoding="UTF-8" ?> <!--MyBatis的DTD约束--> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!-- mapper：核心根标签 namespace属性：名称空间 --> <mapper namespace="com.limei.mapper.StudentMapper"> <!-- select：查询功能的标签 id属性：唯一标识 resultType属性：指定结果映射对象类型 parameterType属性：指定参数映射对象类型 --> <select id="selectAll" resultType="student"> SELECT * FROM student </select> <select id="selectById" resultType="student" parameterType="String"> SELECT * FROM student WHERE id = #{id} </select> <insert id="insert" parameterType="student"> INSERT INTO student VALUES (#{id},#{name},#{birthday},#{address}) </insert> <update id="update" parameterType="student"> UPDATE student SET name = #{name},birthday = #{birthday},address=#{address} WHERE id = #{id} </update> <delete id="delete" parameterType="String"> DELETE FROM student WHERE id = #{id} </delete> <!-- <where>：条件标签。如果有动态条件，则使用该标签代替 where 关键字。 <if>：条件判断标签。 <if test=“条件判断”> 查询条件拼接 </if> --> <select id="selectCondition" resultType="student" parameterType="student"> SELECT * FROM student <where> <if test="id != null"> id = #{id} </if> <if test="name != null"> AND name = #{name} </if> </where> </select> <!-- 属性 collection：参数容器类型， (list-集合， array-数组)。 open：开始的 SQL 语句。 close：结束的 SQL 语句。 item：参数变量名。 separator：分隔符。 --> <select id="selectByIds" resultType="student" parameterType="list"> SELECT * FROM student <where> <foreach collection="list" open="id IN (" close=")" item="id" separator=","> #{id} </foreach> </where> </select> </mapper> 总结此目录缺失的文件去Mybatis的基本使用中去寻找接口代理方式可以让我们只编写接口即可，而实现类对象由 MyBatis 生成。 实现规则 ：映射配置文件中的名称空间必须和 Dao 层接口的全类名相同。映射配置文件中的增删改查标签的 id 属性必须和 Dao 层接口的方法名相同。映射配置文件中的增删改查标签的 parameterType 属性必须和 Dao 层接口方法的参数相同。映射配置文件中的增删改查标签的 resultType 属性必须和 Dao 层接口方法的返回值相同。 获取动态代理对象 SqlSession 功能类中的 getMapper() 方法。

Mybatis的基本使用 什么是Mybatis Mybatis的搭建步骤 什么是Mybatis mybatis 是一个优秀的基于java的持久层框架，它内部封装了jdbc，使开发者只需要关注sql语句本身，而不需要花费精力去处理加载驱动、创建连接、创建statement等繁杂的过程。mybatis通过xml或注解的方式将要执行的各种 statement配置起来，并通过java对象和statement中sql的动态参数进行映射生成最终执行的sql语句。最后mybatis框架执行sql并将结果映射为java对象并返回。采用ORM思想解决了实体和数据库映射的问题，对jdbc 进行了封装，屏蔽了jdbc api 底层访问细节，使我们不用与jdbc api 打交道，就可以完成对数据库的持久化操作。MyBatis官网地址：http://www.mybatis.org/mybatis-3/ Mybatis的搭建步骤MyBatis开发步骤： ①添加MyBatis的jar包 ②创建Student数据表 ③编写Studentr实体类 ④编写映射文件StudentMapper.xml ⑤编写核心文件MyBatisConfig.xml ⑥编写测试类*** 测试案例目录结构 *** jdbc.properties 编写Studentr实体类 package com.limei.bean; import java.util.Date; public class Student { private String id; private String name; private Date birthday; private String address; public Student() { } public Student(String id, String name, Date birthday, String address) { this.id = id; this.name = name; this.birthday = birthday; this.address = address; } public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Date getBirthday() { return birthday; } public void setBirthday(Date birthday) { this.birthday = birthday; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } @Override public String toString() { return "Student{" + "id='" + id + '\'' + ", name='" + name + '\'' + ", birthday=" + birthday + ", address='" + address + '\'' + '}'; } } ④编写映射文件StudentMapper.xml <?xml version="1.0" encoding="UTF-8" ?> <!--MyBatis的DTD约束--> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!-- mapper：核心根标签 namespace属性：名称空间 --> <mapper namespace="StudentMapper"> <!-- select：查询功能的标签 id属性：唯一标识 resultType属性：指定结果映射对象类型 parameterType属性：指定参数映射对象类型 --> <select id="selectAll" resultType="student"> SELECT * FROM student </select> <update id="update" parameterType="student"> UPDATE student SET name = #{name},birthday = #{birthday},address=#{address} WHERE id = #{id} </update> </mapper> ⑤编写核心文件MyBatisConfig.xml <?xml version="1.0" encoding="UTF-8" ?> <!--MyBatis的DTD约束--> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <!--configuration 核心根标签--> <configuration> <!--引入数据库连接的配置文件--> <properties resource="jdbc.properties"/> <!--配置LOG4J--> <settings> <setting name="logImpl" value="log4j"/> </settings> <!--起别名--> <typeAliases> <typeAlias type="com.limei.bean.Student" alias="student"/> <!--<package name="com.limei.bean"/>--> </typeAliases> <!--environments配置数据库环境，环境可以有多个。default属性指定使用的是哪个--> <environments default="mysql"> <!--environment配置数据库环境 id属性唯一标识--> <environment id="mysql"> <!-- transactionManager事务管理。 type属性，采用JDBC默认的事务--> <transactionManager type="JDBC"></transactionManager> <!-- dataSource数据源信息 type属性 连接池--> <dataSource type="POOLED"> <!-- property获取数据库连接的配置信息 --> <property name="driver" value="${driver}" /> <property name="url" value="${url}" /> <property name="username" value="${username}" /> <property name="password" value="${password}" /> </dataSource> </environment> </environments> <!-- mappers引入映射配置文件 --> <mappers> <!-- mapper 引入指定的映射配置文件 resource属性指定映射配置文件的名称 --> <mapper resource="StudentMapper.xml"/> </mappers> </configuration> 编写测试类 package com.limei.dao; import com.limei.bean.Student; 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.List; public class StudentTest01 { /* 查询全部 */ @Test public void selectAll() throws Exception{ //1.加载核心配置文件 //InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml"); InputStream is = StudentTest01.class.getClassLoader().getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过SqlSession工厂对象获取SqlSession对象 SqlSession sqlSession = sqlSessionFactory.openSession(); //4.执行映射配置文件中的sql语句，并接收结果 List<Student> list = sqlSession.selectList("StudentMapper.selectAll"); //5.处理结果 for (Student stu : list) { System.out.println(stu); } //6.释放资源 sqlSession.close(); is.close(); } /* 修改功能 */ @Test public void update() throws Exception{ //1.加载核心配置文件 InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml"); //2.获取SqlSession工厂对象 SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is); //3.通过工厂对象获取SqlSession对象 SqlSession sqlSession = sqlSessionFactory.openSession(); //SqlSession sqlSession = sqlSessionFactory.openSession(true);为自动提交事务 //String类型转换为Date类型 String str ="2000-02-26"; SimpleDateFormat sdf = new SimpleDateFormat ( "yyyy-MM-dd" ); Date date = sdf.parse ( str ); //4.执行映射配置文件中的sql语句，并接收结 Student stu = new Student("10001","阿画",date,"河南省周口市"); int result = sqlSession.update("StudentMapper.update",stu); //5.提交事务 sqlSession.commit(true); //6.处理结果 System.out.println(result); //7.释放资源 sqlSession.close(); is.close(); } } 查询结果

redis持久化使用 redis持久化简介 RDB的介绍和使用 AOF的介绍和使用 RDB与AOF区别 redis持久化简介什么是持久化:  利用永久性存储介质将数据进行保存，在特定的时间将保存的数据进行恢复的工作机制称为持久化 。  持久化用于防止数据的意外丢失，确保数据安全性。<br/><br/>持久化过程保存什么？  我们知道一点，计算机中的数据全部都是二进制，如果现在我要你给我保存一组数据的话，你有什么样的方式呢，其实最简单的就是现在长什么样，我就记下来就行了，那么这种是记录纯粹的数据，也叫做快照存储，也就是它保存的是某一时刻的数据状态。  还有一种形式，它不记录你的数据，它记录你所有的操作过程，比如说大家用idea的时候，有没有遇到过写错了ctrl+z撤销，然后ctrl+y还能恢复，这个地方它也是在记录，但是记录的是你所有的操作过程，那我想问一下，操作过程，我都给你留下来了，你说数据还会丢吗？肯定不会丢，因为你所有的操作过程我都保存了。这种保存操作过程的存储，用专业术语来说可以说是日志，这是两种不同的保存数据的形式啊。<br/><br/>总结一下：  第一种：将当前数据状态进行保存，快照形式，存储数据结果，存储格式简单，关注点在数据。  第二种：将数据的操作过程进行保存，日志形式，存储操作过程，存储格式复杂，关注点在数据的操作过程。<br/><br/>RDB的介绍save指令手动执行一次保存操作savesave指令相关配置设置本地数据库文件名，默认值为 dump.rdb，通常设置为dump-端口号.rdb（目录名称data）dbfilename filename设置存储.rdb文件的路径，通常设置成存储空间较大的目录中，目录名称datadir path设置存储至本地数据库时是否压缩数据，默认yes，设置为no，节省 CPU 运行时间，但存储文件变大rdbcompression yes|no设置读写文件过程是否进行RDB格式校验，默认yes，设置为no，节约读写10%时间消耗，单存在数据损坏的风险rdbchecksum yes|no配置文件展示：<br/><br/>注意：  记得redis是个单线程的工作模式，它会创建一个任务队列，所有的命令都会进到这个队列里边，在这儿排队执行，执行完一个消失一个，当所有的命令都执行完了，OK，结果达到了。  但是如果现在我们执行的时候save指令保存的数据量很大会是什么现象呢？  他会非常耗时，以至于影响到它在执行的时候，后面的指令都要等，所以说这种模式是不友好的，这是save指令对应的一个问题，当cpu执行的时候会阻塞redis服务器，直到他执行完毕，所以说我们不建议大家在线上环境用save指令。bgsave指令之前我们讲到了当save指令的数据量过大时，单线程执行方式造成效率过低，那应该如何处理？此时我们可以使用：bgsave指令，bg其实是background的意思，后台执行的意思手动启动后台保存操作，但不是立即执行bgsavebgsave指令相关配置后台存储过程中如果出现错误现象，是否停止保存操作，默认yesstop-writes-on-bgsave-error yes|no其 他dbfilename filename dir path rdbcompression yes|no rdbchecksum yes|nobgsave指令工作原理当执行bgsave的时候，客户端发出bgsave指令给到redis服务器。注意，这个时候服务器马上回一个结果告诉客户端后台已经开始了，与此同时它会创建一个子进程，使用Linux的fork函数创建一个子进程，让这个子进程去执行save相关的操作，此时我们可以想一下，我们主进程一直在处理指令，而子进程在执行后台的保存，它会不会干扰到主进程的执行吗？答案是不会，所以说他才是主流方案。子进程开始执行之后，它就会创建啊RDB文件把它存起来，操作完以后他会把这个结果返回，也就是说bgsave的过程分成两个过程，第一个是服务端拿到指令直接告诉客户端开始执行了；另外一个过程是一个子进程在完成后台的保存操作，操作完以后回一个消息。save配置自动执行设置自动持久化的条件，满足限定时间范围内key的变化数量达到指定数量即进行持久化save second changes参数second：监控时间范围changes：监控key的变化量范例：save 900 1 save 300 10 save 60 10000其他相关配置：dbfilename filename dir path rdbcompression yes|no rdbchecksum yes|no stop-writes-on-bgsave-error yes|noRDB两种启动方式对比方式save指令bgsave指令读写同步异步阻塞客户端指令是否额外内存消耗否是启动新进程否是RDB特殊启动形式服务器运行过程中重启debug reload关闭服务器时指定保存数据shutdown saveRDB优点：RDB是一个紧凑压缩的二进制文件，存储效率较高RDB内部存储的是redis在某个时间点的数据快照，非常适合用于数据备份，全量复制等场景RDB恢复数据的速度要比AOF快很多应用：服务器中每X小时执行bgsave备份，并将RDB文件拷贝到远程机器中，用于灾难恢复。RDB缺点RDB方式无论是执行指令还是利用配置，无法做到实时持久化，具有较大的可能性丢失数据bgsave指令每次运行要执行fork操作创建子进程，要牺牲掉一些性能Redis的众多版本中未进行RDB文件格式的版本统一，有可能出现各版本服务之间数据格式无法兼容现象AOF的介绍和配置AOF介绍为什么要有AOF,这得从RDB的存储的弊端说起：存储数据量较大，效率较低，基于快照思想，每次读写都是全部数据，当数据量巨大时，效率非常低大数据量下的IO性能较低基于fork创建子进程，内存产生额外消耗宕机带来的数据丢失风险那解决的思路是什么呢？不写全数据，仅记录部分数据降低区分数据是否改变的难度，改记录数据为记录操作过程对所有操作均进行记录，排除丢失数据的风险AOF概念AOF(append only file)持久化：以独立日志的方式记录每次写命令，重启时再重新执行AOF文件中命令 达到恢复数据的目的。与RDB相比可以简单理解为由记录数据改为记录数据产生的变化AOF的主要作用是解决了数据持久化的实时性，目前已经是Redis持久化的主流方式启动AOF相关配置开启AOF持久化功能，默认no，即不开启状态appendonly yes|noAOF持久化文件名，默认文件名为appendonly.aof，建议配置为appendonly-端口号.aofappendfilename filenameAOF持久化文件保存路径，与RDB持久化文件保持一致即可dirAOF写数据策略，默认为everysecappendfsync always|everysec|noAOF执行策略AOF写数据三种策略(appendfsync)always(每次）：每次写入操作均同步到AOF文件中数据零误差，性能较低，不建议使用。everysec（每秒）：每秒将缓冲区中的指令同步到AOF文件中，在系统突然宕机的情况下丢失1秒内的数据 数据准确性较高，性能较高，建议使用，也是默认配置no（系统控制）：由操作系统控制每次同步到AOF文件的周期，整体过程不可控AOF重写什么叫AOF重写？随着命令不断写入AOF，文件会越来越大，为了解决这个问题，Redis引入了AOF重写机制压缩文件体积。AOF文件重 写是将Redis进程内的数据转化为写命令同步到新AOF文件的过程。简单说就是将对同一个数据的若干个条命令执行结 果转化成最终结果数据对应的指令进行记录。AOF重写作用降低磁盘占用量，提高磁盘利用率提高持久化效率，降低持久化写时间，提高IO性能降低数据恢复用时，提高数据恢复效率AOF重写规则进程内具有时效性的数据，并且数据已超时将不再写入文件非写入类的无效指令将被忽略，只保留最终数据的写入命令如del key1、 hdel key2、srem key3、set key4 111、set key4 222等如select指令虽然不更改数据，但是更改了数据的存储位置，此类命令同样需要记录对同一数据的多条写命令合并为一条命令如lpushlist1 a、lpush list1 b、lpush list1 c可以转化为：lpush list1 a b c。为防止数据量过大造成客户端缓冲区溢出，对list、set、hash、zset等类型，每条指令最多写入64个元素AOF重写方式手动重写bgrewriteaof手动重写原理分析：自动重写auto-aof-rewrite-min-size size auto-aof-rewrite-percentage percentage自动重写触发条件设置auto-aof-rewrite-min-size size auto-aof-rewrite-percentage percent自动重写触发比对参数（ 运行指令info Persistence获取具体信息 ）aof_current_size aof_base_size自动重写触发条件公式：RDB与AOF区别 RDB与AOF对比（优缺点）持久化方式RDBAOF占用存储空间小（数据级：压缩）大（指令级：重写）存储速度慢快恢复速度快慢数据安全性会丢失数据依据策略决定资源消耗高/重量级低/轻量级启动优先级低高RDB与AOF应用场景RDB与AOF的选择之惑对数据非常敏感，建议使用默认的AOF持久化方案AOF持久化策略使用everysecond，每秒钟fsync一次。该策略redis仍可以保持很好的处理性能，当出 现问题时，最多丢失0-1秒内的数据。注意：由于AOF文件存储体积较大，且恢复速度较慢数据呈现阶段有效性，建议使用RDB持久化方案数据可以良好的做到阶段内无丢失（该阶段是开发者或运维人员手工维护的），且恢复速度较快，阶段 点数据恢复通常采用RDB方案注意：利用RDB实现紧凑的数据持久化会使Redis降的很低，慎重总结：综合比对RDB与AOF的选择实际上是在做一种权衡，每种都有利有弊如不能承受数分钟以内的数据丢失，对业务数据非常敏感，选用AOF如能承受数分钟以内的数据丢失，且追求大数据集的恢复速度，选用RDB灾难恢复选用RDB双保险策略，同时开启 RDB和 AOF，重启后，Redis优先使用 AOF 来恢复数据，降低丢失数据的量