9

在设计使用 MVCC（多版本并发控制）的数据库时，您创建的表具有像“IsLatest”这样的布尔字段或整数“VersionId”，并且您从不进行任何更新，您只在事情发生变化时插入新记录。

MVCC 为您提供了对需要详细历史记录的应用程序的自动审计，它还减轻了数据库在更新锁方面的压力。缺点是它会使您的数据大小更大并减慢选择速度，因为获得最新版本需要额外的子句。它还使外键更加复杂。

（请注意，我不是在谈论 RDBMS 中的本机 MVCC 支持，例如 SQL Server 的快照隔离级别）

这已在 Stack Overflow 上的其他帖子中讨论过。[待办事项-链接]

我想知道，哪些流行的实体/ORM 框架（Linq to Sql、ADO.NET EF、Hibernate 等）可以完全支持这种类型的设计？这是对典型 ActiveRecord 设计模式的重大更改，因此我不确定现有的大多数工具是否可以帮助那些决定使用他们的数据模型走这条路的人。我对如何处理外键特别感兴趣，因为我什至不确定对它们进行数据建模以支持 MVCC 的最佳方法。

4

6 回答 6

3

我可能会考虑纯粹在数据库中实现 MVCC 层，使用存储的过程和视图来处理我的数据操作。然后，您可以为任何能够映射到存储过程的 ORM 提供一个合理的 API，并且您可以让数据库处理数据完整性问题（因为它几乎就是为此而构建的）。如果你走这条路，你可能想看看像 IBatis 或 IBatis.net 这样的更纯粹的 Mapping 解决方案。

于 2008-09-05T20:04:33.120 回答
3

我类似地设计了一个数据库（只有 INSERT——没有 UPDATE，没有 DELETE）。

几乎我所有的 SELECT 查询都是针对每个表的当前行的视图（最高修订号）。

视图看起来像这样……

SELECT
    dbo.tblBook.BookId,
    dbo.tblBook.RevisionId,
    dbo.tblBook.Title,
    dbo.tblBook.AuthorId,
    dbo.tblBook.Price,
    dbo.tblBook.Deleted
FROM
    dbo.tblBook INNER JOIN
    (
        SELECT
            BookId,
            MAX(RevisionId) AS RevisionId
        FROM
            dbo.tblBook
        GROUP BY
            BookId
    ) AS CurrentBookRevision ON
    dbo.tblBook.BookId = CurrentBookRevision.BookId AND
    dbo.tblBook.RevisionId = CurrentBookRevision.RevisionId
WHERE
    dbo.tblBook.Deleted = 0

我的插入（以及更新和删除）都由存储过程（每个表一个）处理。

存储过程看起来像这样……

ALTER procedure [dbo].[sp_Book_CreateUpdateDelete]
    @BookId      uniqueidentifier,
    @RevisionId  bigint,
    @Title       varchar(256),
    @AuthorId    uniqueidentifier,
    @Price       smallmoney,
    @Deleted     bit
as
    insert into tblBook
        (
            BookId,
            RevisionId,
            Title,
            AuthorId,
            Price,
            Deleted
        )
    values
        (
            @BookId,
            @RevisionId,
            @Title,
            @AuthorId,
            @Price,
            @Deleted
        )

修订号是在 Visual Basic 代码中按事务处理的……

Shared Sub Save(ByVal UserId As Guid, ByVal Explanation As String, ByVal Commands As Collections.Generic.Queue(Of SqlCommand))
    Dim Connection As SqlConnection = New SqlConnection(System.Configuration.ConfigurationManager.ConnectionStrings("Connection").ConnectionString)
    Connection.Open()
    Dim Transaction As SqlTransaction = Connection.BeginTransaction
    Try
        Dim RevisionId As Integer = Nothing
        Dim RevisionCommand As SqlCommand = New SqlCommand("sp_Revision_Create", Connection)
        RevisionCommand.CommandType = CommandType.StoredProcedure
        RevisionCommand.Parameters.AddWithValue("@RevisionId", 0)
        RevisionCommand.Parameters(0).SqlDbType = SqlDbType.BigInt
        RevisionCommand.Parameters(0).Direction = ParameterDirection.Output
        RevisionCommand.Parameters.AddWithValue("@UserId", UserId)
        RevisionCommand.Parameters.AddWithValue("@Explanation", Explanation)
        RevisionCommand.Transaction = Transaction
        LogDatabaseActivity(RevisionCommand)
        If RevisionCommand.ExecuteNonQuery() = 1 Then 'rows inserted
            RevisionId = CInt(RevisionCommand.Parameters(0).Value) 'generated key
        Else
            Throw New Exception("Zero rows affected.")
        End If
        For Each Command As SqlCommand In Commands
            Command.Connection = Connection
            Command.Transaction = Transaction
            Command.CommandType = CommandType.StoredProcedure
            Command.Parameters.AddWithValue("@RevisionId", RevisionId)
            LogDatabaseActivity(Command)
            If Command.ExecuteNonQuery() < 1 Then 'rows inserted
                Throw New Exception("Zero rows affected.")
            End If
        Next
        Transaction.Commit()
    Catch ex As Exception
        Transaction.Rollback()
        Throw New Exception("Rolled back transaction", ex)
    Finally
        Connection.Close()
    End Try
End Sub

我为每个表创建了一个对象，每个表都有构造函数、实例属性和方法、create-update-delete 命令、一堆查找函数和 IComparable 排序函数。这是大量的代码。

一对一的 DB 表到 VB 对象...

Public Class Book
    Implements iComparable

#Region " Constructors "

    Private _BookId As Guid
    Private _RevisionId As Integer
    Private _Title As String
    Private _AuthorId As Guid
    Private _Price As Decimal
    Private _Deleted As Boolean

    ...

    Sub New(ByVal BookRow As DataRow)
        Try
            _BookId = New Guid(BookRow("BookId").ToString)
            _RevisionId = CInt(BookRow("RevisionId"))
            _Title = CStr(BookRow("Title"))
            _AuthorId = New Guid(BookRow("AuthorId").ToString)
            _Price = CDec(BookRow("Price"))
        Catch ex As Exception
            'TO DO: log exception
            Throw New Exception("DataRow does not contain valid Book data.", ex)
        End Try
    End Sub

#End Region

...

#Region " Create, Update & Delete "

    Function Save() As SqlCommand
        If _BookId = Guid.Empty Then
            _BookId = Guid.NewGuid()
        End If
        Dim Command As SqlCommand = New SqlCommand("sp_Book_CreateUpdateDelete")
        Command.Parameters.AddWithValue("@BookId", _BookId)
        Command.Parameters.AddWithValue("@Title", _Title)
        Command.Parameters.AddWithValue("@AuthorId", _AuthorId)
        Command.Parameters.AddWithValue("@Price", _Price)
        Command.Parameters.AddWithValue("@Deleted", _Deleted)
        Return Command
    End Function

    Shared Function Delete(ByVal BookId As Guid) As SqlCommand
        Dim Doomed As Book = FindByBookId(BookId)
        Doomed.Deleted = True
        Return Doomed.Save()
    End Function

    ...

#End Region

...

#Region " Finders "

    Shared Function FindByBookId(ByVal BookId As Guid, Optional ByVal TryDeleted As Boolean = False) As Book
        Dim Command As SqlCommand
        If TryDeleted Then
            Command = New SqlCommand("sp_Book_FindByBookIdTryDeleted")
        Else
            Command = New SqlCommand("sp_Book_FindByBookId")
        End If
        Command.Parameters.AddWithValue("@BookId", BookId)
        If Database.Find(Command).Rows.Count > 0 Then
            Return New Book(Database.Find(Command).Rows(0))
        Else
            Return Nothing
        End If
    End Function

这样的系统保留了每一行的所有过去版本，但管理起来可能会很痛苦。

优点：

  • 保留的全部历史记录
  • 更少的存储过程

缺点：

  • 依赖非数据库应用程序来保证数据完整性
  • 需要编写大量代码
  • 没有在数据库中管理外键（再见自动 Linq-to-SQL 样式的对象生成）
  • 我仍然没有想出一个好的用户界面来检索所有保留的过去版本控制。

结论：

  • 如果没有一些易于使用的开箱即用 ORM 解决方案，我不会在新项目上遇到这样的麻烦。

我很好奇 Microsoft Entity Framework 是否可以很好地处理此类数据库设计。

Jeff 和 Stack Overflow 团队的其他成员在开发 Stack Overflow 时一定不得不处理类似的问题：过去对已编辑问题和答案的修订被保存和检索。

我相信 Jeff 说过他的团队使用 Linq to SQL 和 MS SQL Server。

我想知道他们是如何处理这些问题的。

于 2008-09-08T16:38:15.557 回答
1

据我所知，ORM 框架会希望为您生成 CRUD 代码，因此必须明确设计它们以实现 MVCC 选项；我不知道有什么开箱即用的。

从实体框架的角度来看，CSLA 根本不会为您实现持久性——它只是定义了一个“数据适配器”接口，您可以使用它来实现您需要的任何持久性。因此，您可以设置代码生成（CodeSmith 等）模板来为您的 CSLA 实体自动生成与 MVCC 数据库架构一起使用的 CRUD 逻辑。

这种方法适用于任何实体框架，很可能不仅仅是 CSLA，但它会是 CSLA 中非常“干净”的实现。

于 2008-09-05T19:53:18.560 回答
1

查看 Envers 项目 - 与 JPA/Hibernate 应用程序配合得很好，基本上可以为您做到这一点 - 跟踪另一个表中每个实体的不同版本，并为您提供类似 SVN 的可能性（“Gimme the version of Person being used 2008-11 -05...")

http://www.jboss.org/envers/

/詹斯

于 2008-11-06T09:37:23.787 回答
0

我一直认为您会在更新和删除时使用数据库触发器将这些行推送到 TableName_Audit 表中。

这适用于 ORM，为您提供历史记录，并且不会降低该表上的选择性能。这是个好主意还是我错过了什么？

于 2008-09-08T17:17:01.843 回答
0

我们所做的只是使用普通的 ORM（休眠）并使用视图 + 而不是触发器来处理 MVCC。

所以，有一个 v_emp 视图，它看起来就像一个普通的表，你可以插入和更新它，但是当你这样做时，触发器实际上会处理将正确的数据插入到基表中。

不是.. 我讨厌这种方法 :) 我会按照 Tim 的建议使用存储过程 API。

于 2008-11-06T09:55:13.920 回答