文档删除 #

警告：
├── 删除操作不可恢复
├── 边文档删除不影响顶点
├── 删除会生成新的_rev
└── 建议使用事务保证一致性

REMOVE "user_001" IN users

REMOVE "users/user_001" IN users

REMOVE { _key: "user_001" } IN users

REMOVE "user_001" IN users
RETURN OLD

db.users.remove("user_001");

var result = db.users.remove("user_001");
print(result);

FOR user IN users
    FILTER user.status == "inactive"
    REMOVE user IN users

FOR user IN users
    FILTER user.status == "inactive"
    REMOVE user IN users
    RETURN OLD

FOR user IN users
    FILTER user.status == "deleted"
    AND user.deletedAt < DATE_SUBTRACT(DATE_NOW(), 30, "days")
    REMOVE user IN users

FOR user IN users
    FILTER user.age < 18
    REMOVE user IN users

LET inactiveUsers = (
    FOR user IN users
        FILTER user.lastLogin < DATE_SUBTRACT(DATE_NOW(), 90, "days")
        RETURN user._key
)
FOR key IN inactiveUsers
    REMOVE key IN users

FOR key IN ["user_001", "user_002", "user_003"]
    REMOVE key IN users

FOR user IN users
    FILTER user.status == "expired"
    REMOVE user IN users
    RETURN OLD._key

FOR user IN users
    FILTER user.status == "inactive"
    LIMIT 1000
    REMOVE user IN users

var keys = ["user_001", "user_002", "user_003"];
keys.forEach(function(key) {
    db.users.remove(key);
});

db.users.removeByExample({ status: "inactive" });

REMOVE "user_001" IN users
OPTIONS { waitForSync: true }

REMOVE {
    _key: "user_001",
    _rev: "_old_rev"
} IN users
OPTIONS { ignoreRevs: true }

REMOVE "user_001" IN users
OPTIONS { returnOld: true }
RETURN OLD

REMOVE "user_001" IN users
OPTIONS {
    waitForSync: true,
    ignoreRevs: true
}
RETURN OLD

db.users.truncate();

FOR user IN users
    REMOVE user IN users

REMOVE "follow_001" IN follows

FOR edge IN follows
    FILTER edge._from == "users/user_001" OR edge._to == "users/user_001"
    REMOVE edge IN follows

FOR edge IN follows
    FILTER edge.type == "temporary"
    REMOVE edge IN follows

LET userId = "user_001"
LET userEdges = (
    FOR edge IN follows
        FILTER edge._from == CONCAT("users/", userId) 
            OR edge._to == CONCAT("users/", userId)
        RETURN edge._key
)
FOR key IN userEdges
    REMOVE key IN follows
REMOVE userId IN users

db._executeTransaction({
    collections: { write: ["users", "posts", "comments"] },
    action: function() {
        var db = require("@arangodb").db;
        var userId = "user_001";
        
        db._query(`
            FOR comment IN comments
                FILTER comment.userId == @userId
                REMOVE comment IN comments
        `, { userId: userId });
        
        db._query(`
            FOR post IN posts
                FILTER post.authorId == @userId
                REMOVE post IN posts
        `, { userId: userId });
        
        db.users.remove(userId);
    }
});

LET vertexId = "users/user_001"
FOR v, e IN ANY vertexId GRAPH "social"
    REMOVE e IN follows
REMOVE vertexId IN users

UPDATE "user_001" WITH {
    deleted: true,
    deletedAt: DATE_NOW()
} IN users

FOR user IN users
    FILTER user.deleted != true
    RETURN user

UPDATE "user_001" WITH {
    deleted: false,
    deletedAt: null
} IN users

FOR user IN users
    FILTER user.deleted == true
    AND user.deletedAt < DATE_SUBTRACT(DATE_NOW(), 30, "days")
    REMOVE user IN users

db.users.remove("user_001");

db.users.removeByExample({ status: "inactive" });

db.users.removeByKeys(["user_001", "user_002", "user_003"]);

db.users.truncate();

if (db.users.exists("user_001")) {
    db.users.remove("user_001");
    print("删除成功");
} else {
    print("文档不存在");
}

FOR session IN sessions
    FILTER session.expiresAt < DATE_NOW()
    REMOVE session IN sessions

FOR user IN users
    FILTER user.email LIKE "%@test.com"
    REMOVE user IN users

FOR user IN users
    COLLECT email = user.email WITH COUNT INTO count
    FILTER count > 1
    LET duplicates = (
        FOR u IN users
            FILTER u.email == email
            SORT u.createdAt ASC
            LIMIT 1, count - 1
            RETURN u._key
    )
    FOR key IN duplicates
        REMOVE key IN users

FOR edge IN follows
    LET fromExists = DOCUMENT(edge._from)
    LET toExists = DOCUMENT(edge._to)
    FILTER fromExists == null OR toExists == null
    REMOVE edge IN follows

function batchRemove(collection, batchSize) {
    var removed = 0;
    while (true) {
        var result = db._query(`
            FOR doc IN @@collection
                LIMIT @batchSize
                REMOVE doc IN @@collection
                RETURN 1
        `, { 
            "@collection": collection, 
            batchSize: batchSize 
        });
        var count = result.toArray().length;
        removed += count;
        if (count < batchSize) break;
    }
    return removed;
}

var total = batchRemove("logs", 1000);
print("共删除 " + total + " 条记录");

db.users.ensureHashIndex(["status"]);

FOR user IN users
    FILTER user.status == "inactive"
    LIMIT 1000
    REMOVE user IN users

db.users.truncate();

REMOVE "nonexistent_key" IN users
OPTIONS { ignoreErrors: true }

try {
    db.users.remove("user_001");
} catch (e) {
    if (e.errorNum === 1202) {
        print("文档不存在");
    } else if (e.errorNum === 1200) {
        print("版本冲突");
    }
}

try {
    db._executeTransaction({
        collections: { write: ["users", "orders"] },
        action: function() {
            var db = require("@arangodb").db;
            db.users.remove("user_001");
            throw new Error("模拟错误");
        }
    });
} catch (e) {
    print("事务已回滚: " + e.message);
}