Skip to content

Commit 385cb64

Browse files
authored
Update interface extensions to extend JDBC interfaces (#561)
1 parent a1eda78 commit 385cb64

File tree

6 files changed

+8
-8
lines changed

6 files changed

+8
-8
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import java.sql.Statement;
77

88
/** Interface providing Databricks specific Connection APIs. */
9-
public interface IDatabricksConnection {
9+
public interface IDatabricksConnection extends Connection {
1010

1111
/** Returns the underlying session for the connection. */
1212
IDatabricksSession getSession();

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,11 @@
11
package com.databricks.jdbc.api;
22

33
import com.databricks.sdk.service.sql.StatementStatus;
4+
import java.sql.ResultSet;
45
import java.sql.SQLException;
56

67
/** Extension to java.sql.ResultSet interface */
7-
public interface IDatabricksResultSet {
8+
public interface IDatabricksResultSet extends ResultSet {
89

910
/**
1011
* Returns statement-Id of associated statement

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,10 @@
22

33
import java.sql.ResultSet;
44
import java.sql.SQLException;
5+
import java.sql.Statement;
56

67
/** Interface for Databricks specific statement. */
7-
public interface IDatabricksStatement {
8+
public interface IDatabricksStatement extends Statement {
89

910
/**
1011
* Executes the given SQL command in async mode, and returns a lightweight instance of result set

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
import java.util.stream.Collectors;
2929

3030
/** Implementation for Databricks specific connection. */
31-
public class DatabricksConnection implements IDatabricksConnection, Connection {
31+
public class DatabricksConnection implements IDatabricksConnection {
3232
private static final JdbcLogger LOGGER = JdbcLoggerFactory.getLogger(DatabricksConnection.class);
3333
private final IDatabricksSession session;
3434
private final Set<IDatabricksStatementInternal> statementSet = ConcurrentHashMap.newKeySet();

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,7 @@
3838
import java.util.function.Supplier;
3939
import org.apache.http.entity.InputStreamEntity;
4040

41-
public class DatabricksResultSet
42-
implements ResultSet, IDatabricksResultSet, IDatabricksResultSetInternal {
41+
public class DatabricksResultSet implements IDatabricksResultSet, IDatabricksResultSetInternal {
4342

4443
private static final JdbcLogger LOGGER = JdbcLoggerFactory.getLogger(DatabricksResultSet.class);
4544
protected static final String AFFECTED_ROWS_COUNT = "num_affected_rows";

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,7 @@
2727
import java.util.concurrent.*;
2828
import org.apache.http.entity.InputStreamEntity;
2929

30-
public class DatabricksStatement
31-
implements IDatabricksStatement, IDatabricksStatementInternal, Statement {
30+
public class DatabricksStatement implements IDatabricksStatement, IDatabricksStatementInternal {
3231

3332
private static final JdbcLogger LOGGER = JdbcLoggerFactory.getLogger(DatabricksStatement.class);
3433
private int timeoutInSeconds;

0 commit comments

Comments
 (0)