MyBatis完成品牌数据的增删改查 *** 作

MyBatis完成品牌数据的增删改查 *** 作,第1张

MyBatis配置文件完成增删改查

文章目录
  • MyBatis配置文件完成增删改查
    • 案例:完成品牌数据的增删改查 *** 作
      • 要完成的功能清单:
      • 准备环境
    • MyBatis完成增删改查
      • 查询
        • 查询所有数据
        • 查看详情功能
        • 条件查询
          • 1.多条件查询
          • 2.单条件动态查询
      • 添加
      • MyBatis事务
      • 修改
        • 修改全部字段
        • 修改动态字段
      • 删除功能
        • 删除单个
        • 批量删除
    • 动态SQL

案例:完成品牌数据的增删改查 *** 作 要完成的功能清单:
  1. 查询
    • 查询所有数据
    • 查看详情
    • 条件查询
  2. 添加
  3. 修改
    • 修改全部字段
    • 修改动态字段
  4. 删除
    • 删除一个
    • 批量删除
准备环境
  • 搭建Maven

  • 添加依赖

    
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0modelVersion>
    
        <groupId>com.itycgroupId>
        <artifactId>maven-demoartifactId>
        <version>1.0-SNAPSHOTversion>
    
        
        <dependencies>
            <dependency>
                <groupId>mysqlgroupId>
                <artifactId>mysql-connector-javaartifactId>
                <version>5.1.32version>
            dependency>
    
            
            <dependency>
                <groupId>com.alibabagroupId>
                <artifactId>druidartifactId>
                <version>1.1.12version>
            dependency>
    
    
            <dependency>
                <groupId>junitgroupId>
                <artifactId>junitartifactId>
                <version>4.13version>
                <scope>testscope>
            dependency>
            
            <dependency>
                <groupId>org.mybatisgroupId>
                <artifactId>mybatisartifactId>
                <version>3.5.5version>
            dependency>
    
    
            <dependency>
                <groupId>org.slf4jgroupId>
                <artifactId>slf4j-apiartifactId>
                <version>1.7.20version>
            dependency>
            <dependency>
                <groupId>ch.qos.logbackgroupId>
                <artifactId>logback-classicartifactId>
                <version>1.2.3version>
            dependency>
    
            <dependency>
                <groupId>ch.qos.logbackgroupId>
                <artifactId>logback-coreartifactId>
                <version>1.2.3version>
            dependency>
    
        dependencies>
    project>
    
  • 数据库表

-- 创建tb_brand
CREATE TABLE tb_brand ( 
-- id主键
id INT PRIMARY KEY auto_increment, 
-- 品牌名称
brand_name VARCHAR ( 20 ),
--企业名称
company_name VARCHAR ( 20 ), 
-- 排序字段
ordered INT, 
-- 描述信息
description VARCHAR ( 100 ),
-- 状态:0:禁用 1:启用
`status` INT );

-- 添加数据
INSERT INTO tb_brand ( brand_name, company_name, ordered, description, `status` )
VALUES
	( '三只松鼠', '三只松鼠股份有限公司', 5, '好吃', 0 ),
	( '华为', '华为技术有限公司', 100, '华为致力于构建万物互联的智能世界', 1 ),
	( '小米', '小米技术有限公司', 50, 'are you ok', 1 );
	
	--查询数据
	select id,brand_name, company_name, ordered, description, `status` from tb_brand;
  • 实体类Brand
package com.ityc.pojo;

/**
 * 品牌
 *
 * alt + 鼠标左键  :整列编辑
 *
 * alt + r  替换
 *
 * 在实体类中,基本数据类型建议使用对应的包装类型
 */
public class Brand {

    // id主键
    private Integer id  ;
    // 品牌名称
    private String brandName;
    //企业名
    private String companyName ;
    // 排序字段
    private Integer ordered;
    // 描述信息
    private String description;
    // 状态:0:禁用 1:启用
    private Integer status;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getBrandName() {
        return brandName;
    }

    public void setBrandName(String brandName) {
        this.brandName = brandName;
    }

    public String getCompanyName() {
        return companyName;
    }

    public void setCompanyName(String companyName) {
        this.companyName = companyName;
    }

    public Integer getOrdered() {
        return ordered;
    }

    public void setOrdered(Integer ordered) {
        this.ordered = ordered;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    public Integer getStatus() {
        return status;
    }

    public void setStatus(Integer status) {
        this.status = status;
    }

    @Override
    public String toString() {
        return "Brand{" +
                "id=" + id +
                ", brandName='" + brandName + '\'' +
                ", companyName='" + companyName + '\'' +
                ", ordered=" + ordered +
                ", description='" + description + '\'' +
                ", status=" + status +
                '}';
    }
}

  • 测试用例
  • 安装MyBatisX插件
    1. 打开Setting–>打开Plugins–>搜索MyBatisX,安装
    2. 作用:xml和接口方法相互跳转,根据接口方法生成statement
MyBatis完成增删改查 查询 查询所有数据
  1. 编写接口方法:Mapper接口

    • 参数:无

    • 结果:List

    package com.ityc.mapper;
    import com.ityc.pojo.Brand;
    import java.util.List;
    //接口
    public interface BrandMapper {
    
        public List<Brand> selectALL();
    }
    
    
  2. 编写sql语句:SQL映射文件:

    
    DOCTYPE mapper
            PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
            "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    
    <mapper namespace="com.ityc.mapper.BrandMapper">
        
        
    
    
        
        <resultMap id="brandResultMap" type="brand">
            
            <result column="brand_name" property="brandName"/>
            <result column="company_name" property="companyName"/>
        resultMap>
    
    
        <select id="selectALL" resultMap="brandResultMap">
            select *
            from tb_brand;
        select>
        
    mapper>
    
  3. 执行方法,测试

    package com.ityc.test;
    
    import com.ityc.mapper.BrandMapper;
    import com.ityc.pojo.Brand;
    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.InputStream;
    import java.util.List;
    
    public class MyBatisTest {
        @Test
        public void testSelectAll() throws IOException {
            //1 获取 SqlSessionFaction对象
            //加载mybatis的核心配置文件,获取SqlSessionFactory
            String resource = "mybatis-config.xml";
            InputStream inputStream = Resources.getResourceAsStream(resource);
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    
            //获取SqlSession对象
            SqlSession sqlSession = sqlSessionFactory.openSession();
    
            //3. 获取mapper 接口的代理对象
            BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
    
            //4.执行方法
            List<Brand> brands = mapper.selectALL();
            System.out.println(brands);
    
            //5.释放资源
            sqlSession.close();
        }
    }
    

总结:

  1. MyBatis *** 作需要三步:编写接口方法–编写sql–执行方法
  2. 实体类属性名 与数据库列表名 不一致,不能自动封装数据
    • 起别名
    • resultMap:定义完成不一致属性名与列名的映射
查看详情功能
  1. 编写接口方法 Mapper接口

    //在接口中添加如下方法
    Brand selectById(int id);
    

    参数:id

    结果:Brand

  2. 编写SQL语句:sql映射文件

    <select id="selectById"  resultMap="brandResultMap">
            select * from tb_brand where id = #{id};
    select>
    
  3. 执行方法:测试

     @Test
        public void testSelectById() throws IOException {
            int id =2;
    
            //1 获取 SqlSessionFaction对象
            //加载mybatis的核心配置文件,获取SqlSessionFactory
            String resource = "mybatis-config.xml";
            InputStream inputStream = Resources.getResourceAsStream(resource);
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    
            //获取SqlSession对象
            SqlSession sqlSession = sqlSessionFactory.openSession();
    
            //3. 获取mapper 接口的代理对象
            BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
    
            //4.执行方法
    
            Brand brand = mapper.selectById(id);
    
            System.out.println(brand);
    
            //5.释放资源
            sqlSession.close();
        }
    

总结:

  1. 参数占位符
    1. #{}    会替换为?,用来防止sql注入
    2. ${}    拼 sql ,会存在sql注入问题
    3.使用时机:
        *参数传递的时候:#{}
        *表明 列名不固定能使用 ${} 但是只要使用${}就一定存在sql注入问题
    
    *sql语句特殊字符的处理
     1. 转义字符
     2.CDATA区
    
条件查询 1.多条件查询
  1. 编写接口方法Mapper接口

    参数:所有查询条件

    结果:list

    /**
         * 条件查询
         * 参数接收
         * 1.散装的参数:如果方法中有多个参数,需要使用@Param("SQL参数占位符名称")
         * 2.对象的参数:对象属性名称要和参数占位符名称一致
         * 3.Map集合参数
         * @param status
         * @param companyName
         * @param brandName
         * @return
         */
    //1.散装的参数
    List<Brand> selectByCondition(@Param("status") int status,@Param("companyName") String companyName,@Param("brandName") String brandName);
    //2.对象的参数
     List<Brand> selectByCondition(Brand brand);
    // 3.Map集合参数
    List<Brand> selectByCondition(Map map);
    
  2. 编写SQL语句:sql映射文件

     <select id="selectByCondition" resultMap="brandResultMap">
            select *
            from tb_brand
            where status = #{status}
            and company_name like #{companyName}
            and brand_name like #{brandName};
        select>
    
    
  3. 执行方法,测试

    //散装参数
    @Test
        public void testSelectByCondition() throws IOException {
            //定义局部变量,接收参数
            int status =1;
            String companyName = "华为";
            String brandName = "华为";
            //处理参数,因为要模糊查询,所以加上百分号
            companyName ="%"+ companyName +"%";
            brandName ="%"+ brandName +"%";
    
            //1 获取 SqlSessionFaction对象
            //加载mybatis的核心配置文件,获取SqlSessionFactory
            String resource = "mybatis-config.xml";
            InputStream inputStream = Resources.getResourceAsStream(resource);
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    
            //获取SqlSession对象
            SqlSession sqlSession = sqlSessionFactory.openSession();
    
            //3. 获取mapper 接口的代理对象
            BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
    
            //4.执行方法
    
            List<Brand> brands = mapper.selectByCondition(status, companyName, brandName);
    
            System.out.println(brands);
    
            //5.释放资源
            sqlSession.close();
        }
    
    //封装对象
    @Test
        public void testSelectByCondition() throws IOException {
            //定义局部变量,接收参数
            int status =1;
            String companyName = "华为";
            String brandName = "华为";
            //处理参数
            companyName ="%"+ companyName +"%";
            brandName ="%"+ brandName +"%";
    
            //封装对象
            Brand brand = new Brand();
            brand.setStatus(status);
            brand.setCompanyName(companyName);
            brand.setBrandName(brandName);
            /*map集合
             HashMap hashMap = new HashMap();
            hashMap.put("status",status);
            hashMap.put("companyName",companyName);
            hashMap.put("brandName",brandName);
            */
    
            //1 获取 SqlSessionFaction对象
            //加载mybatis的核心配置文件,获取SqlSessionFactory
            String resource = "mybatis-config.xml";
            InputStream inputStream = Resources.getResourceAsStream(resource);
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    
            //获取SqlSession对象
            SqlSession sqlSession = sqlSessionFactory.openSession();
    
            //3. 获取mapper 接口的代理对象
            BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
    
            //4.执行方法
    
            List<Brand> brands = mapper.selectByCondition(brand);
    
            System.out.println(brands);
    
            //5.释放资源
            sqlSession.close();
        }
    

    总结:

    • SQL语句设置多个参数有几种方式

      1.散装的参数:如果方法中有多个参数,需要使用@Param(“SQL参数占位符名称”)

      2.对象的参数:对象属性名称要和参数占位符名称一致

      3.Map集合参数:要保证sql中的参数名和map集合的键的名称对应上,即可设置成功

    • 出现bug,因为用户不会吧全部的3个空都填上,而不填全的话我们代码就会查出空值,

2.单条件动态查询
  • 从多个条件中选择一个

    choose(when,otherwise):选择,类似于java中的switch语句

    
        <select id="selectByConditionSingle" resultMap="brandResultMap">
            select *
            from tb_brand
            where
    #         <choose>
                <when test="status !=null">
                  status = #{status}
                when>
                <when test="companyName!=null and companyName !=''">
                    company_name like #{companyName}
                when>
                <when test="brandName !=null and brand !=''">
                    brand_name like #{brandName}
                when>
            //保底的otherwise,当用户一个都不选时执行
            	<otherwise>
                    1=1
                otherwise>
    
            choose>
    

    测试类

    @Test
        public void testSelectByConditionSingle() throws IOException {
            //定义局部变量,接收参数
            int status =1;
            String companyName = "华为";
            String brandName = "华为";
            //处理参数
            companyName ="%"+ companyName +"%";
            brandName ="%"+ brandName +"%";
    
            //封装对象
             Brand brand = new Brand();
             brand.setStatus(status);
             //brand.setCompanyName(companyName);
             //brand.setBrandName(brandName);
    
            //1 获取 SqlSessionFaction对象
            //加载mybatis的核心配置文件,获取SqlSessionFactory
            String resource = "mybatis-config.xml";
            InputStream inputStream = Resources.getResourceAsStream(resource);
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    
            //获取SqlSession对象
            SqlSession sqlSession = sqlSessionFactory.openSession();
    
            //3. 获取mapper 接口的代理对象
            BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
    
            //4.执行方法
    
            List<Brand> brands = mapper.selectByConditionSingle(brand);
    
            System.out.println(brands);
    
            //5.释放资源
            sqlSession.close();
        }
    
添加

步骤

  1. 编写接口方法
  • 参数:除了id以外的所有数据

  • 结果void

    //添加功能
        void add(Brand brand);
    
  1. 编写SQL语句:sql映射文件

    
      <insert id="add">
          insert into tb_brand(brand_name, company_name, ordered, description, status)
            values(#{brandName},#{companyName},#{ordered},#{description},#{status});
      insert>
    
  2. 执行方法,测试

//添加功能
    @Test
    public void testAdd() throws IOException {
        int status =1;
        String companyName = "旺旺碎冰";
        String brandName ="旺旺";
        String description = "给你哦破";
        int ordered =100;
        //封装对象
        Brand brand = new Brand();
        brand.setStatus(status);
        brand.setCompanyName(companyName);
        brand.setBrandName(brandName);
        brand.setDescription(description);
        brand.setOrdered(ordered);
        //1 获取 SqlSessionFaction对象
        //加载mybatis的核心配置文件,获取SqlSessionFactory
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //获取SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();

        //3. 获取mapper 接口的代理对象
        BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);

        //4.执行方法
        mapper.add(brand);

        //手动提交事务
        sqlSession.commit();
        //5.释放资源
        sqlSession.close();
    }

MyBatis事务
  • openSession():开启事务,进行增删改 *** 作后需要使用sqlSession.commit();手动提交事务

  • openSession(true):可以设置为自动提交事务(关闭事务)

  • 添加----主键返回

    在数据添加成功后,需要获取插入数据库数据的主键的值

    
    <insert id="add" useGeneratedKeys="true" keyProperty="id">insert>
    

    比如:添加订单和订单项

    1.添加订单

    2.添加订单项,订单项中需要设置所属订单的id

修改 修改全部字段

步骤:

1.编写接口方法Mapper

  • 参数,所有数据
  • 结果:void
 //修改
    void update(Brand brand);

2.编写sql语句:sql映射文件


    <update id="update">
        update tb_brand
        set brand_name= #{brandName},
            company_name = #{companyName},
            ordered = #{ordered},
            description = #{description},
            status = #{status}
        where id =#{id};
    update>

3.执行方法,测试

//修改功能
    @Test
    public void testUpdate() throws IOException {
        int status = 1;
        String companyName = "旺旺碎冰";
        String brandName ="哇哇哇哇哇哇哇哇哇哇哇";
        String description = "给你哦破";
        int ordered =200;
        int id =5;
        //封装对象
        Brand brand = new Brand();
        brand.setId(id);
        brand.setStatus(status);
        brand.setCompanyName(companyName);
        brand.setBrandName(brandName);
        brand.setDescription(description);
        brand.setOrdered(ordered);
        //1 获取 SqlSessionFaction对象
        //加载mybatis的核心配置文件,获取SqlSessionFactory
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //获取SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();

        //3. 获取mapper 接口的代理对象
        BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);

        //4.执行方法
        mapper.update(brand);


        //手动提交事务
        sqlSession.commit();
        //5.释放资源
        sqlSession.close();
    }
修改动态字段

因为上面的修改方法会修改所有字段,如果其他字段不填写就会被改为null,太过死板,所以就需要动态sql。

步骤:

1.编写接口方法Mapper

  • 参数,所有数据
  • 结果:void

2.编写sql语句:sql映射文件

   
    <update id="update">
        update tb_brand
        <set>
            <if test="brandName!=null and brandName!=''">
                brand_name = #{brandName}
            if>
            <if test="companyName!=null and companyName != ''">
                company_name = #{companyName}
            if>
            <if test="ordered != null">
                ordered= #{ordered}
            if>
            <if test="description!=null and description !=''">
                description = #{description}
            if>
            <if test="status!=null ">
                status = #{status}
            if>
        set>
        where id = #{id};
    update>

3.执行方法,测试

删除功能 删除单个

步骤:

1.编写接口方法Mapper

  • 参数,id
  • 结果:void

2.编写sql语句:sql映射文件

 
    <delete id="deleteByid">
        delete from tb_brand where id = #{id};
    delete>

3.执行方法,测试

   //删除单个功能
    @Test
    public void testDeleteByid() throws IOException {
       int id= 5;
        //封装对象
        Brand brand = new Brand();
        brand.setId(id);
        //1 获取 SqlSessionFaction对象
        //加载mybatis的核心配置文件,获取SqlSessionFactory
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //获取SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();

        //3. 获取mapper 接口的代理对象
        BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);

        //4.执行方法
        mapper.deleteByid(id);

        //手动提交事务
        sqlSession.commit();
        //5.释放资源
        sqlSession.close();
    }

批量删除

步骤:

1.编写接口方法Mapper

  • 参数,id数组
  • 结果:void
  //批量删除
    //使用@Param 注解来改变Map集合的默认key的名称
    void deleteByids(@Param("ids") int[] ids);

2.编写sql语句:sql映射文件

 
    
        delete from tb_brand
        where id
        in(
        
            #{id}
        
        );
    

3.执行方法,测试

//批量删除功能
    @Test
    public void testDeleteByids() throws IOException {
        int []ids ={6,7,8};
        //封装对象
        Brand brand = new Brand();
        //1 获取 SqlSessionFaction对象
        //加载mybatis的核心配置文件,获取SqlSessionFactory
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //获取SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();

        //3. 获取mapper 接口的代理对象
        BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);

        //4.执行方法
        mapper.deleteByids(ids);

        //手动提交事务
        sqlSession.commit();
        //5.释放资源
        sqlSession.close();
    }

动态SQL
  • SQL语句会随着用户的输入或者外部条件的变化而变化,我们称为动态SQL

  • 动态 SQL 是 MyBatis 的强大特性之一。如果你使用过 JDBC 或其它类似的框架,你应该能理解根据不同条件拼接 SQL 语句有多痛苦,例如拼接时要确保不能忘记添加必要的空格,还要注意去掉列表最后一个列名的逗号。利用动态 SQL,可以彻底摆脱这种痛苦。

  • MyBatis对动态sql有很强大的支撑

  • if:判断参数是否有值:使用test属性进行条件判断,存在问题第一个条件不需要逻辑运算符

  • choose(when,otherwise)

  • trim(where,set):where标签替换关键词where,帮我们解决if中存在的问题

  • foreach

例:

<select id="selectByCondition" resultMap="brandResultMap">
        select *
        from tb_brand
        <where>
            <if test="status !=null">
                and status = #{status}
            if>
            <if test="companyName!=null and companyName!=''">
                and company_name like #{companyName}
            if>
            <if test="brandName!=null and brandName!=''">
                and brand_name like #{brandName};
            if>
        where>
select>

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/langs/724688.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-04-26
下一篇 2022-04-26

发表评论

登录后才能评论

评论列表(0条)

保存