import lombok.Data;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name = "goods")
@Data
public class Goods {
    @Id
    private Long goodsId;
    private String goodsName;
    private Long goodsType;
}

package com.shardingjdbc.sharding.controller;

import com.shardingjdbc.sharding.entity.Goods;
import com.shardingjdbc.sharding.service.GoodsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.ArrayList;
import java.util.List;

@RestController
@RequestMapping("api/" + "goods")
public class GoodsController {

    @Autowired
    GoodsService goodsService;

    @PostMapping
    public String saveGoods() {
       goodsService.saveGoods();
        return "success";
    }

    @GetMapping
    public List<Goods> listGoods() {
        return goodsService.listAllGoods();
    }

    @DeleteMapping
    public String deleteAllGoods() {
        goodsService.deleteAllGoods();
        return "delete success";
    }

    @GetMapping("/betweenGoodsId")
    public List<Goods> queryBetweenGoodsIds() {
        // 单行表达式不支持 范围查询 Inline strategy cannot support range sharding
        return goodsService.listAllByGoodsIdBetween(2L, 2L);
    }

    @GetMapping("/inGoodsId")
    public List<Goods> queryInGoodsIds() {
        List<Long> goodsIds = new ArrayList<>();
        goodsIds.add(3L);
        goodsIds.add(6L);
        return goodsService.listAllByGoodsIdIn(goodsIds);
    }
}

package com.shardingjdbc.sharding.service;

import com.shardingjdbc.sharding.entity.Goods;
import java.util.List;

public interface GoodsService {

   void saveGoods();

    List<Goods> listAllGoods();

    void deleteAllGoods();

    List<Goods> listAllByGoodsIdBetween(long start, long end);

    List<Goods> listAllByGoodsIdIn(List<Long> goodsIds);
}

package com.shardingjdbc.sharding.service.ServiceImpl;

import com.shardingjdbc.sharding.entity.Goods;
import com.shardingjdbc.sharding.repository.GoodsRepository;
import com.shardingjdbc.sharding.service.GoodsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;

@Service
public class GoodsServiceImpl implements GoodsService {

    @Autowired
    private GoodsRepository goodsRepository;

    @Override
    @Transactional
    public void saveGoods() {
        Goods goods = new Goods();
        for (int i = 1; i <= 40; i++) {
            goods.setGoodsId((long) i);
            goods.setGoodsName("shangpin" + i);
            goods.setGoodsType((long) (i + 1));
            goodsRepository.save(goods);
        }
    }

    @Override
    public List<Goods> listAllGoods() {
        return goodsRepository.findAll();
    }

    @Override
    @Transactional
    public void deleteAllGoods() {
        goodsRepository.deleteAll();
    }

    @Override
    public List<Goods> listAllByGoodsIdBetween(long start, long end) {
        return goodsRepository.findAllByGoodsIdBetween(start, end);
    }

    @Override
    public List<Goods> listAllByGoodsIdIn(List<Long> goodsIds) {
        return goodsRepository.findAllByGoodsIdIn(goodsIds);
    }
}

package com.shardingjdbc.sharding.repository;

import com.shardingjdbc.sharding.entity.Goods;
import org.springframework.data.jpa.repository.JpaRepository;
import java.util.List;

public interface GoodsRepository extends JpaRepository<Goods, Long> {

    List<Goods> findAllByGoodsIdBetween(Long goodsId1, Long goodsId2);

    List<Goods> findAllByGoodsIdIn(List<Long> goodsIds);
}

package com.shardingjdbc.sharding;

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication(exclude = {DruidDataSourceAutoConfigure.class})
public class ShardingApplication {
    public static void main(String[] args) {
        SpringApplication.run(ShardingApplication.class, args);
    }
}