TestBatchController.java 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package com.ruoyi.demo.controller;
  2. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  3. import com.ruoyi.common.core.controller.BaseController;
  4. import com.ruoyi.common.core.domain.AjaxResult;
  5. import com.ruoyi.demo.domain.TestDemo;
  6. import com.ruoyi.demo.service.ITestDemoService;
  7. import io.swagger.annotations.Api;
  8. import io.swagger.annotations.ApiOperation;
  9. import lombok.RequiredArgsConstructor;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.web.bind.annotation.DeleteMapping;
  12. import org.springframework.web.bind.annotation.PostMapping;
  13. import org.springframework.web.bind.annotation.RequestMapping;
  14. import org.springframework.web.bind.annotation.RestController;
  15. import java.util.ArrayList;
  16. import java.util.List;
  17. /**
  18. * 测试批量方法
  19. *
  20. * @author Lion Li
  21. * @date 2021-05-30
  22. */
  23. @Api(value = "测试批量方法", tags = {"测试批量方法"})
  24. @RequiredArgsConstructor(onConstructor_ = @Autowired)
  25. @RestController
  26. @RequestMapping("/demo/batch")
  27. public class TestBatchController extends BaseController {
  28. private final ITestDemoService iTestDemoService;
  29. /**
  30. * 新增批量方法 可完美替代 saveBatch 秒级插入上万数据 (对mysql负荷较大)
  31. */
  32. @ApiOperation(value = "新增批量方法")
  33. @PostMapping()
  34. // @DataSource(DataSourceType.SLAVE)
  35. public AjaxResult<Void> add() {
  36. List<TestDemo> list = new ArrayList<>();
  37. for (int i = 0; i < 10; i++) {
  38. TestDemo testDemo = new TestDemo();
  39. if (i % 2 == 0) {
  40. list.add(testDemo.setId((long) i + 1).setTestKey("批量更新").setValue("批量更新"));
  41. } else {
  42. list.add(testDemo.setOrderNum(-1L).setTestKey("批量新增").setValue("测试新增"));
  43. }
  44. }
  45. return toAjax(iTestDemoService.saveAll(list) ? 1 : 0);
  46. }
  47. /**
  48. * 删除批量方法
  49. */
  50. @ApiOperation(value = "删除批量方法")
  51. @DeleteMapping()
  52. // @DataSource(DataSourceType.SLAVE)
  53. public AjaxResult<Void> remove() {
  54. return toAjax(iTestDemoService.remove(new LambdaQueryWrapper<TestDemo>()
  55. .eq(TestDemo::getOrderNum, -1L)) ? 1 : 0);
  56. }
  57. }