diff --git a/src/ReC.Application/Common/Behaviors/Action/BodyQueryBehavior.cs b/src/ReC.Application/Common/Behaviors/Action/BodyQueryBehavior.cs
index f739ff0..7d48b0b 100644
--- a/src/ReC.Application/Common/Behaviors/Action/BodyQueryBehavior.cs
+++ b/src/ReC.Application/Common/Behaviors/Action/BodyQueryBehavior.cs
@@ -31,7 +31,16 @@ public class BodyQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext) : I
         await dbContext.Database.OpenConnectionAsync(cancel);
         try
         {
-            var scalar = await command.ExecuteScalarAsync(cancel);
+            object? scalar;
+            try
+            {
+                scalar = await command.ExecuteScalarAsync(cancel);
+            }
+            catch (Exception ex)
+            {
+                throw new DataIntegrityException(
+                    $"Body query execution failed. The stored SQL may be malformed. ActionId: {action.Id}, ProfileId: {action.ProfileId}, Error: {ex.Message}");
+            }
 
             action.Body = scalar as string
                 ?? throw new DataIntegrityException(
diff --git a/src/ReC.Application/Common/Behaviors/Action/HeaderQueryBehavior.cs b/src/ReC.Application/Common/Behaviors/Action/HeaderQueryBehavior.cs
index 1ff5d57..2c05774 100644
--- a/src/ReC.Application/Common/Behaviors/Action/HeaderQueryBehavior.cs
+++ b/src/ReC.Application/Common/Behaviors/Action/HeaderQueryBehavior.cs
@@ -32,7 +32,16 @@ public class HeaderQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext) :
         await dbContext.Database.OpenConnectionAsync(cancel);
         try
         {
-            var scalar = await command.ExecuteScalarAsync(cancel);
+            object? scalar;
+            try
+            {
+                scalar = await command.ExecuteScalarAsync(cancel);
+            }
+            catch (Exception ex)
+            {
+                throw new DataIntegrityException(
+                    $"Header query execution failed. The stored SQL may be malformed. ActionId: {action.Id}, ProfileId: {action.ProfileId}, Error: {ex.Message}");
+            }
 
             if (scalar is not string rawHeader)
                 throw new DataIntegrityException(