This is an automated email from the ASF dual-hosted git repository. joscorbe pushed a commit to branch OAK-10801 in repository https://gitbox.apache.org/repos/asf/jackrabbit-oak.git
commit a1999ab8e90e536c265ff9bae11a75bbdb1381d4 Author: Jose Cordero <[email protected]> AuthorDate: Mon May 13 17:46:54 2024 +0200 OAK-10801: Introduce functions to remove nodes that are older than a timestamp --- oak-run/src/main/js/oak-mongo.js | 49 +++++++++++++++++++++++++++++++++++++++- 1 file changed, 48 insertions(+), 1 deletion(-) diff --git a/oak-run/src/main/js/oak-mongo.js b/oak-run/src/main/js/oak-mongo.js index 8f8d264e7e..605dff87e0 100644 --- a/oak-run/src/main/js/oak-mongo.js +++ b/oak-run/src/main/js/oak-mongo.js @@ -329,6 +329,53 @@ var oak = (function(global){ return {nRemoved : count}; }; + /** + * Finds all the descendants with a _modified timestamp older than the + * given timestamp. + * + * @memberof oak + * @method findDescendantsOlderThan + * @param {string} path of the parent node to search. + * @param {number} timestamp to compare with. + */ + api.findDescendantsOlderThan = function(path, timestamp) { + var count = 0; + var depth = pathDepth(path); + var prefix = path + "/"; + depth++; + var query = { _id: pathFilter(depth, prefix), _modified: {$lt: timestamp}}; + db.nodes.find(query).forEach(function(doc) { + print(doc._id); + count++; + }); + print("nCandidates : " + count); + } + + /** + * Removes all the descendants with a _modified timestamp older than the + * given timestamp. + * Use removeDescendantsAndSelf() first to get the list of nodes to remove. + * + * @memberof oak + * @method removeDescendantsOlderThan + * @param {string} path of the parent node to search. + * @param {number} timestamp to compare with. + */ + api.removeDescendantsOlderThan = function(path, timestamp) { + var count = 0; + var depth = pathDepth(path); + var prefix = path + "/"; + depth++; + var query = { _id: pathFilter(depth, prefix), _modified: {$lt: timestamp}}; + db.nodes.find(query).forEach(function(doc) { + print("Removing " + doc._id + " and its children"); + var result = api.removeDescendantsAndSelf(api.pathFromId(doc._id)); + count += result.nRemoved; + print(" removed : " + result.nRemoved); + }); + print("nRemoved : " + count); + } + /** * List all checkpoints. * @@ -1195,7 +1242,7 @@ var oak = (function(global){ var i = Math.floor( Math.log(size) / Math.log(1024) ); return ( size / Math.pow(1024, i) ).toFixed(2) * 1 + ' ' + ['B', 'kB', 'MB', 'GB', 'TB'][i]; }; - + // http://stackoverflow.com/questions/3561493/is-there-a-regexp-escape-function-in-javascript var escapeForRegExp = function(s) { return s.replace(/[-\/\\^$*+?.()|[\]{}]/g, '\\$&');
