Vona ORM分表全攻略
发布于 2 小时前 作者 zhennann 19 次浏览 来自 分享

分表

针对高并发、数据量大的场景，通常会考虑采用分表机制进行优化。下面以 Model User/Order 为例，通过查询用户的订单列表，来演示分表的使用方法

分表规则

比如需要对订单表进行分表操作。可以根据实际业务需求设计分表规则，在这里，根据用户Id取模动态生成表名。比如，拆分为16张表，用户Id为129，对应的表名如下：

const tableName = `Order_${129 % 16}`;  // Order_1

准备Models

先准备两个 Models：User/Order

  1. Model Order
@Model({
  entity: EntityOrder,
})
class ModelOrder{}
  1. Model User
@Model({
  entity: EntityUser,
  relations: {
    orders: $relation.hasMany(() => ModelOrder, 'userId'),
  },
})
class ModelUser {}

查询数据

1. 直接查询订单列表

class ServiceOrder {
  async selectOrdersDirectly() {
    const userId = 129;
    const orders = await this.scope.model.order.select({
      where: {
        userId,
      },
    });
  }
}

到目前为止，使用默认表名查询userId=129的订单列表

2. 基于关系查询订单列表

class ServiceOrder {
  async selectOrdersByRelation() {
    const userId = 129;
    const userAndOrders = await this.scope.model.user.get({
      id: userId,
    }, {
      include: {
        orders: true,
      },
    });
  }
}

到目前为止，使用默认表名查询userId=129的用户信息，使用默认表名查询该用户的订单列表

使用分表：动态方式

可以在代码中动态使用分表：

class ServiceOrder {
  async selectOrdersDirectly() {
    const userId = 129;
+   const tableName = `Order_${userId % 16}`;
+   const modelOrder = this.scope.model.order.newInstance(undefined, tableName as any);
    const orders = await modelOrder.select({
      where: {
        userId,
      },
    });
  }
}
  • newInstance: 传入要使用的表名，返回新的 Model 实例

到目前为止，使用分表查询userId=129的订单列表

使用分表：Relation动态选项

可以在 relation 选项中动态指定表名：

class ServiceOrder {
  async selectOrdersByRelation() {
    const userId = 129;
+   const tableName = `Order_${userId % 16}`;
    const userAndOrders = await this.scope.model.user.get({
      id: userId,
    }, {
      include: {
        orders: {
+         meta: {
+           table: tableName as any,
+         },
        },
      },
    });
  }
}
  • meta.table: 指定 relation orders要使用的表名

到目前为止，使用默认表名查询userId=129的用户信息，使用分表查询该用户的订单列表

使用分表：Model配置

也可以直接在 Model 中配置分表规则，从而简化查询代码

  1. Model Order
@Model({
  entity: EntityOrder,
+ table(_ctx: VonaContext, where: EntityOrder | undefined, defaultTable: keyof ITableRecord) {
+   const userId = where?.userId;
+   if (!userId) return defaultTable;
+   return `Order_${Number(userId) % 16}`;
+ },
})
class ModelOrder{}
  • table: 指定函数，实现分表规则
  1. 查询数据

现在，又可以使用常规的方式查询用户的订单列表

class ServiceOrder {
  async selectOrdersDirectly() {
    const userId = 129;
    const orders = await this.scope.model.order.select({
      where: {
        userId,
      },
    });
  }
}  

class ServiceOrder {
  async selectOrdersByRelation() {
    const userId = 129;
    const userAndOrders = await this.scope.model.user.get({
      id: userId,
    }, {
      include: {
        orders: true,
      },
    });
  }
}

使用分表：App Config配置

也可以在 App config 中配置 Model options:

src/backend/config/config/config.ts

// onions
config.onions = {
  model: {
    'test-vona:order': {
      table(_ctx: VonaContext, where: EntityOrder | undefined, defaultTable: keyof ITableRecord) {
        const userId = where?.userId;
        if (!userId) return defaultTable;
        return `Order_${Number(userId) % 16}`;
      },
    },
  },
};

于是，也可以使用常规的方式查询用户的订单列表

使用分表：Relation静态选项

也可以在定义 Relation 时指定静态选项：

@Model({
  entity: EntityUser,
  relations: {
    orders: $relation.hasMany(() => ModelOrder, 'userId', {
+     meta: {
+       table(_ctx: VonaContext, where: EntityOrder | undefined, defaultTable: keyof ITableRecord) {
+         const userId = where?.userId;
+         if (!userId) return defaultTable;
+         return `Order_${Number(userId) % 16}`;
+       },
+     },
    }),
  },
})
class ModelUser {}

同样，也可以使用常规的方式查询用户的订单列表

Vona ORM已开源：github.com/vonajs/vona

回到顶部