###############################################################################
#
# tkt-5cee5409f8.eagle --
#
# Written by Joe Mistachkin.
# Released to the public domain, use at your own risk!
#
###############################################################################
package require Eagle
package require Eagle.Library
package require Eagle.Test
runTestPrologue
###############################################################################
package require System.Data.SQLite.Test
runSQLiteTestPrologue
###############################################################################
runTest {test tkt-5cee5409f8-1.1 {asynchronous transaction handling} -setup {
setupDb [set fileName tkt-5cee5409f8-1.1.db]
} -body {
sql execute $db "CREATE TABLE t1(x INTEGER);"
set id [object invoke Interpreter.GetActive NextId]
set dataSource [file join [getDatabaseDirectory] $fileName]
unset -nocomplain results errors
set code [compileCSharpWith [subst {
using System;
using System.Data.SQLite;
using System.Transactions;
namespace _Dynamic${id}
{
public static class Test${id}
{
private sealed class EnlistmentNotification : IEnlistmentNotification
{
#region Private Data
private bool forceRollback;
#endregion
/////////////////////////////////////////////////////////////////////
#region Private Constructors
private EnlistmentNotification(bool forceRollback)
{
this.forceRollback = forceRollback;
}
#endregion
/////////////////////////////////////////////////////////////////////
#region IEnlistmentNotification Members
public void Commit(Enlistment enlistment)
{
enlistment.Done();
}
/////////////////////////////////////////////////////////////////////
public void InDoubt(Enlistment enlistment)
{
enlistment.Done();
}
/////////////////////////////////////////////////////////////////////
public void Prepare(PreparingEnlistment preparingEnlistment)
{
if (forceRollback)
preparingEnlistment.ForceRollback();
else
preparingEnlistment.Prepared();
}
/////////////////////////////////////////////////////////////////////
public void Rollback(Enlistment enlistment)
{
enlistment.Done();
}
#endregion
/////////////////////////////////////////////////////////////////////
#region Public Static Methods
public static void UseDistributedTransaction(bool forceRollback)
{
Transaction.Current.EnlistDurable(
Guid.NewGuid(), new EnlistmentNotification(forceRollback),
EnlistmentOptions.None);
}
#endregion
}
///////////////////////////////////////////////////////////////////////
public static void DoTransactions(SQLiteConnection connection)
{
for (int iteration = 0; iteration < 1000; iteration++)
{
using (TransactionScope transactionScope = new TransactionScope())
{
EnlistmentNotification.UseDistributedTransaction(false);
TransactionInformation transactionInformation =
Transaction.Current.TransactionInformation;
if (transactionInformation.DistributedIdentifier.Equals(
Guid.Empty))
{
throw new Exception("distributed identifier is empty");
}
connection.EnlistTransaction(Transaction.Current);
using (SQLiteCommand command = connection.CreateCommand())
{
command.CommandText = "INSERT INTO t1(x) VALUES(?);";
command.Parameters.Add(new SQLiteParameter("", iteration));
command.ExecuteNonQuery();
}
transactionScope.Complete();
}
}
}
///////////////////////////////////////////////////////////////////////
public static void Main()
{
using (SQLiteConnection connection = new SQLiteConnection(
"Data Source=${dataSource};[getTestProperties]"))
{
connection.Open();
DoTransactions(connection);
}
}
}
}
}] true true true results errors System.Data.SQLite.dll]
list $code $results \
[expr {[info exists errors] ? $errors : ""}] \
[expr {$code eq "Ok" ? [catch {
object invoke _Dynamic${id}.Test${id} Main
} result] : [set result ""]}] $result
} -cleanup {
cleanupDb $fileName
unset -nocomplain result results errors code dataSource id db fileName
} -constraints {eagle command.object monoBug211 monoBug54 command.sql\
compile.DATA SQLite System.Data.SQLite compileCSharp} -match regexp -result \
{^Ok System#CodeDom#Compiler#CompilerResults#\d+ \{\} 0 \{\}$}}
###############################################################################
runSQLiteTestEpilogue
runTestEpilogue