Add SqlServerErrorDetailsProvider

Author: psainics

database-commons/src/main/java/io/cdap/plugin/util/DBUtils.java

@@ -61,6 +61,9 @@ public final class DBUtils {
 
   public static final Calendar PURE_GREGORIAN_CALENDAR = createPureGregorianCalender();
   public static final String MYSQL_SUPPORTED_DOC_URL = "https://dev.mysql.com/doc/mysql-errors/9.0/en/";
+  // mssql sel serverdoc url
+  public static final String MSSQL_SUPPORTED_DOC_URL =
+    "https://docs.microsoft.com/en-us/sql/relational-databases/errors-events/database-engine-events-and-errors";
   public static final String CLOUDSQLMYSQL_SUPPORTED_DOC_URL = "https://cloud.google.com/sql/docs/mysql/error-messages";
   public static final String POSTGRES_SUPPORTED_DOC_URL =
     "https://www.postgresql.org/docs/current/errcodes-appendix.html";

mssql-plugin/src/main/java/io/cdap/plugin/mssql/SqlServerErrorDetailsProvider.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright © 2025 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package io.cdap.plugin.mssql;
+
+import io.cdap.cdap.api.exception.ErrorType;
+import io.cdap.plugin.db.DBErrorDetailsProvider;
+import io.cdap.plugin.util.DBUtils;
+
+/**
+ * A custom ErrorDetailsProvider for SQL Server plugins.
+ */
+public class SqlServerErrorDetailsProvider extends DBErrorDetailsProvider {
+
+  @Override
+  protected String getExternalDocumentationLink() {
+    return DBUtils.MSSQL_SUPPORTED_DOC_URL;
+  }
+
+  @Override
+  protected ErrorType getErrorTypeFromErrorCode(int errorCode, String sqlState) {
+    if ((errorCode >= 50000 && errorCode <= 59999) || (errorCode >= 0 && errorCode <= 4999)) {
+      // User-defined or low-level errors
+      return ErrorType.USER;
+    } else if (errorCode >= 60000 && errorCode <= 99999) {
+      // System-level errors
+      return ErrorType.SYSTEM;
+    } else {
+      // Errors outside the defined range
+      return ErrorType.UNKNOWN;
+    }
+  }
+}

mssql-plugin/src/main/java/io/cdap/plugin/mssql/SqlServerSink.java

@@ -88,6 +88,11 @@ protected LineageRecorder getLineageRecorder(BatchSinkContext context) {
     return new LineageRecorder(context, asset);
   }
 
+  @Override
+  protected String getErrorDetailsProviderClassName() {
+    return SqlServerErrorDetailsProvider.class.getName();
+  }
+
   /**
    * MSSQL action configuration.
    */

mssql-plugin/src/main/java/io/cdap/plugin/mssql/SqlServerSource.java

@@ -75,6 +75,11 @@ protected Class<? extends DBWritable> getDBRecordType() {
     return SqlServerSourceDBRecord.class;
   }
 
+  @Override
+  protected String getErrorDetailsProviderClassName() {
+    return SqlServerErrorDetailsProvider.class.getName();
+  }
+
   @Override
   protected LineageRecorder getLineageRecorder(BatchSourceContext context) {
     String fqn = DBUtils.constructFQN("mssql",