And infrastructure for iterating over geocoder data
This commit is contained in:
+10
-1
@@ -448,7 +448,6 @@ MBTiles.prototype._commit = function(callback) {
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
mbtiles._db.run('COMMIT', function(err) {
|
mbtiles._db.run('COMMIT', function(err) {
|
||||||
mbtiles._committing = false;
|
mbtiles._committing = false;
|
||||||
mbtiles.emit('commit');
|
mbtiles.emit('commit');
|
||||||
@@ -616,6 +615,16 @@ MBTiles.prototype.putGeocoderData = function(type, shard, data, callback) {
|
|||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
|
// Implements carmen#getGeocoderData method.
|
||||||
|
MBTiles.prototype.geocoderDataForEach = function(type, callback, completeCallback) {
|
||||||
|
return this._db.each('SELECT shard, data FROM geocoder_data WHERE type = ? ORDER BY shard', type, function(err, row) {
|
||||||
|
if (err && err.code === 'SQLITE_ERROR' && err.errno === 1) return callback();
|
||||||
|
if (err) return callback(err);
|
||||||
|
if (!row) return callback();
|
||||||
|
callback(row.shard, zlib.inflateSync(row.data));
|
||||||
|
}, completeCallback);
|
||||||
|
};
|
||||||
|
|
||||||
// Implements carmen#getIndexableDocs method.
|
// Implements carmen#getIndexableDocs method.
|
||||||
MBTiles.prototype.getIndexableDocs = function(pointer, callback) {
|
MBTiles.prototype.getIndexableDocs = function(pointer, callback) {
|
||||||
pointer = pointer || {};
|
pointer = pointer || {};
|
||||||
|
|||||||
Reference in New Issue
Block a user