Sequelize实现用户独立SQLite分库的Model定义方案

一、架构方案合理性说明 #

这个架构本身是可行的，适配单租户强数据隔离的场景非常合适——SQLite单文件存储的特性和每用户独立库的需求天然契合，比单库加user_id字段过滤的方案隔离性更强，也能降低单库SQLite并发写锁的性能影响。但你当前的实现缺了几个必要环节，直接上线会出问题：

• 必须加实例缓存：同一个用户ID重复调用数据库初始化方法时，不要反复创建Sequelize实例，否则会出现连接泄漏、重复初始化模型报错、内存占用过高的问题。用全局Map做用户ID到实例的映射即可，第一次访问初始化，后续直接返回缓存实例。
• 要做资源生命周期管理：如果用户量较大，建议给缓存加LRU淘汰策略，限制最大缓存实例数，定期清理长期不活跃的用户数据库实例，释放文件句柄和内存。
• 必须保证模型和实例一一绑定：严禁跨数据库实例混用模型，否则会出现数据写入错误用户库的严重问题。
• 提前创建存储目录：SQLite不会自动创建多层不存在的文件路径，初始化实例前要先检查对应用户的数据库目录是否存在，不存在则递归创建。

二、模型通用定义+延迟绑定实现方法 #

Sequelize原生支持模型类延迟绑定，不需要把模型定义写在db函数的闭包内。你只需要把模型类定义和实例初始化逻辑拆开，在创建对应Sequelize实例时传入实例完成绑定即可，可直接复用以下实现：

1. 重构模型定义，拆分类定义和初始化逻辑 #

不要在模块顶层直接调用Model.init()绑定实例，先单独定义通用模型类，再导出初始化方法接收Sequelize实例：

//--- field.ts ---
import { DataTypes, Model, Sequelize } from 'sequelize'

// 通用模型类定义，所有实例通用的属性、方法都写在这里
export class Field extends Model {
  declare name: string
}

// 模型初始化方法，接收指定用户的Sequelize实例完成绑定
export function initFieldModel(sequelize: Sequelize) {
  Field.init(
    {
      name: { type: DataTypes.STRING, allowNull: false }
    },
    {
      sequelize,
      modelName: 'Field',
      tableName: 'fields' // 固定表名，避免Sequelize自动复数化带来的不一致问题
    }
  )
  return Field
}

2. 重构数据库初始化方法，加缓存和自动模型绑定 #

//--- db.ts ---
import { Sequelize } from 'sequelize'
import { initFieldModel } from './field'
// 其他模型的初始化方法按相同方式导入
import path from 'node:path'
import fs from 'node:fs'

// 全局实例缓存
const dbCache = new Map<string, {
  sequelize: Sequelize,
  models: {
    Field: ReturnType<typeof initFieldModel>
    // 后续新增模型在这里补充类型
  }
}>()

export async function getDb(userId: string) {
  // 命中缓存直接返回，避免重复初始化
  if (dbCache.has(userId)) {
    return dbCache.get(userId)!
  }

  // 自动创建用户数据库目录
  const userDbPath = path.resolve('./db', userId)
  if (!fs.existsSync(userDbPath)) {
    fs.mkdirSync(userDbPath, { recursive: true })
  }

  // 初始化对应用户的Sequelize实例
  const sequelize = new Sequelize({
    dialect: 'sqlite',
    storage: path.join(userDbPath, 'Database.sqlite'),
    logging: false
  })

  // 绑定该实例下的所有模型
  const Field = initFieldModel(sequelize)
  // 其他模型在此处按相同方式初始化
  // 如果存在模型关联关系，在这里统一配置关联逻辑

  // 首次初始化可执行表同步，生产环境建议关闭force、alter参数
  await sequelize.sync()

  const instance = {
    sequelize,
    models: { Field }
  }

  dbCache.set(userId, instance)
  return instance
}

3. 业务层调用方式 #

在请求上下文（比如SvelteKit的服务端load、actions、API路由中），拿到鉴权后的用户ID再获取对应数据库实例，操作的就是当前用户的独立库，不会串数据：

//--- 业务逻辑示例 ---
import { getDb } from './db'

async function queryUserFields(authedUserId: string) {
  const { models } = await getDb(authedUserId)
  // 此处的Field模型已经绑定到当前用户的数据库
  return models.Field.findAll()
}

额外注意事项 #

• 不要在模块顶层调用getDb获取模型，必须在请求处理流程中传入经过鉴权的用户ID获取实例，避免越权。
• 不要重复调用同一个模型类的init方法，否则Sequelize会抛出重复初始化错误，缓存逻辑已经规避了这个问题。
• 生产环境不要依赖sequelize.sync()做表结构变更，单独写脚本遍历所有用户库文件执行迁移即可。

内容的提问来源于stack exchange，提问作者Clifton Labrum