Помогите с общим методом вставки LINQ (Norm / MongoDB) - PullRequest
Новая
       20

Помогите с общим методом вставки LINQ (Norm / MongoDB)

1 голос
/ 14 марта 2011

Я пытаюсь написать универсальный метод для вставки объекта как внедренного документа.Приведенный ниже код уже работает, но мне нужно создать общий метод, который можно поместить в репозиторий и вызвать из контроллера.Мне нужно передать корневой идентификатор и объект вложенного документа, который нужно вставить. 

class Post
{
    ...
    public IList<Comment> Comments { get; set; }
}

using (var db = Mongo.Create(session.ConnectionString()))
{
    IMongoCollection<Post> _collection = db.GetCollection<Post>("Post");
    var comment = new Comment();
    comment.InjectFrom(commentViewModel.comment);

    // Use below to add *NEW* embedded document
    _collection.UpdateOne(
        new { _id = commentViewModel.Id },
        new { Comments = M.AddToSet(comment) }
        );
}

В качестве примера, это то, что я использую для получения документа, я ищучто-то похожее на вставку: 

// Controller
var session = new MongoSession();
var post = session.Single<Post>(c => c.Id == id);

//Repository
public T Single<T>(System.Linq.Expressions.Expression<Func<T, bool>> expression) where T : class, new()
{
    T retval = default(T);
    using (var db = Mongo.Create(_connectionString))
    {
        retval = db.GetCollection<T>().AsQueryable()
                    .Where(expression).SingleOrDefault();
    }
    return retval;
}

ОБНОВЛЕНИЕ

Обратите внимание, что вызов: 

_collection.UpdateOne(
            new { _id = commentViewModel.Id },
            new { Comments = M.AddToSet(comment) }
            )

делает то, что мне нужно, я просто хочу бытьвозможность сделать это общим вызовом (из-за отсутствия лучшего слова) к чему-то вроде этого (кроме рабочей версии): 

//Controller
var session = new MongoSession();
session.AddSubDocument<>(new Post { Id = commentViewModel.Id }, new { Comments = M.AddToSet(comment) });

// Repository ==> NOT WORKING SAMPLE
public void AddSubDocument<X, U>(X matchDocument, U valueDocument)
{
    using (var db = Mongo.Create(_connectionString))
    {
        db.GetCollection<X>().UpdateOne(matchDocument, valueDocument);
    }
}

Надеюсь, что это имеет больше смысла.

Спасибо,Mike

1 Ответ

1 голос
/ 14 марта 2011

Это должно работать 

public void Insert<T>( T entity )
{
     using (var db = Mongo.Create(_connectionString))
     {
         var collection = db.GetCollection<T>();
         collection.Save( entity );
     }
}
...