我有下面的代码:System.Transactions.TransactionException
[TestMethod]
public void CalculateThatWeHaveAllRetrunFromProxyImmo()
{
var test = new BaseDataAccess();
var sessionDateParam = new SqlParameter("@SessionDate", new DateTime(1900, 01, 31));
var dateDebutParam = new SqlParameter("@DateDebutHistoricRendement", new DateTime(1999, 01, 31));
var datefinParam = new SqlParameter("@DateFinHistoricRendement", new DateTime(2015, 01, 31));
var idProxyParam = new SqlParameter("@IdRealEstateProxy", 15);
var blocElementParam = new SqlParameter("@BlocNbrElement", 1501);
for (int index = 0; index < 17; index++)
{
Debug.WriteLine("Passage : " + index);
var ds = new DataSet();
SqlConnection conn = null;
using (conn = test.CreateAndOpenConnection())
{
SqlCommand cmd = null;
using (cmd = new SqlCommand("[Core].[cp_CalculAllReturnProxyImmo]", conn))
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandTimeout = 1000000;
cmd.Parameters.Add(sessionDateParam);
cmd.Parameters.Add(dateDebutParam);
cmd.Parameters.Add(datefinParam);
cmd.Parameters.Add(idProxyParam);
cmd.Parameters.Add(blocElementParam);
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
adapter.Fill(ds);
}
cmd.Parameters.Clear();
}
}
}
而且
/// <summary>
/// Creates our connection to the database.
/// </summary>
/// <returns>The SqlConnection object.</returns>
public SqlConnection CreateAndOpenConnection()
{
SqlConnection connection = null;
try
{
connection = new SqlConnection(Settings.Default.DbConnection);
connection.Open(); // the error appears here after 14 iterations
}
catch (SqlException sqlException)
{
}
catch (Exception exception)
{
}
return connection;
}
这里是我每次到达该指数在连接
connectionString="Data Source=xxx\yyy;Initial Catalog=BD;Integrated Security=True;Max Pool Size=5000"
而且14在我的循环中,我得到了一个System.Transactions.TransactionException
。 但我没有在我的代码中打开任何事务。我不明白。
下面是完整的堆栈:
à
System.Transactions.TransactionState.EnlistPromotableSinglePhase(InternalTransaction tx, IPromotableSinglePhaseNotification promotableSinglePhaseNotification, Transaction atomicTransaction)
à System.Transactions.Transaction.EnlistPromotableSinglePhase(IPromotableSinglePhaseNotification promotableSinglePhaseNotification)
à System.Data.SqlClient.SqlInternalConnection.EnlistNonNull(Transaction tx)
à System.Data.SqlClient.SqlInternalConnection.Enlist(Transaction tx)
à System.Data.SqlClient.SqlInternalConnectionTds.Activate(Transaction transaction)
à System.Data.ProviderBase.DbConnectionInternal.ActivateConnection(Transaction transaction)
à System.Data.ProviderBase.DbConnectionPool.PrepareConnection(DbConnection owningObject, DbConnectionInternal obj, Transaction transaction)
à System.Data.ProviderBase.DbConnectionPool.TryGetConnection(DbConnection owningObject, UInt32 waitForMultipleObjectsTimeout, Boolean allowCreate, Boolean onlyOneCheckConnection, DbConnectionOptions userOptions, ref DbConnectionInternal connection)
à System.Data.ProviderBase.DbConnectionPool.TryGetConnection(DbConnection owningObject, TaskCompletionSource`1 retry, DbConnectionOptions userOptions, ref DbConnectionInternal connection)
à System.Data.ProviderBase.DbConnectionFactory.TryGetConnection(DbConnection owningConnection, TaskCompletionSource`1 retry, DbConnectionOptions userOptions, DbConnectionInternal oldConnection, ref DbConnectionInternal connection)
à System.Data.ProviderBase.DbConnectionInternal.TryOpenConnectionInternal(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource`1 retry, DbConnectionOptions userOptions)
à System.Data.ProviderBase.DbConnectionClosed.TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource`1 retry, DbConnectionOptions userOptions)
à System.Data.SqlClient.SqlConnection.TryOpenInner(TaskCompletionSource`1 retry)
à System.Data.SqlClient.SqlConnection.TryOpen(TaskCompletionSource`1 retry)
à System.Data.SqlClient.SqlConnection.Open()
à System.Data.Common.DbDataAdapter.FillInternal(DataSet dataset, DataTable[] datatables, Int32 startRecord, Int32 maxRecords, String srcTable, IDbCommand command, CommandBehavior behavior)
à System.Data.Common.DbDataAdapter.Fill(DataSet dataSet, Int32 startRecord, Int32 maxRecords, String srcTable, IDbCommand command, CommandBehavior behavior)
à System.Data.Common.DbDataAdapter.Fill(DataSet dataSet)
à MarketRisk.dVar.IntegrationTests.Service.Managers.RealEstateProxyCreationManagerFixture.CalculateThatWeHaveAllRetrunFromProxyImmo() dans RealEstateProxyCreationManagerFixture.cs: line 67
调试跟踪:
调试跟踪:
Passage : 0
Passage : 1
Passage : 2
Passage : 3
Passage : 4
Passage : 5
Passage : 6
Passage : 7
Passage : 8
Passage : 9
Passage : 10
Passage : 11
Passage : 12
Test method
MarketRisk.dVar.IntegrationTests.Service.Managers.RealEstateProxyCreationManagerFixture.CalculateThatWeHaveAllRetrunFromProxyImmo Threw exception :
System.Transactions.TransactionException : The operation is not valid for the state of the transaction. ---> System.TimeoutException : Delay transaction time
该代码似乎是正确的。缺少存储过程代码,但尝试显式地打开连接而不将此任务留给SqlDataAdapter – Steve
“将此任务留给SqlDataAdapter”意味着什么? –
错了我。没有注意到连接在创建后打开。但是,如果您设置了与适配器的关闭连接(显式或通过命令),适配器将打开并在填充中关闭它。仍然失败的原因尚不清楚。也许在存储过程中称为 – Steve