src/Coast.Core.Test/Dapper.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

using Dapper;
using Npgsql;
using System;
using System.Data;
using System.Threading.Tasks;
using System.Transactions;
using Xunit;

namespace Coast.Core.Test
{
    public class Dapper
    {
        private const string InsertSagaSql =
@"INSERT INTO ""Coast_Saga"" 
(""Id"", ""State"", ""CreationTime"") 
VALUES (@Id, @State, @CreationTime); ";
        [Fact(Skip ="integration test")]
        public async Task Test1Async()
        {
            using var conn = new NpgsqlConnection("Host=localhost;Port=5432;database=postgres;User Id=postgres;Password=root;");
            conn.Open();
            var tr = conn.BeginTransaction();

            var test = Transaction.Current;
            await conn.ExecuteAsync(
                    InsertSagaSql,
                    new { Id = 5, State = SagaStateEnum.Started, CreationTime = DateTime.UtcNow },
                    transaction: tr).ConfigureAwait(false);
            await ChangeDb(conn, tr);

            throw new Exception();
            tr.Commit();
        }

        private async Task ChangeDb(IDbConnection db, IDbTransaction tx)
        {
            var conn2 = new NpgsqlConnection("Host=localhost;Port=5432;database=postgres;User Id=alean;Password=alean;");
            await db.ExecuteAsync(
                    InsertSagaSql,
                    new { Id = 6, State = SagaStateEnum.Started, CreationTime = DateTime.UtcNow },
                    transaction: tx).ConfigureAwait(false);


            conn2.Close();
        }
    }
}