Implement executeBatch (#532)

- Created `BatchExecutor` to manage batch SQL command execution
  - Serially execute SQL commands until success or a failure
  - Returns the update counts until last successful command
  - Throws batch exception as per JDBC specification
- Introduced `maxBatchSize` to restrict the number of commands in a batch. Throws `SQLException` when attempting to add commands beyond the specified limit
- Logs telemetry data at the debug level to facilitate performance monitoring and debugging
- Lint changes

Author: jayantsing-db

src/main/java/com/databricks/jdbc/api/IDatabricksConnection.java

@@ -27,6 +27,9 @@ public interface IDatabricksConnection {
   /** Opens the connection and initiates the underlying session */
   void open() throws DatabricksSQLException;
 
+  /** Returns the connection context associated with the connection. */
+  IDatabricksConnectionContext getConnectionContext();
+
   /** Returns the statement handle for given statement-Id */
   Statement getStatement(String statementId) throws SQLException;
 }

src/main/java/com/databricks/jdbc/api/IDatabricksConnectionContext.java

@@ -213,4 +213,7 @@ public static AuthMech parseAuthMech(String authMech) {
 
   /** Returns the SSL trust store type of the trust store file. */
   String getSSLTrustStoreType();
+
+  /** Returns the maximum number of commands that can be executed in a single batch. */
+  int getMaxBatchSize();
 }

src/main/java/com/databricks/jdbc/api/impl/DatabricksConnection.java

@@ -30,10 +30,11 @@
 /** Implementation for Databricks specific connection. */
 public class DatabricksConnection implements IDatabricksConnection, Connection {
   private static final JdbcLogger LOGGER = JdbcLoggerFactory.getLogger(DatabricksConnection.class);
-  private IDatabricksSession session;
+  private final IDatabricksSession session;
   private final Set<IDatabricksStatementInternal> statementSet = ConcurrentHashMap.newKeySet();
   private SQLWarning warnings = null;
   private volatile IDatabricksUCVolumeClient ucVolumeClient = null;
+  private final IDatabricksConnectionContext connectionContext;
 
   /**
    * Creates an instance of Databricks connection for given connection context.
@@ -42,13 +43,15 @@ public class DatabricksConnection implements IDatabricksConnection, Connection {
    */
   public DatabricksConnection(IDatabricksConnectionContext connectionContext)
       throws DatabricksSQLException {
+    this.connectionContext = connectionContext;
     this.session = new DatabricksSession(connectionContext);
   }
 
   @VisibleForTesting
   public DatabricksConnection(
       IDatabricksConnectionContext connectionContext, IDatabricksClient testDatabricksClient)
       throws DatabricksSQLException {
+    this.connectionContext = connectionContext;
     this.session = new DatabricksSession(connectionContext, testDatabricksClient);
     UserAgentManager.setUserAgent(connectionContext);
   }
@@ -526,6 +529,11 @@ public IDatabricksUCVolumeClient getUCVolumeClient() {
     return ucVolumeClient;
   }
 
+  @Override
+  public IDatabricksConnectionContext getConnectionContext() {
+    return connectionContext;
+  }
+
   /**
    * This function creates the exception message for the failed setClientInfo command
    *

src/main/java/com/databricks/jdbc/api/impl/DatabricksConnectionContext.java

@@ -581,6 +581,11 @@ public String getSSLTrustStoreType() {
     return getParameter(DatabricksJdbcUrlParams.SSL_TRUST_STORE_TYPE);
   }
 
+  @Override
+  public int getMaxBatchSize() {
+    return Integer.parseInt(getParameter(DatabricksJdbcUrlParams.MAX_BATCH_SIZE));
+  }
+
   private static boolean nullOrEmptyString(String s) {
     return s == null || s.isEmpty();
   }

src/main/java/com/databricks/jdbc/api/impl/DatabricksPreparedStatement.java

@@ -9,6 +9,7 @@
 import com.databricks.jdbc.common.util.DatabricksTypeUtil;
 import com.databricks.jdbc.exception.DatabricksSQLException;
 import com.databricks.jdbc.exception.DatabricksSQLFeatureNotImplementedException;
+import com.databricks.jdbc.exception.DatabricksSQLFeatureNotSupportedException;
 import com.databricks.jdbc.log.JdbcLogger;
 import com.databricks.jdbc.log.JdbcLoggerFactory;
 import java.io.ByteArrayOutputStream;
@@ -38,9 +39,8 @@ public DatabricksPreparedStatement(DatabricksConnection connection, String sql)
     super(connection);
     this.sql = sql;
     this.interpolateParameters =
-        connection.getSession().getConnectionContext().supportManyParameters()
-            || connection.getSession().getConnectionContext().getComputeResource()
-                instanceof AllPurposeCluster;
+        connection.getConnectionContext().supportManyParameters()
+            || connection.getConnectionContext().getComputeResource() instanceof AllPurposeCluster;
     this.databricksParameterMetaData = new DatabricksParameterMetaData();
     this.databricksBatchParameterMetaData = new ArrayList<>();
   }
@@ -552,6 +552,15 @@ public boolean execute(String sql, String[] columnNames) throws SQLException {
     throw new DatabricksSQLException("Method not supported in PreparedStatement");
   }
 
+  /** {@inheritDoc} */
+  @Override
+  public void addBatch(String sql) throws SQLException {
+    LOGGER.debug(String.format("public void addBatch(String sql = {%s})", sql));
+    checkIfClosed();
+    throw new DatabricksSQLFeatureNotSupportedException(
+        "Method not supported: addBatch(String sql)");
+  }
+
   private void checkLength(long targetLength, long sourceLength) throws SQLException {
     if (targetLength != sourceLength) {
       String errorMessage =