Nhibernate 标准：“选择 max(id)...”

Question

我可以使用 Criteria 执行 t-sql 命令来选择表中列的最大值吗？

'从客户中选择@cus_id = max(id) + 1'

Ta

Ollie

Answer 1

使用投影：

session.CreateCriteria(typeof(Customer))
  .SetProjection( Projections.Max("Id") )
  . UniqueResult();

Answer 2

Max(id) + 1 是一种非常糟糕的生成 id 的方法。 如果这是您的目标，请寻找另一种生成 id 的方法。

编辑：回答 LnDCobra：

这很糟糕，因为很难确保插入时得到的 max(id) 仍然是 max(id) 。 如果另一个进程插入一行，您的插入将具有相同的 id，并且您的插入将失败。 （或者，相反，如果您的插入先发生，则其他进程的插入将失败。）

为了防止这种情况，您必须阻止任何其他插入/使您的获取和后续插入原子化，这通常意味着锁定表，这会损害性能。

如果您只锁定写入，则其他进程将获得 max(id)，这与您获得的 max(id) 相同。 您执行插入并释放锁，它会插入重复的 id 并且失败。 或者它也尝试锁定，在这种情况下它会等待你。 如果你也锁定防止读取，那么每个人都会等待你。 如果它也锁定写入，那么它不会插入重复的 id，但它会等待您的读取和写入。

（它破坏了封装：您应该让 RDBMS 找出它的 ID，而不是连接到它的客户端程序。）

通常，此策略将：
* 中断
* 需要一堆“管道”代码才能使其工作
* 显着降低性能
* 或全部三者

，与仅使用 RDBMS 的内置序列或生成的自动增量 id 相比，它会更慢、更不稳健，并且需要更难维护代码。

Answer 3

最好的方法是制作额外的序列表。
您可以在其中维护序列目标和值。

public class Sequence : Entity
{

    public virtual long? OwnerId { get; set; }

    public virtual SequenceTarget SequenceTarget { get; set; }

    public virtual bool IsLocked { get; set; }

    public virtual long Value { get; set; }

    public void GenerateNextValue()
    {
        Value++;
    }

}

public class SequenceTarget : Entity
{

    public virtual string Name { get; set; }

}

public long GetNewSequenceValueForZZZZ(long ZZZZId)
{
    var target =
        Session
        .QueryOver<SequenceTarget>()
        .Where(st => st.Name == "DocNumber")
        .SingleOrDefault();

    if (target == null)
    {
        throw new EntityNotFoundException(typeof(SequenceTarget));
    }

    return GetNewSequenceValue(ZZZZId, target);
}

protected long GetNewSequenceValue(long? ownerId, SequenceTarget target)
{
    var seqQry =
       Session
       .QueryOver<Sequence>()
       .Where(seq => seq.SequenceTarget == target);
    if (ownerId.HasValue)
    {
       seqQry.Where(seq => seq.OwnerId == ownerId.Value);
    }

    var sequence = seqQry.SingleOrDefault();

    if (sequence == null)
    {
       throw new EntityNotFoundException(typeof(Sequence));
    }

    // re-read sequence, if it was in session
    Session.Refresh(sequence);

    // update IsLocked field, so we acuire lock on record
    // configure dynamic update , so only 1 field is being updated
    sequence.IsLocked = !sequence.IsLocked;
    Session.Update(sequence);
    // force update to db
    Session.Flush();
    // now we gained block - re-read record.
    Session.Refresh(sequence);

    // generate new value
    sequence.GenerateNextValue();
    // set back dummy filed
    sequence.IsLocked = !sequence.IsLocked;
    // update sequence & force changes to DB
    Session.Update(sequence);
    Session.Flush();

    return sequence.Value;
}

OwnerId - 当您需要基于某种所有者为同一实体维护不同的序列时。 例如，您需要维护合同内文档的编号，则 OwnerId 将 = ContractId