Skip to content

微服务返回数据集成<br>integration the multi result of micro-service

Notifications You must be signed in to change notification settings

Dreamroute/grator

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

21 Commits
 
 
 
 
 
 
 
 

Repository files navigation

0.Get Start...

<dependency>
    <groupId>com.github.dreamroute</groupId>
    <artifactId>grator</artifactId>
    <version>newest version</version>
</dependency>

1.为什么要使用微服务数据集?

  • 由于微服务拆分比较细,往往在一个服务里面无法进行数据库的inner join或者left/right join操作,而需要查询多个服务,那么查询多个服务的返回结果如组合成为一个结果(对象或者json), 数据集就是提供组合多个微服务查询结果的工具,类似于单库的join操作。
  • 举例:前端查询订单需要显示订单相关的买家信息
    • 订单服务查询出订单对象 Order[id=1, price=1.2, num=3, userId=10];
    • 用户服务查询出用户对象 User[id=10, name="Jay", email="jay@xxx.com"]
    • 此时需要返回给前端Order,并且Order内部包含了User对象的,如果是单库,那么select * from order o left join user u on o.user_id = u.id,利用mybatis或者Hibernate的ORM能力,可以返回Order对象
    • 然而此刻订单和用户未在同一个库,无法进行跨库的join操作,所以首先需要将Order和User单独查出,再人工进行合并数据
    • 利用Grator这样实现:Order odr = QueryBuilder.newInstance().many2one(order, "userId", "addrId").association(user, "id", "user").association(addr, "id", "addr").result(Order.class);和mybatis很类似

2.作者提醒

  • ORM解决的主要关系:一对一,一对多,多对一,多对多;
  • 开发该工具主要致力于花20%的时间解决80%的问题,一对一足够简单(可以理解成为多对一),多对多由于存在中间表,关闭相对复杂,如果通过此工具解决,传入的参数过多,不太优雅,所以该工具 直接放弃多对多的支持,实际业务场景中多对多相对较少,而且即便是有,往往也伴随着比较复杂的业务逻辑,很少有直接3个表关联查询。
  • 该工具支持单个对象或者集合类型的集成。

3.使用方法(以实际场景为例)

  • 工具使用类似于建造者模式;
  • 1.创建工具对象:QueryBuilder.newInstance()
  • 2.关联管理(多对一,一对多,二选一),方法为分别为:many2one和one2many
  • 3.参数,工具由于参数较多,采用链式调用方式:
    • 多对一:many2one(Object master, String... foreignKeys);第一个为外层对象,第二个为多对一的外键,association(user, "id", "user"),第一个参数为内部对象,第二个为内部对象主键,第三个为内部 对象在外部对象中的属性名称;
    • 一对多:one2many(Object master, String pk);第一个为外层对象,第二个为“一”的一方的主键;collection(orders, "userId", "orders"),第一个参数为内部对象,第二个为内部对象的外键,第三个为内部 对象在外部对象中的属性名称;
  • 该工具可以实现类似超过两张表的集成,同样采用链式调用,比如多对一,可以多个association,类似这样: Order odr = QueryBuilder.newInstance() .many2one(order, "userId", "addrId") .association(user, "id", "user") .association(addr, "id", "addr") .result(Order.class);
  • 返回值:目前返回值只支持2种,一种是外层对象类型,另外一种是json,需要调用result方法进行传入参数类型,返回json传入参数为String.class

4.目前工具存在的问题:

  • 由于工具内部涉及到大量的反射调用,因为工作比较繁忙,所以暂时为增加缓存功能,后续会陆续加上

5.兼容性:JDK7+

6.举例(单元测试中有这些例子):

package com.bdfint.grator.util;

import java.math.BigDecimal; import java.util.ArrayList; import java.util.List;

import org.junit.Test;

import com.bdfint.grator.QueryBuilder; import com.bdfint.grator.util.domain.Addr; import com.bdfint.grator.util.domain.Order; import com.bdfint.grator.util.domain.User;

public class GratorTest {

/**
 * 多对一:单个对象
 */
@Test
public void many2oneTest() {

    Order order = new Order();
    order.setId(1L);
    order.setPrice(new BigDecimal("1.2"));
    order.setNum(3);
    order.setUserId(100L);
    order.setAddrId(10L);

    User user = new User();
    user.setId(100L);
    user.setName("w.dehai");
    user.setEmail("342252328@qq.com");

    Addr addr = new Addr();
    addr.setId(10L);
    addr.setName("四川成都");

    Order odr = QueryBuilder.newInstance()
            .many2one(order, "userId", "addrId")
            .association(user, "id", "user")
            .association(addr, "id", "addr")
            .result(Order.class);
    System.err.println(odr);

}

/**
 * 多对一:集合类型
 */
@Test
public void many2oneCollectionTest() {
    List<Order> orders = new ArrayList<>();
    for (int i = 0; i < 3; i++) {
        Order order = new Order();
        order.setId(Long.valueOf(i));
        order.setPrice(new BigDecimal(String.valueOf(i + 1.2)));
        order.setUserId(Long.valueOf(i));
        orders.add(order);
    }
    
    List<User> users = new ArrayList<>();
    for (int i = 0; i < 3; i++) {
        User user = new User();
        user.setId(Long.valueOf(i));
        user.setName("w.dehai" + i);
        users.add(user);
    }
    
    List<?> orderList = QueryBuilder.newInstance().many2one(orders, "userId").association(users, "id", "user").result(List.class);
    System.err.println(orderList);
}

/**
 * 一对多:单个对象
 */
@Test
public void one2manyTest() {

    User user = new User();
    user.setId(100L);
    user.setName("w.dehai");
    user.setEmail("342252328@qq.com");

    List<Order> orders = new ArrayList<>();
    for (int i = 0; i < 3; i++) {
        Order order = new Order();
        order.setId(Long.valueOf(i));
        order.setNum(3);
        order.setPrice(new BigDecimal("1.2"));
        order.setUserId(100L);
        orders.add(order);
    }

    List<Addr> addrs = new ArrayList<>();
    for (int i = 0; i < 3; i++) {
        Addr addr = new Addr();
        addr.setId(Long.valueOf(i));
        addr.setName("四川成都" + i);
        addr.setUserId(100L);
        addrs.add(addr);
    }

    User result = QueryBuilder.newInstance().one2many(user, "id").collection(orders, "userId", "orders").collection(addrs, "userId", "addrs").result(User.class);
    String resultStr = QueryBuilder.newInstance().one2many(user, "id").collection(orders, "userId", "orders").collection(addrs, "userId", "addrs").result(String.class);
    System.err.println(result);
    System.err.println(resultStr);

}

/**
 * 一对多:集合类型
 */
@Test
public void one2manyCollectionTest() {

    List<User> users = new ArrayList<>();
    for (int i = 0; i < 2; i++) {
        User user = new User();
        user.setId(100L + i);
        user.setName("w.dehai");
        user.setEmail("342252328@qq.com");
        users.add(user);
    }

    List<Order> orders = new ArrayList<>();
    for (int i = 0; i < 3; i++) {
        Order order = new Order();
        order.setId(Long.valueOf(i));
        order.setNum(3);
        order.setPrice(new BigDecimal("1.2"));
        order.setUserId(100L + i);
        orders.add(order);
    }

    List<Addr> addrs = new ArrayList<>();
    for (int i = 0; i < 3; i++) {
        Addr addr = new Addr();
        addr.setId(Long.valueOf(i));
        addr.setName("四川成都" + i);
        addr.setUserId(100L);
        addrs.add(addr);
    }

    List<?> result = QueryBuilder.newInstance().one2many(users, "id").collection(orders, "userId", "orders").collection(addrs, "userId", "addrs").result(List.class);
    String resultStr = QueryBuilder.newInstance().one2many(users, "id").collection(orders, "userId", "orders").collection(addrs, "userId", "addrs").result(String.class);
    System.err.println(result);
    System.err.println(resultStr);

}

}



## 更新日志:
* 2018-05-13 内部上线;
* 2018-05-31 缓存功能上线,对用户透明,兼容以往接口;

About

微服务返回数据集成<br>integration the multi result of micro-service

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages