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 实现局域网文件传输的实例

    java 实现局域网文件传输的实例

    这篇文章主要介绍了java 实现局域网文件传输的实例的相关资料,这里提供了实现代码可以帮助大家理解TCP及文件读写的知识,需要的朋友可以参考下
    2017-07-07
  • 如何基于java实现解压ZIP TAR等文件

    如何基于java实现解压ZIP TAR等文件

    这篇文章主要介绍了如何基于java实现解压ZIP TAR等文件,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • java单链表逆序用法代码示例

    java单链表逆序用法代码示例

    这篇文章主要介绍了java单链表逆序用法代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-01-01
  • Spring  AOP的两种使用方法

    Spring  AOP的两种使用方法

    这篇文章主要介绍了Spring AOP的两种使用方法,文章围绕主题展开详细的内容介绍,具有一定的参考价值,需要的小伙伴可以参考一下
    2022-08-08
  • IntelliJ IDEA 部署 Web 项目,看这一篇够了!

    IntelliJ IDEA 部署 Web 项目,看这一篇够了!

    这篇文章主要介绍了IntelliJ IDEA 部署 Web 项目的图文教程,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-05-05
  • java线程之死锁

    java线程之死锁

    这篇文章主要介绍了Java线程之死锁,死锁是这样一种情形-多个线程同时被阻塞,它们中的一个或者全部都在等待某个资源被释放。由于线程被无限期地阻塞,因此程序不可能正常终止
    2022-05-05
  • 2024版本IDEA创建Servlet模板的图文教程

    2024版本IDEA创建Servlet模板的图文教程

    新版IDEA 2024.1.4中,用户需要自行创建Servlet模板以解决Web项目无法通过右键创建Servlet的问题,本文详细介绍了添加ServletAnnotatedClass.java模板的步骤,帮助用户快速配置并使用新的Servlet模板,需要的朋友可以参考下
    2024-10-10
  • 快速解决Hash碰撞冲突的方法小结

    快速解决Hash碰撞冲突的方法小结

    这篇文章主要介绍了快速解决Hash碰撞冲突的方法小结,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-09-09
  • Springboot启动同时创建数据库和表实现方法

    Springboot启动同时创建数据库和表实现方法

    这篇文章主要介绍了Springboot启动同时创建数据库和表,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习吧
    2023-01-01
  • Spring boot自定义http反馈状态码详解

    Spring boot自定义http反馈状态码详解

    这篇文章主要给大家介绍了Spring boot自定义http反馈状态码的相关资料,文中介绍的非常详细,对大家具有一定的参考学习价值,需要的朋友们下面跟着小编一起来学习学习吧。
    2017-06-06

最新评论