From 60c04d10fab85caf845f69bcaad038cdb4b07881 Mon Sep 17 00:00:00 2001 From: Alok Deorani Date: Wed, 21 Jan 2026 15:46:49 -0800 Subject: [PATCH] Decimal256 not working --- csharp/test/StatementTests.cs | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) diff --git a/csharp/test/StatementTests.cs b/csharp/test/StatementTests.cs index 8d3001c..e6ea8ec 100644 --- a/csharp/test/StatementTests.cs +++ b/csharp/test/StatementTests.cs @@ -216,6 +216,35 @@ public async Task CanCancelStreamFromStatement() } } + [Fact] + public async Task BigNumericTest() + { + foreach (BigQueryTestEnvironment environment in _environments) + { + using AdbcConnection adbcConnection = GetAdbcConnection(environment.Name); + using AdbcStatement statement = adbcConnection.CreateStatement(); + statement.SqlQuery = "select `studio`, `bets_game` from `mashuptest-154002`.`NWIND`.`ICM684001186`"; + QueryResult result = statement.ExecuteQuery(); + try + { + QueryResult queryResult = result; + using IArrowArrayStream? stream = queryResult.Stream; + Assert.NotNull(stream); + RecordBatch batch = await stream.ReadNextRecordBatchAsync(); + + Assert.Fail("Expecting OperationCanceledException to be thrown."); + } + catch (Exception ex) when (BigQueryUtils.ContainsException(ex, out OperationCanceledException? _)) + { + _outputHelper?.WriteLine($"Received expected OperationCanceledException: {ex.Message}"); + } + catch (Exception ex) when (ex is not FailException) + { + Assert.Fail($"Expecting OperationCanceledException to be thrown. Instead, received {ex.GetType().Name}: {ex.Message}"); + } + } + } + private AdbcConnection GetAdbcConnection(string? environmentName) { if (string.IsNullOrEmpty(environmentName))