package org.jooq.impl;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.jooq.tools.jdbc.DefaultCallableStatement;
final class DiagnosticsStatement extends DefaultCallableStatement {
private final DiagnosticsConnection connection;
DiagnosticsStatement(DiagnosticsConnection connection, Statement statement) {
super(statement);
this.connection = connection;
}
@Override
public final ResultSet executeQuery(String sql) throws SQLException {
return new DiagnosticsResultSet(super.executeQuery(connection.parse(sql)), sql, this, connection);
}
@Override
public final int executeUpdate(String sql) throws SQLException {
return super.executeUpdate(connection.parse(sql));
}
@Override
public final int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException {
return super.executeUpdate(connection.parse(sql), autoGeneratedKeys);
}
@Override
public final int executeUpdate(String sql, int[] columnIndexes) throws SQLException {
return super.executeUpdate(connection.parse(sql), columnIndexes);
}
@Override
public final int executeUpdate(String sql, String[] columnNames) throws SQLException {
return super.executeUpdate(connection.parse(sql), columnNames);
}
@Override
public final boolean execute(String sql) throws SQLException {
return super.execute(connection.parse(sql));
}
@Override
public final boolean execute(String sql, int autoGeneratedKeys) throws SQLException {
return super.execute(connection.parse(sql), autoGeneratedKeys);
}
@Override
public final boolean execute(String sql, int[] columnIndexes) throws SQLException {
return super.execute(connection.parse(sql), columnIndexes);
}
@Override
public final boolean execute(String sql, String[] columnNames) throws SQLException {
return super.execute(connection.parse(sql), columnNames);
}
@Override
public final long executeLargeUpdate(String sql) throws SQLException {
return super.executeLargeUpdate(connection.parse(sql));
}
@Override
public final long executeLargeUpdate(String sql, int autoGeneratedKeys) throws SQLException {
return super.executeLargeUpdate(connection.parse(sql), autoGeneratedKeys);
}
@Override
public final long executeLargeUpdate(String sql, int[] columnIndexes) throws SQLException {
return super.executeLargeUpdate(connection.parse(sql), columnIndexes);
}
@Override
public final long executeLargeUpdate(String sql, String[] columnNames) throws SQLException {
return super.executeLargeUpdate(connection.parse(sql), columnNames);
}
@Override
public final void addBatch(String sql) throws SQLException {
super.addBatch(connection.parse(sql));
}
@Override
public final Connection getConnection() throws SQLException {
return connection;
}
}