Ecto多数据库配置终极指南如何在单个应用中管理多个数据源【免费下载链接】ectoA toolkit for data mapping and language integrated query.项目地址: https://gitcode.com/gh_mirrors/ec/ectoEcto作为Elixir生态中强大的数据映射和查询工具提供了灵活的多数据库配置方案帮助开发者轻松管理多个数据源。本文将详细介绍两种主流的多数据库配置策略——查询前缀隔离和外键隔离以及如何根据项目需求选择最适合的方案。 多数据库配置的两种核心方案Ecto支持多种多数据库管理策略每种方案都有其适用场景。选择合适的方案取决于你的应用规模、数据隔离需求和性能要求。1. 查询前缀隔离方案Query Prefixes查询前缀方案通过为不同租户或功能模块创建独立的数据库前缀在PostgreSQL中对应DDL模式在MySQL中对应独立数据库实现数据隔离。这种方案适用于需要严格数据隔离且租户数量有限的场景。核心优势完全的数据隔离安全性高独立的数据库结构可针对不同租户定制表结构便于数据迁移和维护实现步骤配置连接前缀在仓库配置中设置默认查询前缀通过search_path参数指定PostgreSQL的模式搜索路径# config/config.exs config :my_app, MyApp.Repo, username: postgres, password: postgres, database: demo_dev, hostname: localhost, pool_size: 10, parameters: [search_path: connection_prefix,public]创建数据库前缀PostgreSQL不会自动创建非public前缀需要手动创建$ psql -d demo_dev -c CREATE SCHEMA connection_prefix迁移多前缀数据库可以通过命令行指定前缀执行迁移$ mix ecto.migrate --prefix prefix_1 $ mix ecto.migrate --prefix prefix_2或者在迁移文件中批量处理多个前缀# priv/repo/migrations/20160101000000_create_sample.exs defmodule MyApp.Repo.Migrations.CreateSample do use Ecto.Migration def change do for i - 1..128 do prefix prefix_#{i} create table(:samples, prefix: prefix) do add :name, :string timestamps() end flush() # 立即执行当前前缀的迁移命令 end end end2. 外键隔离方案Foreign Keys外键隔离方案通过在所有表中添加租户标识字段如org_id并利用数据库外键约束实现数据隔离。这种方案适用于租户数量多、数据结构统一的场景。核心优势维护成本低只需一套数据库表结构便于跨租户数据分析迁移简单一次迁移适用于所有租户实现步骤增强仓库功能通过实现prepare_query/3回调自动为查询添加租户条件# lib/repo.ex defmodule MyApp.Repo do use Ecto.Repo, otp_app: :my_app require Ecto.Query impl true def prepare_query(_operation, query, opts) do cond do opts[:skip_org_id] || opts[:ecto_query] in [:schema_migration, :preload] - {query, opts} org_id opts[:org_id] - {Ecto.Query.where(query, org_id: ^org_id), opts} true - raise expected org_id or skip_org_id to be set end end end设置默认租户ID利用进程字典存储当前租户ID避免每次查询手动传递# lib/repo.ex defmodule MyApp.Repo do ... tenant_key {__MODULE__, :org_id} def put_org_id(org_id) do Process.put(tenant_key, org_id) end def get_org_id() do Process.get(tenant_key) end impl true def default_options(_operation) do [org_id: get_org_id()] end end设计多租户数据模型为所有租户相关表添加org_id字段并使用复合外键确保数据一致性# priv/repo/migrations/20230101000000_create_posts.exs defmodule MyApp.Repo.Migrations.CreatePosts do use Ecto.Migration def change do create table(:orgs, primary_key: false) do add :org_id, :bigserial, primary_key: true add :name, :string timestamps() end create table(:posts) do add :title, :string add :org_id, references(:orgs, column: :org_id), null: false timestamps() end create unique_index(:posts, [:id, :org_id]) create table(:comments) do add :body, :string add :org_id, :integer, null: false add :post_id, references(:posts, with: [org_id: :org_id]), null: false timestamps() end end end 高级应用动态切换数据源Ecto允许在运行时动态切换数据源满足复杂的业务需求。以下是几种常见的动态切换场景按查询指定前缀所有Repo操作都支持prefix选项可临时覆盖默认前缀# 读取公共数据 MyApp.Repo.all(MyApp.PublicData, prefix: public) # 写入特定租户数据 MyApp.Repo.insert(%MyApp.User{name: Alice}, prefix: tenant_123)结构体级别的前缀设置通过Ecto.put_meta/2为结构体设置前缀确保后续操作使用正确的数据源user %MyApp.User{name: Bob} tenant_user Ecto.put_meta(user, prefix: tenant_456) MyApp.Repo.insert(tenant_user) # 数据将插入到tenant_456前缀关联查询中的多前缀处理Ecto允许为每个from和join子句指定不同的前缀实现跨前缀关联查询query from p in MyApp.Post, prefix: tenant_1, join: c in MyApp.Comment, prefix: tenant_1, on: p.id c.post_id, join: t in MyApp.Tag, prefix: public, on: p.tag_id t.id MyApp.Repo.all(query) 方案对比与选择指南特性查询前缀方案外键隔离方案数据隔离级别完全隔离逻辑隔离租户数量适应性适合少量租户适合大量租户迁移复杂度高需为每个前缀迁移低一次迁移所有租户跨租户查询困难简单定制化程度高各租户可定制表结构低统一表结构选择建议企业SaaS应用租户数量少且需求差异大 → 查询前缀方案多用户应用租户数量多且数据结构统一 → 外键隔离方案混合场景 → 结合两种方案核心数据用外键隔离特殊需求用查询前缀 最佳实践与注意事项迁移策略查询前缀方案考虑编写迁移脚本自动处理所有前缀外键隔离方案确保org_id非空约束和索引优化性能优化为外键隔离方案的org_id字段建立索引查询前缀方案考虑连接池隔离安全措施严格验证租户ID防止越权访问使用数据库约束如复合外键增强数据安全性测试策略为不同租户隔离级别编写测试用例模拟多租户并发访问场景通过Ecto的多数据库配置功能开发者可以灵活应对从简单到复杂的多数据源管理需求。无论是构建SaaS平台还是复杂的企业应用Ecto都能提供清晰、安全且高效的解决方案。要深入了解Ecto的更多高级特性可以参考官方文档中的多租户指南和查询构建器文档。【免费下载链接】ectoA toolkit for data mapping and language integrated query.项目地址: https://gitcode.com/gh_mirrors/ec/ecto创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考