Skip to content

sharding

jwpttcg66 edited this page Apr 18, 2017 · 3 revisions

分库分表

每个实体保存服务,实现getEntityServiceShardingStrategy函数集成EntityServiceShardingStrategy

代码例子

@Service
public class OrderService extends EntityService<Order> implements IOrderService{


    public long insertOrder(Order order) {
        return insertEntity(order);
    }

    @Override
    public Order getOrder(long userId, long id) {
        Order order = new Order();
        order.setUserId(userId);
        order.setId(id);
        return (Order) getEntity(order);
    }

    @Override
    public List<Order> getOrderList(long userId) {
        Order order = new Order();
        order.setUserId(userId);
        return getEntityList(order);
    }

    @Override
    public List<Order> getOrderList(long userId, String status) {
        Order order = new Order();
        order.setUserId(userId);
        order.setStatus(status);
        return getEntityList(order);
    }

    @Override
    public void updateOrder(Order order) {
        updateEntity(order);
    }

    @Override
    public void deleteOrder(Order order) {
        deleteEntity(order);
    }

    @Override
    public List<Long> insertOrderList(List<Order> order) {
        return insertEntityBatch(order);
    }

    @Override
    public void updateOrderList(List<Order> order) {
        updateEntityBatch(order);
    }

    @Override
    public void deleteOrderList(List<Order> order) {
        deleteEntityBatch(order);
    }

    @Override
    public EntityServiceShardingStrategy getEntityServiceShardingStrategy() {
        return getDefaultEntityServiceShardingStrategy();
    }
}
Clone this wiki locally