1

我有一个遗留数据库，其中一些存储过程计算所有表的行 ID。现在，我想按照此页面http://www.richter-web.info/Wordpress/?p=132的提示覆盖 IIdentifierGenerator， 以避免出现 Id(x => x.id).GenereatedBy.Assigned。

现在，当我保存一些对象时，当然是在名为 AnnexHierarchy 的 Nhibernate 事务中，然后一旦它进入 ATKIdGenerator.Generate 并启动 command.ExecuteNonQuery() 我收到一些异常 ExecuteNonQuery 需要命令在连接时进行事务分配给该命令的处于挂起的本地事务中。该命令的 Transaction 属性尚未初始化。

如何从 Nhibernate 会话对象中提取 DB 事务，以便将其附加到命令？

我将 FluentMapping 用于 poco

 public AppendixHierarchyMap()
        {
            Table("appendixHierarchy");
            Id(x => x.id).GeneratedBy.Custom(typeof(ATKIdGenerator), a => a.AddParam("TableName", "appendixHierarchy"));
.....

这是 ID 生成器

public class ATKIdGenerator : IIdentifierGenerator, IConfigurable
    {

        private string TableName { get; set; }
        #region IIdentifierGenerator Members

        public object Generate(NHibernate.Engine.ISessionImplementor session, object obj)
        {
            IDbCommand command = new SqlCommand();
            command.Connection = session.Connection;
            //transaction.Enlist(command);
            command.CommandType = CommandType.StoredProcedure;
            command.CommandText = "dbo.ups_GetNewId";
            // Set input parameters   
            var parm = new SqlParameter("@tableName", SqlDbType.VarChar);
            parm.Value = TableName;
            command.Parameters.Add(parm);
            // Set output parameter   
            var outputParameter = new SqlParameter("@id", SqlDbType.Int);
            outputParameter.Direction = ParameterDirection.Output;
            command.Parameters.Add(outputParameter);
            // Set a return value   
            var returnParameter = new SqlParameter("@RETURN_VALUE", SqlDbType.Int);
            returnParameter.Direction = ParameterDirection.ReturnValue;
            command.Parameters.Add(returnParameter);
            // Execute the stored procedure   
            command.ExecuteNonQuery();
            return (int)((SqlParameter)command.Parameters["@id"]).Value;    
        }

        #endregion

        #region IConfigurable Members

        public void Configure(NHibernate.Type.IType type, IDictionary<string, string> parms, NHibernate.Dialect.Dialect d)
        {
            TableName = parms["TableName"];
        }

        #endregion
    }
4

1 回答 1

1

我认为您需要在生成方法中打开另一个连接，而不是在会话中重新使用一个。

于 2009-12-01T20:22:32.110 回答