summaryrefslogtreecommitdiff
path: root/src/main/java/com/amazon/carbonado/repo/jdbc
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/amazon/carbonado/repo/jdbc')
-rw-r--r--src/main/java/com/amazon/carbonado/repo/jdbc/LoggingCallableStatement.java8
-rw-r--r--src/main/java/com/amazon/carbonado/repo/jdbc/LoggingConnection.java22
-rw-r--r--src/main/java/com/amazon/carbonado/repo/jdbc/LoggingDataSource.java5
-rw-r--r--src/main/java/com/amazon/carbonado/repo/jdbc/LoggingStatement.java8
-rw-r--r--src/main/java/com/amazon/carbonado/repo/jdbc/SimpleDataSource.java5
5 files changed, 48 insertions, 0 deletions
diff --git a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingCallableStatement.java b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingCallableStatement.java
index c9d258f..dc27b97 100644
--- a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingCallableStatement.java
+++ b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingCallableStatement.java
@@ -638,6 +638,14 @@ class LoggingCallableStatement extends LoggingPreparedStatement implements Calla
cs().setNClob(parameterName, reader);
}
+ public <T> T getObject(int parameterIndex, Class<T> type) throws SQLException {
+ return cs().getObject(parameterIndex, type);
+ }
+
+ public <T> T getObject(String parameterName, Class<T> type) throws SQLException {
+ return cs().getObject(parameterName, type);
+ }
+
private CallableStatement cs() {
return (CallableStatement) mStatement;
}
diff --git a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingConnection.java b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingConnection.java
index c28b70b..ff99184 100644
--- a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingConnection.java
+++ b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingConnection.java
@@ -339,4 +339,26 @@ class LoggingConnection implements Connection {
public boolean isWrapperFor(Class<?> iface) throws SQLException {
throw new UnsupportedOperationException();
}
+
+ public void setSchema(String schema) throws SQLException {
+ mCon.setSchema(schema);
+ }
+
+ public String getSchema() throws SQLException {
+ return mCon.getSchema();
+ }
+
+ public void abort(java.util.concurrent.Executor executor) throws SQLException {
+ mCon.abort(executor);
+ }
+
+ public void setNetworkTimeout(java.util.concurrent.Executor executor, int milliseconds)
+ throws SQLException
+ {
+ mCon.setNetworkTimeout(executor, milliseconds);
+ }
+
+ public int getNetworkTimeout() throws SQLException {
+ return mCon.getNetworkTimeout();
+ }
}
diff --git a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingDataSource.java b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingDataSource.java
index 031e9b2..eb8d5c2 100644
--- a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingDataSource.java
+++ b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingDataSource.java
@@ -20,6 +20,7 @@ package com.amazon.carbonado.repo.jdbc;
import java.sql.Connection;
import java.sql.SQLException;
+import java.sql.SQLFeatureNotSupportedException;
import java.io.PrintWriter;
import javax.sql.DataSource;
@@ -115,4 +116,8 @@ public class LoggingDataSource implements DataSource {
public boolean isWrapperFor(Class<?> iface) throws SQLException {
throw new UnsupportedOperationException();
}
+
+ public java.util.logging.Logger getParentLogger() throws SQLFeatureNotSupportedException {
+ return mDataSource.getParentLogger();
+ }
}
diff --git a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingStatement.java b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingStatement.java
index 6f09e0b..cea13f6 100644
--- a/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingStatement.java
+++ b/src/main/java/com/amazon/carbonado/repo/jdbc/LoggingStatement.java
@@ -232,4 +232,12 @@ class LoggingStatement implements Statement {
public boolean isWrapperFor(Class<?> iface) throws SQLException {
throw new UnsupportedOperationException();
}
+
+ public void closeOnCompletion() throws SQLException {
+ mStatement.closeOnCompletion();
+ }
+
+ public boolean isCloseOnCompletion() throws SQLException {
+ return mStatement.isCloseOnCompletion();
+ }
}
diff --git a/src/main/java/com/amazon/carbonado/repo/jdbc/SimpleDataSource.java b/src/main/java/com/amazon/carbonado/repo/jdbc/SimpleDataSource.java
index 0352003..9d232c3 100644
--- a/src/main/java/com/amazon/carbonado/repo/jdbc/SimpleDataSource.java
+++ b/src/main/java/com/amazon/carbonado/repo/jdbc/SimpleDataSource.java
@@ -21,6 +21,7 @@ package com.amazon.carbonado.repo.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
+import java.sql.SQLFeatureNotSupportedException;
import java.io.PrintWriter;
import java.util.Properties;
@@ -151,4 +152,8 @@ public class SimpleDataSource implements DataSource {
public boolean isWrapperFor(Class<?> iface) throws SQLException {
throw new UnsupportedOperationException();
}
+
+ public java.util.logging.Logger getParentLogger() throws SQLFeatureNotSupportedException {
+ throw new SQLFeatureNotSupportedException();
+ }
}