G_ids
J
GJfor tableName in ;
do npx convex import --table $tableName --replace -y --format jsonLines /dev/null;
done
JJGJGnpx convex datactx.db.clear(table)Clear Tableexport const vacuumTable = internalMutation({
args: {
tableName: v.string(),
before: v.number(),
cursor: v.union(v.string(), v.null()),
soFar: v.number(),
},
handler: async (ctx, { tableName, before, cursor, soFar }) => {
const results = await ctx.db
.query(tableName as TableNames)
.withIndex('by_creation_time', (q) => q.lt('_creationTime', before))
.paginate({ cursor, numItems: DELETE_BATCH_SIZE });
for (const row of results.page) {
await ctx.db.delete(row._id);
}
if (!results.isDone) {
await ctx.scheduler.runAfter(0, internal.crons.vacuumTable, {
tableName,
before,
soFar: results.page.length + soFar,
cursor: results.continueCursor,
});
} else {
console.log(`Vacuumed ${soFar + results.page.length} entries from ${tableName}`);
}
},
}