bug: fixed extract json / yson types

Author: KirillKurdyukov

src/Ydb.Sdk/src/Ado/YdbDataReader.cs

@@ -333,7 +333,10 @@ public override object GetValue(int ordinal)
             YdbTypeId.Float => ydbValue.GetFloat(),
             YdbTypeId.Double => ydbValue.GetDouble(),
             YdbTypeId.Interval => ydbValue.GetInterval(),
-            YdbTypeId.Utf8 or YdbTypeId.JsonDocument or YdbTypeId.Json or YdbTypeId.Yson => GetString(ordinal),
+            YdbTypeId.Utf8 => ydbValue.GetUtf8(),
+            YdbTypeId.Json => ydbValue.GetJson(),
+            YdbTypeId.JsonDocument => ydbValue.GetJsonDocument(),
+            YdbTypeId.Yson => ydbValue.GetYson(),
             YdbTypeId.String => ydbValue.GetString(),
             YdbTypeId.DecimalType => ydbValue.GetDecimal(),
             _ => throw new YdbException($"Unsupported ydb type {ydbValue.TypeId}")

src/Ydb.Sdk/tests/Ado/YdbCommandTests.cs

@@ -1,7 +1,9 @@
 using System.Data;
 using System.Text;
+using Dapper;
 using Xunit;
 using Ydb.Sdk.Ado;
+using Ydb.Sdk.Value;
 
 namespace Ydb.Sdk.Tests.Ado;
 
@@ -67,6 +69,42 @@ public async Task ExecuteScalarAsync_WhenSetYdbParameterThenPrepare_ReturnThisVa
         Assert.Equal(data.Expected, await dbCommand.ExecuteScalarAsync());
     }
 
+    [Fact]
+    public async Task ExecuteScalarAsync_WhenNoDbTypeParameter_ReturnThisValue()
+    {
+        const string simpleJson = @"{""a"":""b""}";
+
+        var args = new List<(YdbValue YdbValue, object Expected)>
+        {
+            (YdbValue.MakeJson(simpleJson), simpleJson),
+            (YdbValue.MakeJsonDocument(simpleJson), simpleJson),
+            (YdbValue.MakeInterval(TimeSpan.FromSeconds(5)), TimeSpan.FromSeconds(5)),
+            (YdbValue.MakeYson(Encoding.ASCII.GetBytes("{type=\"yson\"}")), Encoding.ASCII.GetBytes("{type=\"yson\"}")),
+            (YdbValue.MakeOptionalJson(simpleJson), simpleJson),
+            (YdbValue.MakeOptionalJsonDocument(simpleJson), simpleJson),
+            (YdbValue.MakeOptionalInterval(TimeSpan.FromSeconds(5)), TimeSpan.FromSeconds(5)),
+            (YdbValue.MakeOptionalYson(Encoding.ASCII.GetBytes("{type=\"yson\"}")),
+                Encoding.ASCII.GetBytes("{type=\"yson\"}"))
+        };
+
+        await using var connection = new YdbConnection();
+        await connection.OpenAsync();
+
+        var dbCommand = connection.CreateCommand();
+        dbCommand.CommandText = "SELECT @var;";
+
+        foreach (var arg in args)
+        {
+            dbCommand.Parameters.Clear();
+            dbCommand.Parameters.Add(new YdbParameter
+            {
+                ParameterName = "@var",
+                Value = arg.YdbValue
+            });
+            Assert.Equal(arg.Expected, await dbCommand.ExecuteScalarAsync());
+        }
+    }
+
     [Fact]
     public async Task ExecuteNonQueryAsync_WhenCreateUser_ReturnEmptyResultSet()
     {