在我的模式模型上设计ecto查询以支持预加载
，可以通过使用Ecto的预加载功能来优化数据库查询，减少数据库访问次数，提高查询性能。预加载是一种在查询结果中同时获取关联数据的技术，可以避免N+1查询问题。
在Ecto中，可以通过使用preload/3函数来实现预加载。preload/3函数接受三个参数：查询的模式模型、关联的字段和查询选项。以下是一个示例：
query = from u in User,
preload: [:posts]
Repo.all(query)上述代码中，我们从User模型中查询数据，并通过preload/3函数预加载了关联的posts字段。这样，在获取用户数据的同时，也会获取到该用户的所有帖子数据。
预加载可以应用于多个关联字段，也可以通过嵌套的方式进行预加载。以下是一个示例：
query = from u in User,
preload: [:posts, comments: :user]
Repo.all(query)上述代码中，我们预加载了用户的帖子数据，并且还预加载了每个帖子的评论数据，以及每个评论的用户数据。
预加载可以提高查询性能，特别是在需要获取关联数据的情况下。它适用于各种应用场景，例如博客系统中获取用户的帖子和评论数据，电子商务系统中获取商品的分类和评论数据等。
腾讯云提供了一系列与云计算相关的产品，其中包括数据库、服务器、存储等。以下是一些推荐的腾讯云产品和产品介绍链接地址：
- 云数据库 TencentDB：提供高性能、可扩展的数据库服务，支持多种数据库引擎。详细信息请参考：腾讯云数据库 TencentDB
- 云服务器 CVM：提供弹性计算能力，可根据需求快速创建和管理虚拟机实例。详细信息请参考：腾讯云服务器 CVM
- 云存储 COS：提供安全、稳定、低成本的对象存储服务，适用于各种数据存储需求。详细信息请参考：腾讯云存储 COS
请注意，以上仅为示例，实际选择产品时应根据具体需求进行评估和选择。
相关·内容
2回答
我有一个查询，在这个查询中，我动态地预装表。
assoc_models = [:example]
from(
q in queryable,
preload: ^assoc_models
)
其结果是：
#Ecto.Query<from j in TestModel.Join, preload: [[:example]]>
assoc_models中可以有任意数量的表
在预加载后有一个额外的括号，我想移除。
是否有一种方法可以从列表中获取所有项目，然后将其放在预加载中，以便移除这样的括号
浏览 0提问于2018-09-26得票数 0
回答已采纳
当涉及到在现有模型中添加一个新的关联时，我对Ecto感到相当困惑。假设我有一些讨论板，用户可以在其中发布一个帖子，我有以下模型：
schema "discussion_items" do
many_to_many :likes, XXX.Tag, join_through: "discussion_items_likes"
timestamps()
end
schema "likes" do
belongs_to :user, XXX.User
timestamps()
end
现在假设我有一个现
浏览 1提问于2016-12-02得票数 4
我有团队，每个团队都有用户，所以有一个连接表将用户链接到团队，因为这是一个多对多的关系，这是我的模型：
defmodule App.Team do
use App.Web, :model
schema "teams" do
field :owner_id, :integer
has_many :team_users, {"team_user", App.TeamUser}
end
end
defmodule App.User do
use App.Web, :model
schema "users" do
浏览 0提问于2016-06-01得票数 18
回答已采纳
1回答
我有两个与has_many和belongs_to相关的模型。加载Repo.preload很好，但我注意到孩子并没有将关联返回到亲眼目睹的Ecto.Association.NotLoaded。
我是否也必须将子关联预加载回父级？是否有办法将两个关联从父预加载调用中连接起来？
(我正在使用ECTO2.0 rc5。)
浏览 2提问于2016-06-09得票数 2
回答已采纳
在我的数据库中，一篇文章有很多评论。对于夜间清理任务，我需要将大量的帖子加载到列表中，并预加载与每个帖子相关的所有注释。
Post.filter(needs_review: true)
|> Ecto.preload(:comments)
|> Repo.all()
加载帖子的查询运行良好(大约200‘s)，但是加载所有相关注释超时(60+ secs)的查询可以理解，因为它试图在一个查询中加载数百万条注释。
是否有一种方法可以告诉Ecto.preload()将预加载操作拆分成批处理，以便将注释加载到多个可管理大小的查询中？我想象的情况如下：
Post.filter(needs_re
浏览 0提问于2021-09-10得票数 0
2回答
有没有办法在不显式使用preload:的情况下预加载ecto关联？
类似于模式中的选项？
schema "gadgets" do
field :foo,
has_many :bars, Myapp.Bar, preload: true
end
我正在做类似这样的事情
Repo.get(Gadget, id)
|> Repo.preload: [:bars]
编辑:我尝试这样做的原因是因为我想将一个相关模型预加载到已经预加载的相关模型中，比如
preload: [:invoices preload: :items]
浏览 3提问于2015-04-13得票数 20
回答已采纳
因此，我正在尝试为所有具有子关联的ecto模型获取一个模式。 在我的控制器中，有时我只想加载模型，而另一些时候我想加载所有或部分关联。 def get_account!(id), do: Repo.get!(Account, id) 帐户具有以下关联： has_many :users
belongs_to :company 什么是修改我的get_account的好方法！函数，让我可以选择预加载关联？ 我不想把这个预加载代码放在我的控制器中，我喜欢把所有与查询相关的东西都放在模块中，而不是在我的控制器中泄漏。
浏览 27提问于2018-12-19得票数 0
我刚接触过药剂和凤凰城(学习了6个月)，我遇到了一种情况，我想在MySql中为BIGINT分配一个Ecto模型的字段(不是主键或表ID)。
我意识到当您创建一个Ecto模型时，MySql表中该模型的ID将在迁移后自动映射到BIGINT。
在检查了这个之后，我尝试在模型和相应的迁移脚本中创建一个Ecto模型的字段到:integer或:id，但是它总是在MySql中给出INT数据类型。
有人知道哪种数据类型与MySql中的BIGINT对应，所以当我执行迁移脚本时，表中的特定列将作为BIGINT？
谢谢
浏览 3提问于2017-07-30得票数 8
回答已采纳
3回答
我有一个简单的todo / author模型，其中todo有一个author_id字段。
这些模型的定义如下：
defmodule TodoElixir.User.Author do
use Ecto.Schema
import Ecto.Changeset
schema "authors" do
field :email, :string
field :name, :string
field :password, :string, virtual: true
field :hash, :string
has_many
浏览 6提问于2019-12-10得票数 1
回答已采纳
1回答
使用药剂，Ecto.Query，Postgres
我通过一个连接表User和Location之间有一个关联。在查询时，我使用deleted_at作为一个软删除和签入is_nil(ul.deleted_at)。
如果我软删除连接表记录，我将拥有
%User{id: 1, name: "larskris", deleted_at: nil, location: #Ecto.Association.NotLoaded<association :location is not loaded>}
%UserLocation{id: 25, user_id: 1, locati
浏览 0提问于2018-03-07得票数 0
回答已采纳
2回答
我尝试在ecto中编写一个嵌套查询，从post表中预加载comments，然后在一个单独的查询中为每个评论预加载user。这看起来像这样：
post = Repo.preload(Repo.get(Post, id), [:comments])
comments = Repo.preload(post.comments, [:user])
这样做的问题是，当我知道有一种方法可以在一个查询中加载所需的所有数据时，它会在数据库上运行3个不同的查询。
是不是跟join: assoc()有关
浏览 2提问于2016-07-01得票数 4
3回答
与灵丹妙药中的其他函数一样(以及Ecto自己的事务)，我希望使用模式匹配来处理Ecto查询中可能出现的错误。如下所示：
case Repo.get!(User, id) do
{:ok, user} ->
#do something
{:error, message} ->
#pass the error
end
显然，这不起作用，但是我的模式如何匹配像Ecto.NotSingleResult这样的Ecto错误和其他潜在的查询问题(比如预加载错误)？
浏览 1提问于2015-04-11得票数 7
回答已采纳
这是我的模型：
schema "fixtures" do
field :sm_id, :integer
field :local_score, :integer
field :visitor_score, :integer
field :local_pen_score, :integer
field :visitor_pen_score, :integer
field :ht_score, :string
field :ft_score, :string
field :et_score, :string
f
浏览 0提问于2017-08-03得票数 0
在测试Elixir/Phoenix应用程序时，我尝试使用ecto_fixtures ()。我面临的挑战是，我需要预先加载关联，但我无法控制从fixtures文件创建模型的过程。当我获得给定fixture的结果模型时，它的关联模型还没有加载。我喜欢它们被预加载，并为黄金时段做好准备。
目前，当我这样定义我的装置时，
在文件basic_models.exs：
basic_models model: MyApp.BasicModel, repo: MyApp.Repo do
basic_model_one do
name("A Fake Name")
other
浏览 1提问于2018-11-24得票数 1
alias Bank.{
Account,
Customer,
Deposit,
Ledger,
Repo,
Transfer,
Entry
}
没有它，我得到了一个Ecto.Queryable not implemented for Foo, the given module does not exist。这是如何将Ecto查询内容引入到模型中的？
浏览 18提问于2017-02-21得票数 1
回答已采纳
我有一个Meetup模型，has_many :rsvps，Rsvp模型和belongs_to :user模型。
这是我的端点：
def index(conn, _params) do
one_hour_ago = Timex.now
|> Timex.shift(hours: -1)
|> Timex.to_unix
meetups = from(m in Meetup, where: m.timestamp >= ^one_hour_ago)
|> Repo.all
浏览 3提问于2017-04-17得票数 1
我正在使用ECTO2.0并试图运行以下查询：
query = from e in EmpireInstance,
where: e.user_id == ^user.id,
preload: [:board]
板的模式如下所示：
schema "board_instances" do
belongs_to :empire, PlexServer.EmpireInstance
has_many :board_pieces, BoardTileInstance
timestamps
end
EmpireInstance模式：
sch
浏览 0提问于2016-08-05得票数 0
回答已采纳
我和我的团队正在使用Phoenix和Ecto开发我正在制作的web应用程序。
我们的问题是，我们模型的变更集验证之一依赖于子关联的属性。如果在子关联中将布尔值设置为true，我们应该无法更新记录。
但是，我们不能保证变更集总是使用预加载我们所需的关联的结构来调用。我们希望尽可能避免在模型中进行Repo.preload调用，因为关注点分离，我们知道这可能会为未来糟糕的编码实践开创先例。
任何意见或想法都会得到极大的赞赏。
浏览 7提问于2017-06-24得票数 2
我对Elixir/Phoenix/Ecto不熟悉。我使用ecto.migration创建了一个具有4个不同模式的数据库。这些表是正确创建的，但是当我尝试查询这些表时，ecto找不到它们。
ERROR 42P01 (undefined_table): relation "users" does not exist
我知道这个问题是与数据库模式相关的，因为当我在默认模式中创建users表时，ecto可以毫不费力地找到它。
浏览 4提问于2018-07-29得票数 0
3回答
我有一个三级层次模型关系，即model1属于model2，model2属于model3.
我试图为model2和model3预加载model1
my_models = Repo.all(Model1)
|> Enum.map(fn (x) ->
Repo.preload(x, :model2)
end)
|> Enum.map(fn(x) -> # error "no function clause matching in Ecto.Repo.Preloader.preload/4"
Repo.pre
浏览 15提问于2016-12-08得票数 1
从数据库加载日期/时间类型时，Ecto将转换为Ecto.DateTime类型。如何在从JSON字符串加载模型时应用相同类型的转换
defmodule Rocket.User do
use Rocket.Model
schema "users" do
field :created_at, :datetime
field :name, :string
field :email, :string
field :password, :string
field :timezone, :string
end
end
iex(40)&g
浏览 1提问于2015-01-21得票数 5
回答已采纳
如何预装has_many和belongs_to与Ecto的关联？
例如，在一篇文章has_many注释和评论belong_to的情况下，有一篇文章：
defmodule MyApp.Article do
schema "articles" do
has_many :comments, MyApp.Comments
timestamps
end
end
defmodule MyApp.Comment do
schema "comments" do
belongs_to :article, MyApp.Article
浏览 0提问于2016-01-19得票数 1
我目前有两个具有hasMany关系的表： customers [hasMany] items 在items中有一些belongsTo关系： providers [belongsTo] items
statuses [belongsTo] items
types [belongsTo] items 我的目标是创建一个Ecto查询，该查询返回一个customers列表，其中至少有一个status_id为2的items记录，以及该customers记录所具有的任何其他items。 我还需要预加载items、providers、statuses和一个types 我在SQL中复制了它，如下所示： SE
浏览 10提问于2019-09-09得票数 1
回答已采纳
在Rails中，如果我有以下设置：
class Post < ActiveRecord::Base
has_many :comments
end
class Comment < ActiveRecord::Base
belongs_to :post
def self.approved
where(approved: true)
end
end
然后我可以这样做：
post = Post.find(100)
comments = post.comments.approved
以快速获得给定Post的所有已批准的注释。
我如何在Ecto中做类似的事情？
de
浏览 0提问于2015-06-02得票数 26
1回答
Ecto文档展示了如何基于模式中定义的关联连接两个表(A<-B)。我想通过添加另一个表来扩展它(B <- C)
但是我得到了这个错误。如何在此查询中反映:comments属于:posts这一事实？
Repo.all from u in App.User,
join
浏览 8提问于2016-09-13得票数 1
回答已采纳
1回答
我试图运行以下查询：
select last_sd.*
from
(select distinct(sensor_id) from sensor_data) s LEFT JOIN LATERAL
(select * from sensor_data sd1 where sd1.sensor_id = s.sensor_id order by sd1.received_at desc limit 1) last_sd ON true
我最接近的是：
from s in IotInABox.SensorData, distinct: true, select: s.sensor_id
|
浏览 1提问于2016-09-12得票数 1
我有一个银行和分行模式。所以银行有很多分支机构，但是当我创建一家银行时，它应该获取分支机构id及其详细信息。
银行模式
defmodule Banking.Schema.Bank do
use Ecto.Schema
import Ecto.Changeset
alias Banking.Schema.Branch
schema "banks" do
field :name, :string
has_many :branches, Branch
timestamps()
end
def changeset(bank, att
浏览 3提问于2019-10-30得票数 1
假设我有User和Organization的模型，以及两者之间的多到多关系。我现在想补充关于两者之间的关系的信息。例如，timestamps和position。如何进行此操作，以及如何查询这些信息？
我认为正确的方向是使用连接模式。在Ecto文档之后，应该是这样的：
defmodule UserOrganization do
use Ecto.Schema
@primary_key false
schema "users_organizations" do
field :position, :string # adding information on t
浏览 0提问于2018-05-08得票数 0
回答已采纳
在这种情况下，我使用一些自定义sql生成一个中间表。在我的应用程序中，我有一个指向中间表的模型。我有一个不使用中间表的要求，所以我试图弄清楚如何编写一个Ecto模型，以便它在加载该模型的数据时使用自定义sql。
重要事项:此模型仅用于读取该表或select结果，因此我不必支持insert/update/delete。这应该大大简化了我想做的事。
为了我想做的事情，这里有一个假模型：
defmodule EventBridge.C3poEvent do
use Ecto.Schema
import Ecto
import Ecto.Query, only: [from: 1, fro
浏览 0提问于2018-06-27得票数 0
回答已采纳
1回答
我是一名灵丹妙药/凤凰城的新手，试图弄清楚基本知识，这样我才能跟上速度。我很难理解下面的模式定义有什么问题，这使得生成的查询不正确。
附带注意:我正在使用Tds.Ecto适配器访问只读2005数据库。
defmodule Rodes.Sigcdpro do
use Ecto.Schema
import Ecto.Changeset
alias Rodes.Sigcdpro
@primary_key {:cpros, :string, []}
@derive {Phoenix.Param, key: :cpros}
schema "si
浏览 1提问于2017-12-16得票数 0
回答已采纳
2回答
在我的评论模型(菲尼克斯1.2)中有以下内容：
schema "comments" do
belongs_to :parent, Test.Comment
belongs_to :user, Test.User
belongs_to :post, Test.Post
has_many :children, Test.Comment, foreign_key: :parent_id
end
在移民期间，我补充说：
create table(:comments) do
add :parent_id, :integer
add :user_id,
浏览 6提问于2017-08-04得票数 2
我试图找出我通常(在Rails/ActiveRecord中)在模型类中放置公共函数的位置。具体来说，我有User和Company之间的多到多关系，但是用户有一个default_company，它只是在user_companies联接表上有一个布尔标志。
ActiveRecord
class User < ActiveRecord::Base
belongs_to :user_companies
has_many :companies, through: :user_companies
def default_company
# Filter through comp
浏览 2提问于2017-04-19得票数 3
2回答
偶然发现了这个关于使用Ecto的链接。。模式已经在数据库中创建了，那么为什么在这里声明呢？在使用odbc/jdbc/odac驱动程序时，我们使用类似于stmt的Ecto.Adapters.SQL.query，并且不那么复杂和简单。
那么在哪里给出stmt: Ecto.Adapters.SQL.query(YourRepo，"SELECT $1"，1)？
它在网页/模型/abc.ex中吗？你是怎么得到结果的？您能提到使用直接SQL没有提供的Ecto带来的一些好处吗？
浏览 2提问于2016-05-24得票数 0
我试图弄清楚如何组合select和join表，但遇到了问题。 假设我有表A、表B和表C。表A有一些值，表B在表C中有很多项。 我的查询是这样的： query = from(
a in TableA,
select: %NewStruct{
a: a.value
}
)
from(
a in query,
join: b in TableB,
on: b.a_id == a.id,
join: c in TableC,
on: c.b_id == b.id,
select_merge: %{
c: [c]
}
)
|> Re
浏览 12提问于2019-08-29得票数 0
我今天刚开始使用Elixir & Phoenix，我正在尝试添加Ecto作为映射器，但我在使用时间上遇到了一些问题。
这是我的模型。
schema "users" do
field :name, :string
field :email, :string
field :created_at, :datetime, default: Ecto.DateTime.local
field :updated_at, :datetime, default: Ecto.DateTime.local
end
我试图设置默认的created_at
浏览 0提问于2015-02-14得票数 9
回答已采纳
我有以下模式：
schema "products" do
field :product_id, :integer
field :title, :string
has_many :variants, MyApp.Variant, references: :product_id
timestamps
end
schema "variants" do
field :variant_id, :integer
field :title, :string
belongs_to :product, MyApp.Prod
浏览 2提问于2016-06-28得票数 2
2回答
早上好!我已经到了挣扎的时刻。总而言之，我试图创建一个模式/模型，该模式/模型与关联的模式/模型已经存在关联。我发现的每个示例看起来都更像是Rails的嵌套属性。下面是我的各种代码：
具有以下关联的模式(及其变更集函数)：
schema "payor_procedure_mappings" do
belongs_to :payor, Payor
belongs_to :procedure, Procedure
field :payor_procedure_name, :string
field :payor_procedure_id, :string
ti
浏览 0提问于2020-02-16得票数 1
在Rails AR中，可以运行这样的查询：
current_user.articles # fetch all articles from current_user
SELECT * from articles where user_id = <user_id>;
和Ecto有同样的方法吗？
浏览 2提问于2015-10-22得票数 4
回答已采纳
1回答
我正在运行一个类似这样的查询：
query = from q in MY.Model, preload: [:accoc], where: q.accoc_field in [10, 11]
Repo.all(query)
这给了我一个错误：
** (Ecto.QueryError) iex:32: field `accoc_field` in `where` does not exist in schema MY.Model in query:
因此，基本上我尝试编写一个查询，如下所示：
select * from my_model m join assoc a on m.assoc_id
浏览 31提问于2018-05-30得票数 0
回答已采纳
我有疑问：
PhoenixApp.one(from r in PhoenixApp.Reply,
where: r.inserted_at > ^datatime,
select: count(r.id))
此查询失败，错误：value '#Ecto.DateTime<2016-12-04 20:11:21>' in 'where' cannot be cast to type :naive_datetime in query:
但是，当使用type(^datatime, Ecto.Da
浏览 4提问于2017-01-08得票数 5
回答已采纳
1回答
我正在尝试将记录范围限定为属于当前用户的记录。但我没有什么成功。以下是我正在尝试的：
def show(conn, %{"id" => id}) do
user_id = Map.get(Statcasters.Guardian.Plug.current_resource(conn), :id)
user = Repo.get!(User, user_id) |> Repo.preload(:leagues)
league = Repo.get(user.leagues, id)
end
但我发现了一个错误：
** (Protocol.Un
浏览 0提问于2018-05-07得票数 0
回答已采纳
我得到了一个简单的模式Product，带有many_to_many :tags relation，没有用于连接表的中间模式。
many_to_many :tags, Tag, join_through: "products_tags"
现在问题非常简单，在Ruby的ActiveRecord中，有一个方便的设置器，您只需将其设置为相关记录的it数组，它就会自动更新连接记录，即：product.tag_ids = [1, 2, 5, 6]。
在Ecto中，如果我想使用put_assoc，它似乎需要我预先加载数组中的所有标签，所以我可以perform put_assoc(:tags,
浏览 0提问于2017-09-15得票数 0
我正在尝试对具有预加载关联的数据进行分页。
在我的控制器中，这是工作的：
def index(conn, _params) do
products = Product
|> Repo.all
|> Repo.preload(:category)
render(conn, "index.html", products: products)
end
这也是可行的：
def index(conn, params) do
{products, kerosene} = Product
|> R
浏览 1提问于2017-09-28得票数 1
我刚开始使用Ecto和药剂，我遇到了一个我无法解释的错误。我的代码看起来就像Ecto中的示例。
以下是Ecto模型和查询的模块
defmodule Registration do
use Ecto.Model
schema "registrations" do
field :user_id, :string
field :created_at, :datetime, default: Ecto.DateTime.local
field :updated_at, :datetime, default: Ecto.DateTime.local
浏览 3提问于2014-12-27得票数 4
回答已采纳
我最近开始将一个现有的PHP信使应用程序移植到灵丹妙药(使用灵丹妙药1.3、凤凰1.2、ecto 2.0.1和mariaex 0.7.7)。这个应用程序为数百万用户服务，因此性能非常重要。我对长生不老药很陌生，所以请原谅我的沉默。
我有以下数据库模式：
每个线程都有多个thread_participants和消息。thread_participant在链接线程的上下文中提供了关于用户的信息(例如，用户最后一次看到这个线程的时间)。线程由用户编写的多条消息组成。
我希望json我的API最终返回的内容是：
"data": {
"result": [1
浏览 2提问于2016-06-30得票数 1
回答已采纳
1回答
我有三种型号：User，Group，UserMembership。
它们之间的关系是
defmodule Samajika.Group do
has_many :user_memberships, MyApp.UserMembership
has_many :users, through: [:user_memberships, :user]
end
UserMembership模型有一个存储成员身份类型的type列。例如，它可以存储owner、tenant等。
现在，我想查询Group并获取其仅为租户的成员。
Ecto.assoc(group, :users) |> Repo.
浏览 0提问于2016-04-29得票数 3
1回答
考虑到以下代码工作正常：
image_1 = %Image{naturalHeight: "100", naturalWidth: 100}
diffbot_objects = [
%DiffbotObject{
availability: true,
images: [
image_1
]
}
]
changeset = Ecto.Changeset.change(product)
changeset = Ecto.Changeset.put_embed(changeset, :diffbot_objects, diffbot_
浏览 3提问于2016-01-20得票数 4
回答已采纳
1回答
能否使用长生不老药有效地查询belongs_to关系？看起来，load正在查询它需要的所有项，但是get返回加载项的第一个值，而不管它实际需要哪一个项。这是我现在使用的代码：
field :node, :node_object, resolve: fn parent, _, %{context: %{loader: loader}} ->
# parent.node_id = 1, but concurrently also another parent.node_id = 5
loader
|> Dataloader.load(NodeContext, :node,
浏览 2提问于2020-08-06得票数 1
回答已采纳
1回答
我试图使用带有Ecto的多行insert查询插入800个变更集。我在用postgres。我看到postgrex现在支持这一点。用Ecto有可能吗？
如果可能的话，我也愿意通过预先准备的声明来做这件事。
浏览 4提问于2016-05-05得票数 6
回答已采纳
1回答
我一直试图在postgresql中的jsonb列中保存JSON，我已经尝试过教程，也开始阅读Ecto以及Postgrex，但是无法使它工作，一个工作示例会让我感到兴奋:)到目前为止，我已经将它添加到了我的配置中。
config :bonsai, Bonsai.Repo,
adapter: Ecto.Adapters.Postgres,
username: "demo",
password: "demo123",
database: "bonsai_test",
hostname: "localhost",
浏览 0提问于2016-03-15得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
