From b8731ceaf4de7918166d6f84af59c0e4ca10df54 Mon Sep 17 00:00:00 2001
From: psainics <pushpender.saini@cloudsufi.com>
Date: Wed, 29 Jan 2025 11:50:20 +0530
Subject: [PATCH] Update Error message to include sql error codes

---
 .../java/io/cdap/plugin/common/db/DBErrorDetailsProvider.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/hydrator-common/src/main/java/io/cdap/plugin/common/db/DBErrorDetailsProvider.java b/hydrator-common/src/main/java/io/cdap/plugin/common/db/DBErrorDetailsProvider.java
index 4e5ad7240..c160f657e 100644
--- a/hydrator-common/src/main/java/io/cdap/plugin/common/db/DBErrorDetailsProvider.java
+++ b/hydrator-common/src/main/java/io/cdap/plugin/common/db/DBErrorDetailsProvider.java
@@ -180,7 +180,9 @@ public ProgramFailureException getExceptionDetails(Exception e, ErrorContext err
   }
 
   private ProgramFailureException getProgramFailureException(SQLException e, ErrorContext errorContext) {
-    String errorMessage = e.getMessage();
+    String errorMessage =
+      String.format("SQL Exception occurred: [Message='%s', SQLState='%s', ErrorCode='%s'].", e.getMessage(),
+        e.getSQLState(), e.getErrorCode());
     String sqlState = e.getSQLState();
     int errorCode = e.getErrorCode();
     String errorMessageWithDetails =