分表
针对高并发、数据量大的场景,通常会考虑采用分表机制进行优化。下面以 Model User/Order 为例,通过查询用户的订单列表,来演示分表的使用方法
分表规则
比如需要对订单表进行分表操作。可以根据实际业务需求设计分表规则,在这里,根据用户Id取模动态生成表名。比如,拆分为16张表,用户Id为129,对应的表名如下:- const tableName = `Order_${129 % 16}`; // Order_1
复制代码 准备Models
先准备两个 Models:User/Order
- @Model({
- entity: EntityOrder,
- })
- class ModelOrder{}
复制代码- @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 中配置分表规则,从而简化查询代码
- @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{}
复制代码 现在,又可以使用常规的方式查询用户的订单列表- 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
来源:程序园用户自行投稿发布,如果侵权,请联系站长删除
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作! |