Commit aa6a03c

committed

Adds FbTransactionInfo.GetTransactionId().

1 parent ac0fc79 commit aa6a03cCopy full SHA for aa6a03c

File tree

+31

-0

lines changed

+31

-0

lines changed

Lines changed: 18 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -139,4 +139,22 @@ public async Task SnapshotAtNumber()`
`139`	`139`	`}`
`140`	`140`	`}`
`141`	`141`	`}`
	`142`	`+`
	`143`	`+ [Test]`
	`144`	`+ public async Task CanGetTransactionId()`
	`145`	`+ {`
	`146`	`+ if (!EnsureServerVersionAtLeast(new Version(2, 5, 0, 0)))`
	`147`	`+ return;`
	`148`	`+`
	`149`	`+ await using (var transaction1 = await Connection.BeginTransactionAsync())`
	`150`	`+ {`
	`151`	`+ var idFromInfo = await new FbTransactionInfo(transaction1).GetTransactionIdAsync();`
	`152`	`+ Assert.NotZero(idFromInfo);`
	`153`	`+`
	`154`	`+ var command = new FbCommand("SELECT current_transaction FROM rdb$database", Connection, transaction1);`
	`155`	`+ var idFromSql = await command.ExecuteScalarAsync();`
	`156`	`+`
	`157`	`+ Assert.AreEqual(idFromInfo, idFromSql);`
	`158`	`+ }`
	`159`	`+ }`
`142`	`160`	`}`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -206,6 +206,10 @@ public static List<object> ParseTransactionInfo(byte[] buffer, Charset charset)`
`206`	`206`	`case IscCodes.isc_info_error:`
`207`	`207`	`throw FbException.Create("Received error response.");`
`208`	`208`
	`209`	`+ case IscCodes.isc_info_tra_id:`
	`210`	`+ info.Add(VaxInteger(buffer, pos, length));`
	`211`	`+ break;`
	`212`	`+`
`209`	`213`	`case IscCodes.fb_info_tra_snapshot_number:`
`210`	`214`	`info.Add(VaxInteger(buffer, pos, length));`
`211`	`215`	`break;`

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,15 @@ public sealed class FbTransactionInfo`
`33`	`33`
`34`	`34`	`#region Methods`
`35`	`35`
	`36`	`+ public long GetTransactionId()`
	`37`	`+ {`
	`38`	`+ return GetValue<long>(IscCodes.isc_info_tra_id);`
	`39`	`+ }`
	`40`	`+ public Task<long> GetTransactionIdAsync(CancellationToken cancellationToken = default)`
	`41`	`+ {`
	`42`	`+ return GetValueAsync<long>(IscCodes.isc_info_tra_id, cancellationToken);`
	`43`	`+ }`
	`44`	`+`
`36`	`45`	`public long GetTransactionSnapshotNumber()`
`37`	`46`	`{`
`38`	`47`	`return GetValue<long>(IscCodes.fb_info_tra_snapshot_number);`

Comments

(0)