wie wärs damit? ;)
http://archives.postgresql.org/pgsql-jdbc/2001-03/msg00110.php
Nett, gibt zwar das originale statement und die Paramter aus ersetzt die ? aber nicht, und es kompiliert nicht weil vieles fehlt. Das könnte hinhauen:
import java.io.InputStream;
import java.io.Reader;
import java.math.BigDecimal;
import java.net.URL;
import java.sql.Array;
import java.sql.Blob;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.Date;
import java.sql.ParameterMetaData;
import java.sql.PreparedStatement;
import java.sql.Ref;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.SQLWarning;
import java.sql.Time;
import java.sql.Timestamp;
import java.util.Calendar;
/**
* a wrapper class for prepared statments to allow them to be logged original
* code from <a
* href="http://archives.postgresql.org/pgsql-jdbc/2001-03/msg00110.php>http://archives.postgresql.org/pgsql-jdbc/2001-03/msg00110.php
* </a>
*/
public class PreparedStatementLogable implements PreparedStatement {
PreparedStatement stmt;
String sql;
String[] params;
public PreparedStatementLogable(Connection con, String sql)
throws SQLException {
this.stmt = con.prepareStatement(sql);
this.sql = sql;
params = new String[countOccurances(sql, "?")];
}
private static int countOccurances(String string, String subString) {
int currentIndex = string.indexOf(subString);
int occurances = 0;
while (currentIndex > 0) {
currentIndex = string.indexOf(subString);
occurances += 1;
}
return occurances;
}
public String toString() {
StringBuilder buff = new StringBuilder(sql);
int currentIndex = 0;
for (String nextParam : params) {
currentIndex = buff.indexOf("?", currentIndex);
buff.replace(currentIndex, currentIndex + 1, nextParam);
}
return buff.toString();
}
/** ***************************************************************************** */
/***************************************************************************
* implement PreparedStatement /
**************************************************************************/
public ResultSet executeQuery() throws SQLException {
return stmt.executeQuery();
}
public int executeUpdate() throws SQLException {
return stmt.executeUpdate();
}
public void setNull(int parameterIndex, int sqlType) throws SQLException {
params[parameterIndex - 1] = null;
stmt.setNull(parameterIndex, sqlType);
}
public void setBoolean(int parameterIndex, boolean x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setBoolean(parameterIndex, x);
}
public void setByte(int parameterIndex, byte x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setByte(parameterIndex, x);
}
public void setShort(int parameterIndex, short x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setShort(parameterIndex, x);
}
public void setInt(int parameterIndex, int x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setInt(parameterIndex, x);
}
public void setLong(int parameterIndex, long x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setLong(parameterIndex, x);
}
public void setFloat(int parameterIndex, float x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setFloat(parameterIndex, x);
}
public void setDouble(int parameterIndex, double x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setDouble(parameterIndex, x);
}
public void setBigDecimal(int parameterIndex, BigDecimal x)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setBigDecimal(parameterIndex, x);
}
public void setString(int parameterIndex, String x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setString(parameterIndex, x);
}
public void setBytes(int parameterIndex, byte[] x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setBytes(parameterIndex, x);
}
public void setDate(int parameterIndex, java.sql.Date x)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setDate(parameterIndex, x);
}
public void setTime(int parameterIndex, Time x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setTime(parameterIndex, x);
}
public void setTimestamp(int parameterIndex, Timestamp x)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setTimestamp(parameterIndex, x);
}
public void setAsciiStream(int parameterIndex, InputStream x, int length)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setAsciiStream(parameterIndex, x, length);
}
@Deprecated public void setUnicodeStream(int parameterIndex, InputStream x,
int length) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setUnicodeStream(parameterIndex, x, length);
}
public void setBinaryStream(int parameterIndex, InputStream x, int length)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setBinaryStream(parameterIndex, x, length);
}
public void clearParameters() throws SQLException {
params = new String[params.length];
stmt.clearParameters();
}
public void setObject(int parameterIndex, Object x, int targetSqlType,
int scale) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setObject(parameterIndex, x, targetSqlType, scale);
}
public void setObject(int parameterIndex, Object x, int targetSqlType)
throws SQLException {
params[parameterIndex - 1] = "" + x;
stmt.setObject(parameterIndex, x, targetSqlType);
}
public void setObject(int parameterIndex, Object x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setObject(parameterIndex, x);
}
public boolean execute() throws SQLException {
return stmt.execute();
}
public void addBatch() throws SQLException {
stmt.addBatch();
}
public void setCharacterStream(int parameterIndex, Reader reader, int length)
throws SQLException {
params[parameterIndex - 1] = reader.toString();
stmt.setCharacterStream(parameterIndex, reader, length);
}
public void setRef(int i, Ref x) throws SQLException {
params[i - 1] = String.valueOf(x);
stmt.setRef(i, x);
}
public void setBlob(int i, Blob x) throws SQLException {
params[i - 1] = String.valueOf(x);
stmt.setBlob(i, x);
}
public void setClob(int i, Clob x) throws SQLException {
params[i - 1] = String.valueOf(x);
stmt.setClob(i, x);
}
public void setArray(int i, Array x) throws SQLException {
params[i - 1] = String.valueOf(x);
stmt.setArray(i, x);
}
public ResultSetMetaData getMetaData() throws SQLException {
return stmt.getMetaData();
}
public void setDate(int parameterIndex, Date x, Calendar cal)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setDate(parameterIndex, x, cal);
}
public void setTime(int parameterIndex, Time x, Calendar cal)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setTime(parameterIndex, x, cal);
}
public void setTimestamp(int parameterIndex, Timestamp x, Calendar cal)
throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setTimestamp(parameterIndex, x, cal);
}
public void setURL(int parameterIndex, URL x) throws SQLException {
params[parameterIndex - 1] = String.valueOf(x);
stmt.setURL(parameterIndex, x);
}
public void setNull(int paramIndex, int sqlType, String typeName)
throws SQLException {
params[paramIndex - 1] = null;
stmt.setNull(paramIndex, sqlType, typeName);
}
public ResultSet executeQuery(String sql) throws SQLException {
return stmt.executeQuery(sql);
}
public int executeUpdate(String sql) throws SQLException {
return stmt.executeUpdate(sql);
}
public void close() throws SQLException {
stmt.close();
}
public int getMaxFieldSize() throws SQLException {
return stmt.getMaxFieldSize();
}
public void setMaxFieldSize(int max) throws SQLException {
stmt.setMaxFieldSize(max);
}
public int getMaxRows() throws SQLException {
return stmt.getMaxRows();
}
public void setMaxRows(int max) throws SQLException {
stmt.setMaxRows(max);
}
public void setEscapeProcessing(boolean enable) throws SQLException {
stmt.setEscapeProcessing(enable);
}
public int getQueryTimeout() throws SQLException {
return stmt.getQueryTimeout();
}
public void setQueryTimeout(int seconds) throws SQLException {
stmt.setQueryTimeout(seconds);
}
public void cancel() throws SQLException {
stmt.cancel();
}
public SQLWarning getWarnings() throws SQLException {
return stmt.getWarnings();
}
public void clearWarnings() throws SQLException {
stmt.clearWarnings();
}
public void setCursorName(String name) throws SQLException {
stmt.setCursorName(name);
}
public boolean execute(String sql) throws SQLException {
return stmt.execute(sql);
}
public ResultSet getResultSet() throws SQLException {
return stmt.getResultSet();
}
public int getUpdateCount() throws SQLException {
return stmt.getUpdateCount();
}
public boolean getMoreResults() throws SQLException {
return stmt.getMoreResults();
}
public void setFetchDirection(int direction) throws SQLException {
stmt.setFetchDirection(direction);
}
public int getFetchDirection() throws SQLException {
return stmt.getFetchDirection();
}
public void setFetchSize(int rows) throws SQLException {
stmt.setFetchSize(rows);
}
public int getFetchSize() throws SQLException {
return stmt.getFetchSize();
}
public int getResultSetConcurrency() throws SQLException {
return stmt.getResultSetConcurrency();
}
public int getResultSetType() throws SQLException {
return stmt.getResultSetType();
}
public void addBatch(String sql) throws SQLException {
stmt.addBatch(sql);
}
public void clearBatch() throws SQLException {
stmt.clearBatch();
}
public int[] executeBatch() throws SQLException {
return stmt.executeBatch();
}
public Connection getConnection() throws SQLException {
return stmt.getConnection();
}
public ParameterMetaData getParameterMetaData() throws SQLException {
return stmt.getParameterMetaData();
}
public boolean execute(String sql, int autoGeneratedKeys)
throws SQLException {
return stmt.execute(sql, autoGeneratedKeys);
}
public boolean execute(String sql, int[] columnIndexes) throws SQLException {
return stmt.execute(sql, columnIndexes);
}
public boolean execute(String sql, String[] columnNames)
throws SQLException {
return stmt.execute(sql, columnNames);
}
public int executeUpdate(String sql, int autoGeneratedKeys)
throws SQLException {
return stmt.executeUpdate(sql, autoGeneratedKeys);
}
public int executeUpdate(String sql, int[] columnIndexes)
throws SQLException {
return stmt.executeUpdate(sql, columnIndexes);
}
public int executeUpdate(String sql, String[] columnNames)
throws SQLException {
return stmt.executeUpdate(sql, columnNames);
}
public ResultSet getGeneratedKeys() throws SQLException {
return stmt.getGeneratedKeys();
}
public boolean getMoreResults(int current) throws SQLException {
return stmt.getMoreResults(current);
}
public int getResultSetHoldability() throws SQLException {
return stmt.getResultSetHoldability();
}
}
Ist natürlich nicht getested. ;)
Edit:
StringUtil.countOccurances ist auch gefixt