Adds FbTransactionInfo.GetTransactionId().

Author: fdcastel

src/FirebirdSql.Data.FirebirdClient.Tests/FbTransactionTests.cs

@@ -139,4 +139,22 @@ public async Task SnapshotAtNumber()
 			}
 		}
 	}
+
+	[Test]
+	public async Task CanGetTransactionId()
+	{
+		if (!EnsureServerVersionAtLeast(new Version(2, 5, 0, 0)))
+			return;
+
+		await using (var transaction1 = await Connection.BeginTransactionAsync())
+		{
+			var idFromInfo = await new FbTransactionInfo(transaction1).GetTransactionIdAsync();
+			Assert.NotZero(idFromInfo);
+
+			var command = new FbCommand("SELECT current_transaction FROM rdb$database", Connection, transaction1);
+			var idFromSql = await command.ExecuteScalarAsync();
+
+			Assert.AreEqual(idFromInfo, idFromSql);
+		}
+	}
 }

src/FirebirdSql.Data.FirebirdClient/Common/IscHelper.cs

@@ -206,6 +206,10 @@ public static List<object> ParseTransactionInfo(byte[] buffer, Charset charset)
 				case IscCodes.isc_info_error:
 					throw FbException.Create("Received error response.");
 
+				case IscCodes.isc_info_tra_id:
+					info.Add(VaxInteger(buffer, pos, length));
+					break;
+
 				case IscCodes.fb_info_tra_snapshot_number:
 					info.Add(VaxInteger(buffer, pos, length));
 					break;

src/FirebirdSql.Data.FirebirdClient/FirebirdClient/FbTransactionInfo.cs

@@ -33,6 +33,15 @@ public sealed class FbTransactionInfo
 
 	#region Methods
 
+	public long GetTransactionId()
+	{
+		return GetValue<long>(IscCodes.isc_info_tra_id);
+	}
+	public Task<long> GetTransactionIdAsync(CancellationToken cancellationToken = default)
+	{
+		return GetValueAsync<long>(IscCodes.isc_info_tra_id, cancellationToken);
+	}
+
 	public long GetTransactionSnapshotNumber()
 	{
 		return GetValue<long>(IscCodes.fb_info_tra_snapshot_number);