有NOSQL数据层设计模式吗？

Question

我已经看到了一些关于此的想法，例如使用 Get 和 Put 代替创建、更新、插入、删除 (CRUD)。那挺好的。然而，我还没有看到太多关于如何处理复杂性的内容。有人告诉我，“只需为您需要的每种查询类型编写一个方法”。

大多数 NOSQL 对我来说似乎都不错，直到我开始考虑限定符（where 子句）——可能有很多变化。是否已经有一个好的方案来以合理的方式实现限定符，仅使用方法名称和方法名称？论证约定？也许有某种运行良好的动词/名词方案，但它本身并不是一种语言。

我并不是在寻找“正确”的答案……我希望有一些我可以学习的思想流派。

找到了 RavenDB 制造商的这篇博客文章： http://ayende.com/blog/ 4562/ravendb-index-management

我们可以在一个类上实现多个索引吗？

我什至发现可以序列化匿名委托 http://blogs.microsoft.co.il/blogs/aviwortzel/archive/2008/06/20/how-to-serialize-anonymous-delegates.aspx 我想如果这是可能的，那他们可能会使用这样的东西。

但是如果我们无法访问相同的程序集（例如 Silverlight）怎么办？在这里找到这篇文章： http://ayende.com/blog/4766/accessing-ravendb-from- silverlight

IEnumerable 对象是在客户端还是服务器端搜索的？在通过线路将结果集发送回之前，我们可以在 NOSQL 中的服务器端缩小结果集的范围，而不将其锁定到一个唯一的 ID，具体如何？

更新：我最终从 RavenDB 给 Ayende 发了电子邮件。他亲切地回答了我的问题（如下）：

你能做的就是写：

  public IEnumerable<T> FindAll(Expression<Func<T,bool>> whereClause)
  {
      return session.Query<T>().Where(whereClause).ToList();
  }

这使用 linq 来确定您的意图，然后使用 RavenDB 的语法将查询发送到服务器。在服务器上，我们分析您的查询，查询优化器检查是否存在可以回答该查询的现有索引，如果不存在，它将为您创建一个临时索引。

如果您对该临时索引的查询足够多，RavenDB 会将其永久化。因此，自我优化自己的运营。

您对“来自 Silverlight”用例的了解是否深入？

我们完全支持 Silverlight。

RavenDB 可以处理多个索引服务器端吗？

是的。事实上，我们有一些客户拥有 > 500 个索引运行没有问题。

RavenDB 的 Ayende 信息结束

在设计查询语言（即 FindAll / where / delegate）时，mongo 似乎通过 JSON 实现了一些... http://www.mongodb.org/display/DOCS/Indexes 我希望我了解更多。

这听起来更接近： http://www.mongodb.org/display/DOCS/MapReduce

关于序列化的有趣主题序列化匿名委托C#。这并不直接相关......但我只是想稍微了解一下，以便我更多地了解潜力。

Answer 1

我不确定这是否适用于 NoSQL，但我使用 Raven DB 实现了通用存储库模式，下面是一个片段。

首先，我定义了一些接口

internal interface ISessionProvider : IDisposable
{
    IDocumentSession OpenSession();
    void CloseSession();
}

public interface IDataAccessManager : IDisposable
{
    void Initialize();
    void OpenSession();
    void CloseSession();
}

public interface IRepository<T> where T : Entity
{
    IQueryable<T> Query();
    IEnumerable<T> Find(Func<T, bool> exp);
    T FirstOrDefault(Func<T, bool> exp);

    void Delete(T entity);
    void Add(T entity);
    void Save();

    string PutAttachment(string key, byte[] data);
    Attachment GetAttachment(string key);
    void DeleteAttachment(string key);
}

这是一个简短的实现

internal class SessionProvider : ISessionProvider
{
    ...

    public IDocumentSession OpenSession()
    {
        session = store.OpenSession();
        return session;
    }

    public void CloseSession()
    {
        if (session != null)
        {
            session.Dispose();
        }
    }
}

public class DataAccessManager : IDataAccessManager
{
    ...

    public void Initialize()
    {       
        store = new DocumentStore
        {
            ConnectionStringName = ConnectionString
        };
        store.Initialize();
        store.DatabaseCommands.EnsureDatabaseExists(dbName);

        provider = new SessionProvider(store);
    }

    public void OpenSession()
    {
        session = provider.OpenSession();
    }

    public void CloseSession()
    {
        provider.CloseSession();
    }
}


public class Repository<T> : IRepository<T> where T : Entity
{
    ...

    public IEnumerable<T> Find(Func<T, bool> exp)
    {
        return AsQuaribale().Where(exp);
    }

    public void Add(T entity)
    {
        session.Store(entity);
    }

    public void Save()
    {
        session.SaveChanges();
    }

    public string PutAttachment(string key, byte[] data)
    {
        Guid? etag = null;
        var metadata = new RavenJObject
        {
            {"owner", Thread.CurrentPrincipal.Identity.Name},
            {"filename", key}
        };
        session.Advanced.DatabaseCommands.PutAttachment(key, etag, data, metadata);

        return key;
    }

    public Attachment GetAttachment(string key)
    {
        return session.Advanced.DatabaseCommands.GetAttachment(key);
    }

    private IQueryable<T> AsQuaribale()
    {
        return session.Query<T>().Customize(x => x.WaitForNonStaleResultsAsOfNow(Timeout));
    }
}

使用示例

private void SendData()
{
    try
    {
        dataManager.OpenSession();
        repository = new Repository<MyDomainType>();

        ...

        foreach (string path in paths)
        {           
            //read file to memory
            byte[] data = File.ReadAllBytes(path);
            string fName = Path.GetFileName(path);
            myDomainType.Name = fName;

            //save data in memory and metadata to the database
            string key = repository.PutAttachment(
                myDomainType.Id.ToString(), data);

            repository.Add(myDomainType);
        }

        repository.Save();
    }
    catch (Exception ex)
    {
        AppManager.LogException(ex);
    }
    finally
    {
        dataManager.CloseSession();
        dataManager.Dispose();      
    }
}

创建的示例测试，它使用 Find (FirstOrDefault) 方法进行断言

[Test]
public void CreateValueTest()
{
    var repository = ContainerService.Instance.Resolve<IRepository<DummyType>>();
    var expected = new DummyType();
    repository.Add(expected);
    repository.Save();
    DummyType actual = repository.FirstOrDefault(item => item.Id == expected.Id);

    Assert.IsTrue(expected == actual);
}