Как передать DataTable в качестве параметра хранимой процедуры, не совершая транзакции текущего сеанса?

Question

Мой код выглядит следующим образом:

public void InsertSampleData(DataTable tempTable) 
    { 
     session.Transaction.Commit(); 
     var connection = session.GetSessionImplementation().Connection; 
     using (var sqlConnection = (SqlConnection)connection) 
     { 
      using (var cmd = sqlConnection.CreateCommand()) 
      { 
       cmd.CommandType = CommandType.StoredProcedure; 
       cmd.CommandText = "dbo.insertData"; 
       cmd.Parameters.Add("@sItems", SqlDbType.Structured); 
       var sqlParam = cmd.Parameters["@Items"]; 
       sqlParam.Direction = ParameterDirection.Input; 
       sqlParam.TypeName = "[dbo].[DataItemType]"; 
       sqlParam.Value = tempTable; 
       cmd.ExecuteNonQuery(); 
      } 
     } 
    } 

код работает нормально, но если я не совершить сделку он бросает исключение, как показано

System.InvalidOperationException: ExecuteNonQuery требует команды, чтобы иметь когда соединение, назначенное команде , находится в ожидающей локальной транзакции. Свойство Transaction команды не было инициализировано.

Но я не хочу, чтобы транзакция была совершена еще до завершения всей операции. Как я могу это достичь?

Answer 1

проблема заключается в том, что транзакция должна была быть использована и была уже удалена, поэтому либо создайте новый SqlConnection, либо получите новый сеанс, а затем запустите запрос как часть нового сеанса.

public void InsertSampleData(DataTable tempTable) 
{ 
    session.Transaction.Commit(); 

    using (var sqlConnection = new SqlConnection(session.GetSessionImplementation() 
             .Connection.ConnectionString)) 
    { 
     using (var cmd = sqlConnection.CreateCommand()) 
     { 
      cmd.CommandType = CommandType.StoredProcedure; 
      cmd.CommandText = "dbo.insertData"; 
      cmd.Parameters.Add("@sItems", SqlDbType.Structured); 
      var sqlParam = cmd.Parameters["@Items"]; 
      sqlParam.Direction = ParameterDirection.Input; 
      sqlParam.TypeName = "[dbo].[DataItemType]"; 
      sqlParam.Value = tempTable; 
      cmd.ExecuteNonQuery(); 
     } 
    } 
} 

или

public void InsertSampleData(DataTable tempTable) 
    { 
     session.Transaction.Commit(); 
     var connection = session.SessionFactory.OpenSession().GetSessionImplementation().Connection; 
     using (var sqlConnection = (SqlConnection)connection) 
     { 
      using (var cmd = sqlConnection.CreateCommand()) 
      { 
       cmd.CommandType = CommandType.StoredProcedure; 
       cmd.CommandText = "dbo.insertData"; 
       cmd.Parameters.Add("@sItems", SqlDbType.Structured); 
       var sqlParam = cmd.Parameters["@Items"]; 
       sqlParam.Direction = ParameterDirection.Input; 
       sqlParam.TypeName = "[dbo].[DataItemType]"; 
       sqlParam.Value = tempTable; 
       cmd.ExecuteNonQuery(); 
      } 
     } 
    } 

Кстати, почему используют SQLConnection почему ARENT вы exexurting запрос с помощью NHibernate сессии, вы могли бы сделать все, что вы делаете прямо сейчас, используя NHibernate сессии.

session.CreateSQLQuery(<your sql>) 
.SetParameters() //and various other API to set your parameters 
.ExecuteUpdate();