MongoDb C# 驱动程序 - DeleteMany 不适用于 In Filter

Question

我尝试使用 MongoDb C# 驱动程序删除重复记录。下面的脚本既不引发错误也不删除任何记录。有什么建议吗？

[BsonIgnoreExtraElements]
public class ApiUsers
{
    [BsonId]
    [BsonRepresentation(BsonType.String)]
    public ObjectId Id { get; set; }
    
    public string UserEMail { get; set; }
}

var users = _mongoDbContext.ApiUsers.Find(f => f.UserEMail == email).ToList();
var oneUser = users[0];

var idsToDelete = users.Where(x => !x.Id.Equals(oneUser.Id)).Select(x => x.Id);
if (idsToDelete.Any())
{   //Delete Dublicates
    
    var idsToDeleteFilter = Builders<ApiUsers>.Filter.In(t => t.Id, idsToDelete);
    var result = _mongoDbContext.ApiUsers.DeleteMany(idsToDeleteFilter);
}

我也尝试了下面的 DeleteOne 方法，但它也没有用，

foreach (var idToDelete in idsToDelete)                        
   _mongoDbContext.ApiChildUsers.DeleteOne(Builders<ApiChildUsers>.Filter.Eq(u => u.Id, idToDelete));

Answer 1

您可以尝试以下方法，您可以像这样取回一个 Id 以保留并删除其余的：

var filter = Builders<ApiUsers>.Filter.Where(u => u.UserEMail == "test@test.com");
var projection = Builders<ApiUsers>.Projection.Expression(u=>u.Id);
var options = new FindOptions<ApiUsers, string> { Projection = projection, Limit = 1 };

var idToKeep = collection.FindSync(filter, options).ToList()[0];

collection.DeleteMany(
    u => u.UserEMail == "test@test.com" &&
         u.Id != idToKeep);

作为旁注，我想建议您将 ID 作为 ObjectId 而不是字符串存储在服务器中，因为它的效率较低，因为 ObjectId 只需要 12 个字节来存储，这将少于十六进制它的字符串表示形式。

这是一个使用 mongodb.entities 的不太冗长的测试程序：

using MongoDB.Entities;
using System.Threading.Tasks;

namespace TestApp
{
    public class ApiUsers : Entity
    {
        public string UserEMail { get; set; }
    }

    internal static class Program
    {
        private static async Task Main()
        {
            await DB.InitAsync("test", "localhost");

            await new[] {
                new ApiUsers { UserEMail = "test@test.com"},
                new ApiUsers { UserEMail = "test@test.com"},
                new ApiUsers { UserEMail = "test@test.com"},
                new ApiUsers { UserEMail = "teX@teX.com"},
            }.SaveAsync();

            var idToKeep = (await DB.Find<ApiUsers, string>()
                                    .Match(u => u.UserEMail == "test@test.com")
                                    .Project(u => u.ID)
                                    .Limit(1)
                                    .ExecuteAsync())[0];

            await DB.DeleteAsync<ApiUsers>(
                u => u.UserEMail == "test@test.com" &&
                     u.ID != idToKeep);
        }
    }
}

MongoDb C# 驱动程序 - DeleteMany 不适用于 In Filter

MongoDb C# Driver - DeleteMany doesn't work with In Filter

c#

mongodb

mongodb-.net-driver

asp.net-core-2.1