From cd7a3a49341b8365a2825262b6861ed8e5531263 Mon Sep 17 00:00:00 2001 From: Yegor Bugayenko Date: Sun, 9 Sep 2018 11:17:43 +0300 Subject: [PATCH] #27 LIMIT 1 --- objects/pipeline.rb | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/objects/pipeline.rb b/objects/pipeline.rb index f2fbfdc..97fde67 100644 --- a/objects/pipeline.rb +++ b/objects/pipeline.rb @@ -135,8 +135,7 @@ def self.query(campaign = 0) ' AND recipient.active=true', ' AND (recipient.created < NOW() - INTERVAL \'10 MINUTES\' OR recipient.email LIKE \'%@mailanes.com\')', campaign.zero? ? "AND (#{history}) < c.speed" : "AND c.id = #{campaign}", - 'GROUP BY rid', - 'LIMIT 1' + 'GROUP BY rid' ].join(' ') end @@ -145,7 +144,7 @@ def self.query(campaign = 0) def fetch_one(postman) deliveries = Deliveries.new(pgsql: @pgsql) done = false - @pgsql.exec(Pipeline.query).each do |r| + @pgsql.exec(Pipeline.query + ' LIMIT 1').each do |r| campaign = Campaign.new(id: r['cid'].to_i, pgsql: @pgsql) letter = Letter.new(id: r['lid'].to_i, pgsql: @pgsql, tbot: @tbot) recipient = Recipient.new(id: r['rid'].to_i, pgsql: @pgsql)