如何高效实现Vona ORM分表策略?

摘要:针对高并发、数据量大的场景,通常会考虑采用分表机制进行优化。下面以 Model UserOrder 为例,通过查询用户的订单列表,来演示分表的使用方法
分表 针对高并发、数据量大的场景,通常会考虑采用分表机制进行优化。下面以 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: 指定 relation orders要使用的表名 到目前为止,使用默认表名查询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