Skip to content

Get rid of unsafe code from TruncateToNetDecimal() implemetation #397

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 23 commits into from
Jun 25, 2025
Merged

Get rid of unsafe code from TruncateToNetDecimal() implemetation #397

Changes from 9 commits
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
4fbfdc4
Make `TruncateToNetDecimal()` be `safe`
SergeiPavlov Jun 24, 2025
8ddfbf4
Ten value
SergeiPavlov Jun 24, 2025
e8695d1
Update Orm/Xtensive.Orm.SqlServer/Sql.Drivers.SqlServer/InternalHelpe…
SergeiPavlov Jun 24, 2025
68b5084
FromSqlDecimalData()
SergeiPavlov Jun 24, 2025
ba33915
Update Orm/Xtensive.Orm.SqlServer/Sql.Drivers.SqlServer/InternalHelpe…
SergeiPavlov Jun 24, 2025
8d46035
Update Orm/Xtensive.Orm.SqlServer/Sql.Drivers.SqlServer/InternalHelpe…
SergeiPavlov Jun 24, 2025
ed2eef4
Simplify
SergeiPavlov Jun 24, 2025
7b4db8e
Pattern
SergeiPavlov Jun 24, 2025
5c46d9d
Fix casting
SergeiPavlov Jun 24, 2025
efec239
Fix order of UInt128 parts
SergeiPavlov Jun 24, 2025
c8dbd00
Simplify
SergeiPavlov Jun 24, 2025
81456c9
Simplify
SergeiPavlov Jun 24, 2025
a87ca73
u128
SergeiPavlov Jun 24, 2025
58b3eed
Simplify
SergeiPavlov Jun 24, 2025
8e121a6
Simplify
SergeiPavlov Jun 24, 2025
7a05b38
Try Catch
SergeiPavlov Jun 24, 2025
c8212d4
Typo
SergeiPavlov Jun 24, 2025
734769a
add comment
SergeiPavlov Jun 24, 2025
5417af4
Simplify
SergeiPavlov Jun 24, 2025
e329140
correct comment
SergeiPavlov Jun 24, 2025
8d5eede
fix build
SergeiPavlov Jun 24, 2025
05efcae
Simplify
SergeiPavlov Jun 24, 2025
276105e
Simplify
SergeiPavlov Jun 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
354 changes: 161 additions & 193 deletions Orm/Xtensive.Orm.SqlServer/Sql.Drivers.SqlServer/InternalHelpers.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,219 +4,187 @@
// Created by: Alexey Kulakov
// Created: 2020.04.10

using System;
using System.Collections.Generic;
using Microsoft.Data.SqlClient;
using System.Data.SqlTypes;
using System.Diagnostics.Metrics;
using System.Numerics;
using Xtensive.Diagnostics;

namespace Xtensive.Sql.Drivers.SqlServer
namespace Xtensive.Sql.Drivers.SqlServer;

internal static class InternalHelpers
{
internal static class InternalHelpers
private static readonly UInt128[] PowersOf10 = [
1,
10,
100,
1000,
10000,
100000,
1000000,
10000000,
100000000,
1000000000
];

private static readonly UInt128 Max96bitValue = new(0xFFFFFFFFUL, ulong.MaxValue);

private static readonly UInt128 Ten = 10;

/// <summary>
/// This API supports the Entity Framework Core infrastructure and is not intended to be used
/// directly from your code. This API may change or be removed in future releases.
/// </summary>
public static bool ShouldRetryOn(Exception ex)
{
private static readonly uint[] PowersOf10 = {
1,
10,
100,
1000,
10000,
100000,
1000000,
10000000,
100000000,
1000000000
};

/// <summary>
/// This API supports the Entity Framework Core infrastructure and is not intended to be used
/// directly from your code. This API may change or be removed in future releases.
/// </summary>
public static bool ShouldRetryOn(Exception ex)
{
ArgumentNullException.ThrowIfNull(ex);
if (ex is SqlException sqlException) {
foreach (SqlError err in sqlException.Errors) {
Metrics.SqlErrorCounter.Add(1, KeyValuePair.Create("Code", (object)err.Number));
}
ArgumentNullException.ThrowIfNull(ex);
if (ex is SqlException sqlException) {
foreach (SqlError err in sqlException.Errors) {
Metrics.SqlErrorCounter.Add(1, KeyValuePair.Create("Code", (object)err.Number));
}

foreach (SqlError err in sqlException.Errors) {
switch (err.Number) {
// SQL Error Code: 49920
// Cannot process request. Too many operations in progress for subscription "%ld".
// The service is busy processing multiple requests for this subscription.
// Requests are currently blocked for resource optimization. Query sys.dm_operation_status for operation status.
// Wait until pending requests are complete or delete one of your pending requests and retry your request later.
case 49920:
// SQL Error Code: 49919
// Cannot process create or update request. Too many create or update operations in progress for subscription "%ld".
// The service is busy processing multiple create or update requests for your subscription or server.
// Requests are currently blocked for resource optimization. Query sys.dm_operation_status for pending operations.
// Wait till pending create or update requests are complete or delete one of your pending requests and
// retry your request later.
case 49919:
// SQL Error Code: 49918
// Cannot process request. Not enough resources to process request.
// The service is currently busy.Please retry the request later.
case 49918:
// SQL Error Code: 41839
// Transaction exceeded the maximum number of commit dependencies.
case 41839:
// SQL Error Code: 41325
// The current transaction failed to commit due to a serializable validation failure.
case 41325:
// SQL Error Code: 41305
// The current transaction failed to commit due to a repeatable read validation failure.
case 41305:
// SQL Error Code: 41302
// The current transaction attempted to update a record that has been updated since the transaction started.
case 41302:
// SQL Error Code: 41301
// Dependency failure: a dependency was taken on another transaction that later failed to commit.
case 41301:
// SQL Error Code: 40613
// Database XXXX on server YYYY is not currently available. Please retry the connection later.
// If the problem persists, contact customer support, and provide them the session tracing ID of ZZZZZ.
case 40613:
// SQL Error Code: 40501
// The service is currently busy. Retry the request after 10 seconds. Code: (reason code to be decoded).
case 40501:
// SQL Error Code: 40197
// The service has encountered an error processing your request. Please try again.
case 40197:
// SQL Error Code: 10929
// Resource ID: %d. The %s minimum guarantee is %d, maximum limit is %d and the current usage for the database is %d.
// However, the server is currently too busy to support requests greater than %d for this database.
// For more information, see http://go.microsoft.com/fwlink/?LinkId=267637. Otherwise, please try again.
case 10929:
// SQL Error Code: 10928
// Resource ID: %d. The %s limit for the database is %d and has been reached. For more information,
// see http://go.microsoft.com/fwlink/?LinkId=267637.
case 10928:
// SQL Error Code: 10060
// A network-related or instance-specific error occurred while establishing a connection to SQL Server.
// The server was not found or was not accessible. Verify that the instance name is correct and that SQL Server
// is configured to allow remote connections. (provider: TCP Provider, error: 0 - A connection attempt failed
// because the connected party did not properly respond after a period of time, or established connection failed
// because connected host has failed to respond.)"}
case 10060:
// SQL Error Code: 10054
// A transport-level error has occurred when sending the request to the server.
// (provider: TCP Provider, error: 0 - An existing connection was forcibly closed by the remote host.)
case 10054:
// SQL Error Code: 10053
// A transport-level error has occurred when receiving results from the server.
// An established connection was aborted by the software in your host machine.
case 10053:
// SQL Error Code: 1205
// Deadlock
case 1205:
// SQL Error Code: 233
// The client was unable to establish a connection because of an error during connection initialization process before login.
// Possible causes include the following: the client tried to connect to an unsupported version of SQL Server;
// the server was too busy to accept new connections; or there was a resource limitation (insufficient memory or maximum
// allowed connections) on the server. (provider: TCP Provider, error: 0 - An existing connection was forcibly closed by
// the remote host.)
case 233:
// SQL Error Code: 121
// The semaphore timeout period has expired
case 121:
// SQL Error Code: 64
// A connection was successfully established with the server, but then an error occurred during the login process.
// (provider: TCP Provider, error: 0 - The specified network name is no longer available.)
case 64:
// DBNETLIB Error Code: 20
// The instance of SQL Server you attempted to connect to does not support encryption.
case 20:
return true;
// This exception can be thrown even if the operation completed successfully, so it's safer to let the application fail.
// DBNETLIB Error Code: -2
// Timeout expired. The timeout period elapsed prior to completion of the operation or the server is not responding. The statement has been terminated.
//case -2:
}
foreach (SqlError err in sqlException.Errors) {
switch (err.Number) {
// SQL Error Code: 49920
// Cannot process request. Too many operations in progress for subscription "%ld".
// The service is busy processing multiple requests for this subscription.
// Requests are currently blocked for resource optimization. Query sys.dm_operation_status for operation status.
// Wait until pending requests are complete or delete one of your pending requests and retry your request later.
case 49920:
// SQL Error Code: 49919
// Cannot process create or update request. Too many create or update operations in progress for subscription "%ld".
// The service is busy processing multiple create or update requests for your subscription or server.
// Requests are currently blocked for resource optimization. Query sys.dm_operation_status for pending operations.
// Wait till pending create or update requests are complete or delete one of your pending requests and
// retry your request later.
case 49919:
// SQL Error Code: 49918
// Cannot process request. Not enough resources to process request.
// The service is currently busy.Please retry the request later.
case 49918:
// SQL Error Code: 41839
// Transaction exceeded the maximum number of commit dependencies.
case 41839:
// SQL Error Code: 41325
// The current transaction failed to commit due to a serializable validation failure.
case 41325:
// SQL Error Code: 41305
// The current transaction failed to commit due to a repeatable read validation failure.
case 41305:
// SQL Error Code: 41302
// The current transaction attempted to update a record that has been updated since the transaction started.
case 41302:
// SQL Error Code: 41301
// Dependency failure: a dependency was taken on another transaction that later failed to commit.
case 41301:
// SQL Error Code: 40613
// Database XXXX on server YYYY is not currently available. Please retry the connection later.
// If the problem persists, contact customer support, and provide them the session tracing ID of ZZZZZ.
case 40613:
// SQL Error Code: 40501
// The service is currently busy. Retry the request after 10 seconds. Code: (reason code to be decoded).
case 40501:
// SQL Error Code: 40197
// The service has encountered an error processing your request. Please try again.
case 40197:
// SQL Error Code: 10929
// Resource ID: %d. The %s minimum guarantee is %d, maximum limit is %d and the current usage for the database is %d.
// However, the server is currently too busy to support requests greater than %d for this database.
// For more information, see http://go.microsoft.com/fwlink/?LinkId=267637. Otherwise, please try again.
case 10929:
// SQL Error Code: 10928
// Resource ID: %d. The %s limit for the database is %d and has been reached. For more information,
// see http://go.microsoft.com/fwlink/?LinkId=267637.
case 10928:
// SQL Error Code: 10060
// A network-related or instance-specific error occurred while establishing a connection to SQL Server.
// The server was not found or was not accessible. Verify that the instance name is correct and that SQL Server
// is configured to allow remote connections. (provider: TCP Provider, error: 0 - A connection attempt failed
// because the connected party did not properly respond after a period of time, or established connection failed
// because connected host has failed to respond.)"}
case 10060:
// SQL Error Code: 10054
// A transport-level error has occurred when sending the request to the server.
// (provider: TCP Provider, error: 0 - An existing connection was forcibly closed by the remote host.)
case 10054:
// SQL Error Code: 10053
// A transport-level error has occurred when receiving results from the server.
// An established connection was aborted by the software in your host machine.
case 10053:
// SQL Error Code: 1205
// Deadlock
case 1205:
// SQL Error Code: 233
// The client was unable to establish a connection because of an error during connection initialization process before login.
// Possible causes include the following: the client tried to connect to an unsupported version of SQL Server;
// the server was too busy to accept new connections; or there was a resource limitation (insufficient memory or maximum
// allowed connections) on the server. (provider: TCP Provider, error: 0 - An existing connection was forcibly closed by
// the remote host.)
case 233:
// SQL Error Code: 121
// The semaphore timeout period has expired
case 121:
// SQL Error Code: 64
// A connection was successfully established with the server, but then an error occurred during the login process.
// (provider: TCP Provider, error: 0 - The specified network name is no longer available.)
case 64:
// DBNETLIB Error Code: 20
// The instance of SQL Server you attempted to connect to does not support encryption.
case 20:
return true;
// This exception can be thrown even if the operation completed successfully, so it's safer to let the application fail.
// DBNETLIB Error Code: -2
// Timeout expired. The timeout period elapsed prior to completion of the operation or the server is not responding. The statement has been terminated.
//case -2:
}

return false;
}

Metrics.SqlErrorCounter.Add(1, KeyValuePair.Create("Code", (object)ex.GetType().Name));
return ex is TimeoutException;
return false;
}

internal static unsafe decimal TruncateToNetDecimal(SqlDecimal sqlDecimal)
{
var inputData = sqlDecimal.Data;
var scale = sqlDecimal.Scale;
Metrics.SqlErrorCounter.Add(1, KeyValuePair.Create("Code", (object)ex.GetType().Name));
return ex is TimeoutException;
}

if (inputData[3] == 0) {
if (scale <= 28) {
return sqlDecimal.Value;
}
}
else if (scale == 0) {
return sqlDecimal.Value; // throws OverflowException.
private static UInt128 FromSqlDecimalData(int[] a) =>
new((uint) a[0] | ((ulong) (uint) a[1] << 32),
(uint) a[2] | ((ulong) (uint) a[3] << 32));

internal static decimal TruncateToNetDecimal(SqlDecimal sqlDecimal)
{
var inputData = sqlDecimal.Data;
int scale = sqlDecimal.Scale;

if (inputData[3] == 0) {
if (scale <= 28) {
return sqlDecimal.Value;
}
}
else if (scale == 0) {
return sqlDecimal.Value; // throws OverflowException.
}

fixed (int* inputS = inputData) {
var input = (uint*) inputS;
byte maxZeroCount = 0;
while (maxZeroCount < scale && (input[maxZeroCount >> 6] & (1 << maxZeroCount)) == 0) {
maxZeroCount++;
}
var maxZeroCount = Math.Min(scale, BitOperations.TrailingZeroCount(inputData[0]));
var realScale = scale;
var data = FromSqlDecimalData(inputData);

var realScale = scale;
var outputData = sqlDecimal.Data;
fixed (int* outputS = outputData) {
var output = (uint*) outputS;
var dividerPow = maxZeroCount > 9 ? (byte) 9 : maxZeroCount;
if (dividerPow > 5) {
var divider = PowersOf10[dividerPow];
for (byte length = 4; realScale >= dividerPow; realScale -= dividerPow) {
if (DivHasRem(input, ref length, divider)) {
break;
}

output[0] = input[0];
output[1] = input[1];
output[2] = input[2];
output[3] = input[3];
}
}

for (byte length = 4; realScale > 0 && output[3] != 0; realScale--) {
_ = DivHasRem(output, ref length, 10);
}

if (output[3] != 0) {
return sqlDecimal.Value; // throws OverflowException.
}

return new decimal(outputS[0], outputS[1], outputS[2], !sqlDecimal.IsPositive, realScale);
if (Math.Min(maxZeroCount, 9) is > 5 and var dividerPow) {
var divider = PowersOf10[dividerPow];
for (; realScale >= dividerPow; realScale -= dividerPow) {
(data, var rem) = UInt128.DivRem(data, divider);
if (rem != 0) {
break;
}
}
}

private static unsafe bool DivHasRem(uint* bits, ref byte length, uint divider)
{
unchecked {
ulong rem = 0;
var tempBits = bits + length;
for (byte i = 0; i < length; i++) {
var bit = *(--tempBits);
if (bit == 0 && i == 0) {
length--;
i--;
continue;
}

var num = (rem << 32) + bit;
bit = (uint) (num / divider);
rem = (uint) (num - (ulong) bit * divider);
*tempBits = bit;
}
for (; realScale > 0 && data > Max96bitValue; realScale--) {
(data, _) = UInt128.DivRem(data, Ten);
}

return rem > 0;
}
if (data > Max96bitValue) {
return sqlDecimal.Value; // throws OverflowException.
}

return new((int) data, (int) (data >> 32), (int) (data >> 64), !sqlDecimal.IsPositive, (byte) realScale);
}
}
}
Loading