Foundry376/Mailspring
1
1
Fork 0
mirror of https://github.com/Foundry376/Mailspring.git synced 2024-09-21 15:56:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(database): Allow findVersions to be called with more than 250 items

Browse source
This commit is contained in:
Ben Gotow 2015-08-24 14:01:31 -07:00
parent fd7722bc1a
commit 2e1e485051
1 changed files with 19 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/flux/stores/database-store.coffee
View file

@ -398,16 +398,28 @@ class DatabaseStore extends NylasStore
#
# Using this method requires that the klass has declared the version field queryable.
#
findVersions: (klass, ids) =>
findVersions: (klass, allIds) =>
return Promise.reject(new Error("DatabaseStore::findVersions - You must provide a class")) unless klass
return Promise.reject(new Error("DatabaseStore::findVersions - version field must be queryable")) unless klass.attributes.version.queryable
marks = new Array(ids.length)
marks[idx] = '?' for m, idx in marks
@_query("SELECT id, version FROM `#{klass.name}` WHERE id IN (#{marks.join(",")})", ids).then (results) ->
map = {}
map[id] = version for {id, version} in results
Promise.resolve(map)
_findVersionsFor = (ids) =>
marks = new Array(ids.length)
marks[idx] = '?' for m, idx in marks
@_query("SELECT id, version FROM `#{klass.name}` WHERE id IN (#{marks.join(",")})", ids).then (results) ->
map = {}
map[id] = version for {id, version} in results
Promise.resolve(map)
promises = []
while allIds.length > 0
promises.push(_findVersionsFor(allIds.splice(0, 100)))
# We can only use WHERE IN for up to ~250 items at a time. Run a query for
# every 100 items and then combine the results before returning.
Promise.all(promises).then (results) =>
all = {};
all = _.extend(all, result) for result in results
Promise.resolve(all)
# Public: Executes a {ModelQuery} on the local database.
#