分表
针对高并发、数据量大的场景,通常会考虑采用分表机制进行优化。下面以 Model User/Order 为例,通过查询用户的订单列表,来演示分表的使用方法
分表规则
比如需要对订单表进行分表操作。可以根据实际业务需求设计分表规则,在这里,根据用户Id取模动态生成表名。比如,拆分为16张表,用户Id为129,对应的表名如下:
const tableName = `Order_${129 % 16}`; // Order_1
准备Models
先准备两个 Models:User/Order
- Model Order
@Model({ entity: EntityOrder, }) class ModelOrder{}
- 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: 指定 relationorders要使用的表名
到目前为止,使用默认表名查询userId=129的用户信息,使用分表查询该用户的订单列表
使用分表:Model配置
也可以直接在 Model 中配置分表规则,从而简化查询代码
- 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: 指定函数,实现分表规则
- 查询数据
现在,又可以使用常规的方式查询用户的订单列表
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