java新增关联的三张表,每张表要求都插入集合,代码实现方式

 更新时间:2023年12月13日 09:16:04   作者:程序猿不秃头  
这篇文章主要介绍了java新增关联的三张表,每张表要求都插入集合,代码实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

一、表

1.第一张表

表名:goods_sell_attribute

goods_sell_attribute

2.第二张表

表名:goods_sell_attribute_value

以第一张表的name_id关联

在这里插入图片描述

3.第三张表

表名:goods_sub_attribute_value

以第二张表的value_id关联

在这里插入图片描述

二、实体类

1.第一张表的实体类

// lombok
@Data
public class GoodsSellAttributeDTO {
    private Integer nameId;
    private Integer valueId;
    private Integer firstLevelId;
    private String  firstLevelName;
    private Integer secondLevelId;
    private String secondLevelName;
    private Integer thirdLevelId;
    private String thirdLevelName;
    private String attributeName;
    private String required;
    // 放入第二张表的DTO
    private List<GoodsSellAttributeValueDTO> goodsSellAttributeValueDTO;

2.第二张表的实体类

@Data
public class GoodsSellAttributeValueDTO {
    private Integer nameId;
    private String attributeValue;
    private Integer valueId;
    // 放入第三张表的DTO
    private List<GoodsSubAttributeValueDTO> goodsSubAttributeValueDTO;
    }

3.第三张表的是实体类

@Data
public class GoodsSubAttributeValueDTO {
    private Integer valueId;
    private String  subValue;
    }

三、在xml中sql的编写

1.第一张表的新增sql

   <!--第一张表的新增 -->
    <insert id="insertGoodsSellAttributes" keyProperty="nameId" useGeneratedKeys="true" parameterType="com.dy.mallConfig.pojo.dto.GoodsSellAttributeDTO">
        INSERT INTO goods_sell_attribute
                (first_level_id,
                second_level_id,
                third_level_id,
            first_level_name,
            second_level_name,
            third_level_name,
            attribute_name,
            required,
            status)
            VALUES
        <foreach collection="list" separator="," item="item" index="index">
                (#{item.firstLevelId},
                #{item.secondLevelId},
                #{item.thirdLevelId},
            #{item.firstLevelName},
            #{item.secondLevelName},
            #{item.thirdLevelName},
            #{item.attributeName},
            #{item.required},
            '1')
        </foreach>
    </insert>

2.第二张表的新增sql

<!-- 第二张表-->
    <insert id="insertGoodsSellAttributeValues" keyProperty="valueId" useGeneratedKeys="true" parameterType="com.dy.mallConfig.pojo.dto.GoodsSellAttributeValueDTO">
        INSERT INTO goods_sell_attribute_value
            (name_id,attribute_value,status) VALUES
        <foreach collection="list" index="goodsIndex" item="item" separator="),(" open="(" close=")" >
            #{item.nameId},
            #{item.attributeValue,jdbcType=VARCHAR},
            '1'
        </foreach>
    </insert>

3.第三张表的新增sql

<!-- 第三张表-->
<insert id="insertGoodsSubAttributeValue" parameterType="com.dy.mallConfig.pojo.dto.GoodsSellAttributeValueDTO">
        INSERT INTO goods_sub_attribute_value
            (value_id,
            sub_value,
            status)
            VALUES
        <foreach collection="list" separator="," index="index" item="items">
        <foreach collection="items.goodsSubAttributeValueDTO" item="items1" index="index" separator="),(" open="(" close=")">
            #{items.valueId},
            #{items1.subValue},
            '1'
        </foreach>
        </foreach>
    </insert>

四、mapper层

// 第一张表
int insertGoodsSellAttributes(List<GoodsSellAttributeDTO> goodsSellAttributeDTO);
// 第二张表
    int insertGoodsSellAttributeValues(List<GoodsSellAttributeValueDTO> goodsSellAttributeValueDTO);
// 第三张表
    int insertGoodsSubAttributeValue(List<GoodsSellAttributeValueDTO> goodsSellAttributeValueDTO);

五、service层

// 接口
OutputObject insertGoodsSellAttributes(List<GoodsSellAttributeDTO> goodsSellAttributeDTO);

六、serviceImpl层

@Service
public class GoodsSellAttributeServiceImpl implements GoodsSellAttributeService {
    /**
     * 添加Log日志
     * @author zhushaojie
     */
    private static final Logger LOGGER = LoggerFactory.getLogger(com.dy.mallConfig.service.impl.GoodsSellAttributeServiceImpl.class);

    @Autowired
    private GoodsSellAttributeMapper goodsSellAttributeMapper;
    
	@Override
	// 事务注解
    @Transactional(rollbackFor = Exception.class)
    public OutputObject insertGoodsSellAttributes(List<GoodsSellAttributeDTO> goodsSellAttributeDTO) {
        try {
            // 批量添加一级属性
            int i = goodsSellAttributeMapper.insertGoodsSellAttributes(goodsSellAttributeDTO);

             // 将商品属性和属性子属性中 抽离出来
            List<GoodsSellAttributeValueDTO> goodsSellAttributeValueDTO = goodsSellAttributeDTO.stream()
                    .flatMap(o -> o.getGoodsSellAttributeValueDTO().stream().peek(s -> {
                        s.setNameId(o.getNameId());
                    })).collect(Collectors.toList());
            if (i > 0 || goodsSellAttributeValueDTO.size()>0) {
                // 一级属性添加完后,回调一级id添加到二级当中,进行新增操作
                int i1 = goodsSellAttributeMapper.insertGoodsSellAttributeValues(goodsSellAttributeValueDTO);

                List<List<GoodsSubAttributeValueDTO>>  goodsSubAttributeValueDTO= goodsSellAttributeValueDTO.stream().map(GoodsSellAttributeValueDTO::getGoodsSubAttributeValueDTO)
                        .collect(Collectors.toList());
                if (i1 > 0 && goodsSubAttributeValueDTO.get(0)!=null) {
                    // 二级属性添加完后,回调二级id添加到二级当中,进行新增操作
                    goodsSellAttributeMapper.insertGoodsSubAttributeValue(goodsSellAttributeValueDTO);
                }
                return new OutputObject(ReturnCode.SUCCESS, "添加成功", "添加成功");

            }else {
                return new OutputObject(ReturnCode.FAIL, "添加失败", goodsSellAttributeDTO);
            }

        }catch (Exception e){
            // 事务回滚
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return new OutputObject(ReturnCode.FAIL, "添加失败", e.getMessage());
        }
        }


}

七、Controller

@RequestMapping("/insertGoodsSellAttributes")
    @ResponseBody
    public OutputObject insertGoodsSellAttributes(@RequestBody List<GoodsSellAttributeDTO> goodsSellAttributeDTO){
        return goodsSellAttributeService.insertGoodsSellAttributes(goodsSellAttributeDTO);
    }

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java线程编程中Thread类的基础学习教程

    Java线程编程中Thread类的基础学习教程

    这篇文章主要介绍了Java线程编程中Thread类的基础学习教程,Thread类包含诸多操作线程的方法,非常重要,需要的朋友可以参考下
    2015-12-12
  • Java如何使用spire进行word文档的替换详解

    Java如何使用spire进行word文档的替换详解

    创作一份文案经常会高频率地使用某些词汇,如地名、人名、人物职位等,若表述有误,就需要整体撤换,下面这篇文章主要给大家介绍了关于Java如何使用spire进行word文档的替换的相关资料,需要的朋友可以参考下
    2023-01-01
  • Java多线程start()方法原理解析

    Java多线程start()方法原理解析

    这篇文章主要介绍了Java多线程start()方法原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • JavaWeb 实现多个文件压缩下载功能

    JavaWeb 实现多个文件压缩下载功能

    文件下载时,我们可能需要一次下载多个文件,批量下载文件时,需要将多个文件打包为zip,然后再下载。本文给大家分享实现思路及具体实现代码,对javaweb实现文件压缩下载功能感兴趣的朋友一起学习吧
    2017-07-07
  • MybatisPlus自定义Sql实现多表查询的示例

    MybatisPlus自定义Sql实现多表查询的示例

    这篇文章主要介绍了MybatisPlus自定义Sql实现多表查询的示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • SpringBoot+MyBatis Plus实现update_time字段自动更新详解

    SpringBoot+MyBatis Plus实现update_time字段自动更新详解

    在 Spring Boot + MyBatis Plus 中实现 update_time 字段自动更新,可通过 ​​MyBatis Plus 的自动填充(Auto Fill)功能​​ 完成,下面小编就来和大家详细介绍一下吧
    2025-07-07
  • IDEA Debug启动tomcat报60659端口占用错误的解决

    IDEA Debug启动tomcat报60659端口占用错误的解决

    工作中将开发工具由Eclipse转为IntelliJ IDEA,在使用过程中遇到许多问题,其中60659端口占用错误对于不熟悉IDEA的开发者来说或许会比较头痛,本文就来解决一下这个问题
    2018-11-11
  • 详解java中的互斥锁信号量和多线程等待机制

    详解java中的互斥锁信号量和多线程等待机制

    这篇文章主要介绍了Java编程中的互斥锁,信号量和多线程等待机制实例详解,简单介绍了互斥锁和信号量的区别,需要的朋友可以了解下。
    2017-09-09
  • 一文详解SpringBoot使用Kafka如何保证消息不丢失

    一文详解SpringBoot使用Kafka如何保证消息不丢失

    这篇文章主要为大家详细介绍了SpringBoot使用Kafka如何保证消息不丢失的相关知识,文中的示例代码讲解详细,有需要的小伙伴可以参考一下
    2025-01-01
  • SpringBoot 创建获取yml里配置字段值

    SpringBoot 创建获取yml里配置字段值

    在Spring Boot中通过@ConfigurationProperties绑定YML配置,创建Bean并提供访问方法,实现根据配置字段动态处理业务逻辑,具有一定的参考价值,感兴趣的可以了解一下
    2025-06-06

最新评论