/*
Derby - Class org.apache.derby.client.am.LogWriter
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package org.apache.derby.client.am;
import java.io.File;
import java.io.PrintWriter;
import java.sql.SQLException;
import java.util.Iterator;
import java.util.Map;
import java.util.Properties;
import javax.transaction.xa.XAException;
import org.apache.derby.jdbc.BasicClientDataSource40;
import org.apache.derby.shared.common.reference.Attribute;
import org.apache.derby.shared.common.reference.SQLState;
import org.apache.derby.shared.common.sanity.SanityManager;
public class LogWriter {
final protected PrintWriter printWriter_;
final private int traceLevel_;
private boolean driverConfigurationHasBeenWrittenToJdbc1Stream_ = false;
private boolean driverConfigurationHasBeenWrittenToJdbc2Stream_ = false;
// It is assumed that this constructor is never called when logWriter is null.
public LogWriter(PrintWriter printWriter, int traceLevel) {
printWriter_ = printWriter;
traceLevel_ = traceLevel;
}
final protected boolean loggingEnabled(int traceLevel) {
if (SanityManager.DEBUG) {
if (printWriter_ == null) {
SanityManager.THROWASSERT(
"Broken invariant: printWriter_ == null");
}
}
return (traceLevel & traceLevel_) != 0;
}
// When garbage collector doesn't kick in in time
// to close file descriptors, "Too many open files"
// exception may occur (currently found on Linux).
// To minimize the chance of this problem happening,
// the print writer needs to be closed (after this
// DNC log writer is closed) when each connection has
// its own trace file (i.e. traceDirectory is specified).
public boolean printWriterNeedsToBeClosed_;
void close() {
if (printWriterNeedsToBeClosed_) {
printWriter_.close();
printWriterNeedsToBeClosed_ = false;
}
// printWriter_ = null; // help GC.
}
// ---------------------------------------------------------------------------
private void dncprintln(String s) {
synchronized (printWriter_) {
printWriter_.println("[derby] " + s);
printWriter_.flush();
}
}
private void dncprint(String s) {
synchronized (printWriter_) {
printWriter_.print("[derby] " + s);
printWriter_.flush();
}
}
private void dncprintln(String header, String s) {
synchronized (printWriter_) {
printWriter_.println("[derby]" + header + " " + s);
printWriter_.flush();
}
}
private void dncprint(String header, String s) {
synchronized (printWriter_) {
printWriter_.print("[derby]" + header + " " + s);
printWriter_.flush();
}
}
// ------------------------ tracepoint api -----------------------------------
public void tracepoint(String component, int tracepoint,
String classContext, String methodContext) {
String staticContextTracepointRecord =
component +
"[time:" + System.currentTimeMillis() + "]" +
"[thread:" + Thread.currentThread().getName() + "]" +
"[tracepoint:" + tracepoint + "]" +
"[" + classContext + "." + methodContext + "]";
dncprintln(staticContextTracepointRecord);
}
// ------------- API entry and exit trace methods ----------------------------
// Entry and exit are be traced separately because input arguments need
// to be traced before any potential exception can occur.
// Exit tracing is only performed on methods that return values.
// Entry tracing is only performed on methods that update state,
// so entry tracing is not performed on simple getter methods.
// We could decide in the future to restrict entry tracing only to methods with input arguments.
private void traceExternalMethod(Object instance, String className, String methodName) {
dncprint(buildExternalMethodHeader(instance, className), methodName);
}
private void traceExternalDeprecatedMethod(Object instance, String className, String methodName) {
dncprint(buildExternalMethodHeader(instance, className), "Deprecated " + methodName);
}
private String buildExternalMethodHeader(Object instance, String className) {
return
"[Time:" + System.currentTimeMillis() + "]" +
"[Thread:" + Thread.currentThread().getName() + "]" +
"[" + className + "@" + Integer.toHexString(instance.hashCode()) + "]";
}
private String getClassNameOfInstanceIfTraced(Object instance) {
if (instance == null) // this prevents NPE from instance.getClass() used below
{
return null;
} else if (instance instanceof ClientConnection && loggingEnabled(
BasicClientDataSource40.TRACE_CONNECTION_CALLS)) {
return "ClientConnection";
} else if (instance instanceof ClientResultSet && loggingEnabled(
BasicClientDataSource40.TRACE_RESULT_SET_CALLS)) {
return "ClientResultSet";
} else if (instance instanceof ClientCallableStatement &&
loggingEnabled(
BasicClientDataSource40.TRACE_STATEMENT_CALLS)) {
return "ClientCallableStatement";
} else if (instance instanceof ClientPreparedStatement &&
loggingEnabled(
BasicClientDataSource40.TRACE_STATEMENT_CALLS)) {
return "ClientPreparedStatement";
} else if (instance instanceof ClientStatement && loggingEnabled(
BasicClientDataSource40.TRACE_STATEMENT_CALLS)) {
return "ClientStatement";
}
// Not yet externalizing Blob tracing, except for trace_all
else if (instance instanceof ClientBlob && loggingEnabled(
BasicClientDataSource40.TRACE_ALL)) // add a trace level for
// lobs !!
{
return "ClientBlob";
}
// Not yet externalizing ClientClob tracing, except for trace_all
else if (instance instanceof ClientClob && loggingEnabled(
BasicClientDataSource40.TRACE_ALL)) // add a trace level for
// bobs !!
{
return "ClientClob";
}
// Not yet externalizing dbmd catalog call tracing, except for trace_all
else if (instance instanceof ClientDatabaseMetaData && loggingEnabled(
BasicClientDataSource40.TRACE_ALL)) // add a trace level for
// dbmd ??
{
return "ClientDatabaseMetaData";
}
// we don't use instanceof javax.transaction.XAResource to avoid dependency on j2ee.jar
else if (loggingEnabled(BasicClientDataSource40.TRACE_XA_CALLS) &&
instance.getClass().getName().startsWith("org.apache.derby.client.net.NetXAResource")) {
return "NetXAResource";
} else if (loggingEnabled(BasicClientDataSource40.TRACE_ALL) &&
instance.getClass().getName().equals("org.apache.derby.client.ClientPooledConnection")) {
return "ClientPooledConnection";
} else if (loggingEnabled(BasicClientDataSource40.TRACE_ALL) &&
instance.getClass().getName().equals("org.apache.derby.jdbc.ClientConnectionPoolDataSource")) {
return "ClientConnectionPoolDataSource";
} else if (loggingEnabled(BasicClientDataSource40.TRACE_ALL) &&
instance.getClass().getName().equals("org.apache.derby.client.ClientXAConnection")) {
return "ClientXAConnection";
} else if (loggingEnabled(BasicClientDataSource40.TRACE_ALL) &&
instance.getClass().getName().equals("org.apache.derby.jdbc.ClientDataSource")) {
return "ClientDataSource";
} else if (loggingEnabled(BasicClientDataSource40.TRACE_ALL) &&
instance.getClass().getName().equals("org.apache.derby.jdbc.ClientXADataSource")) {
return "ClientXADataSource";
} else {
return instance.getClass().getName();
}
}
// --------------------------- method exit tracing --------------------------
public void traceExit(Object instance, String methodName, Object returnValue) {
String className = getClassNameOfInstanceIfTraced(instance);
if (className == null) {
return;
}
synchronized (printWriter_) {
traceExternalMethod(instance, className, methodName);
printWriter_.println(" () returned " + returnValue);
printWriter_.flush();
}
}
void traceDeprecatedExit(Object instance,
String methodName,
Object returnValue) {
String className = getClassNameOfInstanceIfTraced(instance);
if (className == null) {
return;
}
synchronized (printWriter_) {
traceExternalDeprecatedMethod(instance, className, methodName);
printWriter_.println(" () returned " + returnValue);
printWriter_.flush();
}
}
void traceExit(
Object instance,
String methodName,
ClientResultSet resultSet) {
String returnValue = (resultSet == null) ? "ResultSet@null" : "ResultSet@" + Integer.toHexString(resultSet.hashCode());
traceExit(instance, methodName, returnValue);
}
void traceExit(
Object instance,
String methodName,
ClientStatement returnValue) {
traceExit(instance, methodName, "Statement@" + Integer.toHexString(returnValue.hashCode()));
}
void traceExit(Object instance, String methodName, ClientBlob blob) {
String returnValue = (blob == null) ? "Blob@null" : "Blob@" + Integer.toHexString(blob.hashCode());
traceExit(instance, methodName, returnValue);
}
void traceExit(Object instance, String methodName, ClientClob clob) {
String returnValue = (clob == null) ? "Clob@null" : "Clob@" + Integer.toHexString(clob.hashCode());
traceExit(instance, methodName, returnValue);
}
void traceExit(
Object instance,
String methodName,
ClientDatabaseMetaData returnValue) {
traceExit(instance, methodName, "DatabaseMetaData@" + Integer.toHexString(returnValue.hashCode()));
}
void traceExit(
Object instance,
String methodName,
ClientConnection returnValue) {
traceExit(instance, methodName, "Connection@" + Integer.toHexString(returnValue.hashCode()));
}
void traceExit(
Object instance,
String methodName,
ColumnMetaData returnValue) {
traceExit(instance, methodName, "MetaData@" + (returnValue != null ? Integer.toHexString(returnValue.hashCode()) : null));
}
void traceExit(Object instance, String methodName, byte[] returnValue) {
traceExit(instance, methodName, Utils.getStringFromBytes(returnValue));
}
void traceExit(Object instance, String methodName, byte returnValue) {
traceExit(instance, methodName, "0x" + Integer.toHexString(returnValue & 0xff));
}
// --------------------------- method entry tracing --------------------------
public void traceEntry(Object instance, String methodName, Object... args) {
traceEntryAllArgs(instance, methodName, false, args);
}
public void traceDeprecatedEntry(
Object instance, String methodName, Object... args) {
traceEntryAllArgs(instance, methodName, true, args);
}
private void traceEntryAllArgs(Object instance, String methodName,
boolean deprecated, Object[] args) {
String className = getClassNameOfInstanceIfTraced(instance);
if (className == null) {
return;
}
synchronized (printWriter_) {
if (deprecated) {
traceExternalDeprecatedMethod(instance, className, methodName);
} else {
traceExternalMethod(instance, className, methodName);
}
printWriter_.print(" (");
for (int i = 0; i < args.length; i++) {
if (i > 0) {
printWriter_.print(", ");
}
printWriter_.print(toPrintableString(args[i]));
}
printWriter_.println(") called");
printWriter_.flush();
}
}
private static String toPrintableString(Object o) {
if (o instanceof byte[]) {
return Utils.getStringFromBytes((byte[]) o);
} else if (o instanceof Byte) {
return "0x" + Integer.toHexString(((Byte) o) & 0xff);
}
return String.valueOf(o);
}
// ---------------------------tracing exceptions and warnings-----------------
void traceDiagnosable(SqlException e) {
if (!loggingEnabled(BasicClientDataSource40.TRACE_DIAGNOSTICS)) {
return;
}
synchronized (printWriter_) {
dncprintln("BEGIN TRACE_DIAGNOSTICS");
ExceptionFormatter.printTrace(e, printWriter_, "[derby]", true); // true means return tokens only
dncprintln("END TRACE_DIAGNOSTICS");
}
}
public void traceDiagnosable(SQLException e) {
if (!loggingEnabled(BasicClientDataSource40.TRACE_DIAGNOSTICS)) {
return;
}
synchronized (printWriter_) {
dncprintln("BEGIN TRACE_DIAGNOSTICS");
ExceptionFormatter.printTrace(e, printWriter_, "[derby]", true); // true means return tokens only
dncprintln("END TRACE_DIAGNOSTICS");
}
}
void traceDiagnosable(XAException e) {
if (!loggingEnabled(BasicClientDataSource40.TRACE_DIAGNOSTICS)) {
return;
}
synchronized (printWriter_) {
dncprintln("BEGIN TRACE_DIAGNOSTICS");
ExceptionFormatter.printTrace(e, printWriter_, "[derby]");
dncprintln("END TRACE_DIAGNOSTICS");
}
}
// ------------------------ meta data tracing --------------------------------
void traceParameterMetaData(
ClientStatement statement,
ColumnMetaData columnMetaData) {
if (!loggingEnabled(
BasicClientDataSource40.TRACE_PARAMETER_META_DATA) ||
columnMetaData == null) {
return;
}
synchronized (printWriter_) {
String header = "[ParameterMetaData@" + Integer.toHexString(columnMetaData.hashCode()) + "]";
try {
dncprintln(header, "BEGIN TRACE_PARAMETER_META_DATA");
dncprintln(header, "Parameter meta data for statement Statement@" + Integer.toHexString(statement.hashCode()));
dncprintln(header, "Number of parameter columns: " + columnMetaData.getColumnCount());
traceColumnMetaData(header, columnMetaData);
dncprintln(header, "END TRACE_PARAMETER_META_DATA");
} catch (SQLException e) {
dncprintln(header, "Encountered an SQL exception while trying to trace parameter meta data");
dncprintln(header, "END TRACE_PARAMETER_META_DATA");
}
}
}
void traceResultSetMetaData(
ClientStatement statement,
ColumnMetaData columnMetaData) {
if (!loggingEnabled(
BasicClientDataSource40.TRACE_RESULT_SET_META_DATA) ||
columnMetaData == null) {
return;
}
synchronized (printWriter_) {
String header = "[ResultSetMetaData@" + Integer.toHexString(columnMetaData.hashCode()) + "]";
try {
dncprintln(header, "BEGIN TRACE_RESULT_SET_META_DATA");
dncprintln(header, "Result set meta data for statement Statement@" + Integer.toHexString(statement.hashCode()));
dncprintln(header, "Number of result set columns: " + columnMetaData.getColumnCount());
traceColumnMetaData(header, columnMetaData);
dncprintln(header, "END TRACE_RESULT_SET_META_DATA");
} catch (SQLException e) {
dncprintln(header, "Encountered an SQL exception while trying to trace result set meta data");
dncprintln(header, "END TRACE_RESULT_SET_META_DATA");
}
}
}
//-----------------------------transient state--------------------------------
private void traceColumnMetaData(String header, ColumnMetaData columnMetaData) {
try {
synchronized (printWriter_) {
for (int column = 1; column <= columnMetaData.getColumnCount(); column++) {
dncprint(header, "Column " + column + ": { ");
printWriter_.print("label=" + columnMetaData.getColumnLabel(column) + ", ");
printWriter_.print("name=" + columnMetaData.getColumnName(column) + ", ");
printWriter_.print("type name=" + columnMetaData.getColumnTypeName(column) + ", ");
printWriter_.print("type=" + columnMetaData.getColumnType(column) + ", ");
printWriter_.print("nullable=" + columnMetaData.isNullable(column) + ", ");
printWriter_.print("precision=" + columnMetaData.getPrecision(column) + ", ");
printWriter_.print("scale=" + columnMetaData.getScale(column) + ", ");
printWriter_.print("schema name=" + columnMetaData.getSchemaName(column) + ", ");
printWriter_.print("table name=" + columnMetaData.getTableName(column) + ", ");
printWriter_.print("writable=" + columnMetaData.isWritable(column) + ", ");
printWriter_.print("sqlPrecision=" + (columnMetaData.sqlPrecision_ == null ? "" : "" + columnMetaData.sqlPrecision_[column - 1]) + ", ");
printWriter_.print("sqlScale=" + (columnMetaData.sqlScale_ == null ? "" : "" + columnMetaData.sqlScale_[column - 1]) + ", ");
printWriter_.print("sqlLength=" + (columnMetaData.sqlLength_ == null ? "" : "" + columnMetaData.sqlLength_[column - 1]) + ", ");
printWriter_.print("sqlType=" + (columnMetaData.sqlType_ == null ? "" : "" + columnMetaData.sqlType_[column - 1]) + ", ");
printWriter_.print("sqlCcsid=" + (columnMetaData.sqlCcsid_ == null ? "" : "" + columnMetaData.sqlCcsid_[column - 1]) + ", ");
printWriter_.print("sqlName=" + (columnMetaData.sqlName_ == null ? "" : columnMetaData.sqlName_[column - 1]) + ", ");
printWriter_.print("sqlLabel=" + (columnMetaData.sqlLabel_ == null ? "" : columnMetaData.sqlLabel_[column - 1]) + ", ");
printWriter_.print("sqlUnnamed=" + (columnMetaData.sqlUnnamed_ == null ? "" : "" + columnMetaData.sqlUnnamed_[column - 1]) + ", ");
printWriter_.print("sqlComment=" + (columnMetaData.sqlComment_ == null ? "" : columnMetaData.sqlComment_[column - 1]) + ", ");
printWriter_.print("sqlxKeymem=" + (columnMetaData.sqlxKeymem_ == null ? "" : "" + columnMetaData.sqlxKeymem_[column - 1]) + ", ");
printWriter_.print("sqlxGenerated=" + (columnMetaData.sqlxGenerated_ == null ? "" : "" + columnMetaData.sqlxGenerated_[column - 1]) + ", ");
printWriter_.print("sqlxParmmode=" + (columnMetaData.sqlxParmmode_ == null ? "" : "" + columnMetaData.sqlxParmmode_[column - 1]) + ", ");
printWriter_.print("sqlxCorname=" + (columnMetaData.sqlxCorname_ == null ? "" : columnMetaData.sqlxCorname_[column - 1]) + ", ");
printWriter_.print("sqlxName=" + (columnMetaData.sqlxName_ == null ? "" : columnMetaData.sqlxName_[column - 1]) + ", ");
printWriter_.print("sqlxBasename=" + (columnMetaData.sqlxBasename_ == null ? "" : columnMetaData.sqlxBasename_[column - 1]) + ", ");
printWriter_.print("sqlxUpdatable=" + (columnMetaData.sqlxUpdatable_ == null ? "" : "" + columnMetaData.sqlxUpdatable_[column - 1]) + ", ");
printWriter_.print("sqlxSchema=" + (columnMetaData.sqlxSchema_ == null ? "" : columnMetaData.sqlxSchema_[column - 1]) + ", ");
printWriter_.print("sqlxRdbnam=" + (columnMetaData.sqlxRdbnam_ == null ? "" : columnMetaData.sqlxRdbnam_[column - 1]) + ", ");
printWriter_.print("internal type=" + columnMetaData.types_[column - 1] + ", ");
printWriter_.println(" }");
}
dncprint(header, "{ ");
printWriter_.print("sqldHold=" + columnMetaData.sqldHold_ + ", ");
printWriter_.print("sqldReturn=" + columnMetaData.sqldReturn_ + ", ");
printWriter_.print("sqldScroll=" + columnMetaData.sqldScroll_ + ", ");
printWriter_.print("sqldSensitive=" + columnMetaData.sqldSensitive_ + ", ");
printWriter_.print("sqldFcode=" + columnMetaData.sqldFcode_ + ", ");
printWriter_.print("sqldKeytype=" + columnMetaData.sqldKeytype_ + ", ");
printWriter_.print("sqldRdbnam=" + columnMetaData.sqldRdbnam_ + ", ");
printWriter_.print("sqldSchema=" + columnMetaData.sqldSchema_);
printWriter_.println(" }");
printWriter_.flush();
}
} catch (SQLException e) {
dncprintln(header, "Encountered an SQL exception while trying to trace column meta data");
}
}
// ---------------------- 3-way tracing connects -----------------------------
// Including protocol manager levels, and driver configuration
// Jdbc 2
void traceConnectEntry(BasicClientDataSource40 dataSource) {
if (loggingEnabled(
BasicClientDataSource40.TRACE_DRIVER_CONFIGURATION)) {
traceDriverConfigurationJdbc2();
}
if (loggingEnabled(BasicClientDataSource40.TRACE_CONNECTS)) {
traceConnectsEntry(dataSource);
}
}
// Jdbc 1
void traceConnectEntry(String server,
int port,
String database,
Properties properties) {
if (loggingEnabled(
BasicClientDataSource40.TRACE_DRIVER_CONFIGURATION)) {
traceDriverConfigurationJdbc1();
}
if (loggingEnabled(BasicClientDataSource40.TRACE_CONNECTS)) {
traceConnectsEntry(server, port, database, properties);
}
}
void traceConnectResetEntry(
Object instance, LogWriter logWriter,
String user, BasicClientDataSource40 ds) {
traceEntry(instance, "reset", logWriter, user, "", ds);
if (loggingEnabled(BasicClientDataSource40.TRACE_CONNECTS)) {
traceConnectsResetEntry(ds);
}
}
void traceConnectExit(ClientConnection connection) {
if (loggingEnabled(BasicClientDataSource40.TRACE_CONNECTS)) {
traceConnectsExit(connection);
}
}
public void traceConnectResetExit(ClientConnection connection) {
if (loggingEnabled(BasicClientDataSource40.TRACE_CONNECTS)) {
traceConnectsResetExit(connection);
}
}
// ---------------------- tracing connects -----------------------------------
private void traceConnectsResetEntry(BasicClientDataSource40 dataSource) {
try {
traceConnectsResetEntry(dataSource.getServerName(),
dataSource.getPortNumber(),
dataSource.getDatabaseName(),
getProperties(dataSource));
} catch ( SqlException se ) {
dncprintln("Encountered an SQL exception while trying to trace connection reset entry");
}
}
private void traceConnectsEntry(BasicClientDataSource40 dataSource) {
try {
traceConnectsEntry(dataSource.getServerName(),
dataSource.getPortNumber(),
dataSource.getDatabaseName(),
getProperties(dataSource));
} catch ( SqlException se ) {
dncprintln("Encountered an SQL exception while trying to trace connection entry");
}
}
private void traceConnectsResetEntry(String server,
int port,
String database,
Properties properties) {
dncprintln("BEGIN TRACE_CONNECT_RESET");
dncprintln("Connection reset requested for " + server + ":" + port + "/" + database);
dncprint("Using properties: ");
writeProperties(properties);
dncprintln("END TRACE_CONNECT_RESET");
}
private void traceConnectsEntry(String server,
int port,
String database,
Properties properties) {
synchronized (printWriter_) {
dncprintln("BEGIN TRACE_CONNECTS");
dncprintln("Attempting connection to " + server + ":" + port + "/" + database);
dncprint("Using properties: ");
writeProperties(properties);
dncprintln("END TRACE_CONNECTS");
}
}
// Specialized by NetLogWriter.traceConnectsExit()
public void traceConnectsExit(ClientConnection c) {
synchronized (printWriter_) {
String header = "[Connection@" + Integer.toHexString(c.hashCode()) + "]";
try {
dncprintln(header, "BEGIN TRACE_CONNECTS");
dncprintln(header, "Successfully connected to server " + c.databaseMetaData_.getURL());
dncprintln(header, "User: " + c.databaseMetaData_.getUserName());
dncprintln(header, "Database product name: " + c.databaseMetaData_.getDatabaseProductName());
dncprintln(header, "Database product version: " + c.databaseMetaData_.getDatabaseProductVersion());
dncprintln(header, "Driver name: " + c.databaseMetaData_.getDriverName());
dncprintln(header, "Driver version: " + c.databaseMetaData_.getDriverVersion());
dncprintln(header, "END TRACE_CONNECTS");
} catch (SQLException e) {
dncprintln(header, "Encountered an SQL exception while trying to trace connection exit");
dncprintln(header, "END TRACE_CONNECTS");
}
}
}
public void traceConnectsResetExit(ClientConnection c) {
synchronized (printWriter_) {
String header = "[Connection@" + Integer.toHexString(c.hashCode()) + "]";
try {
dncprintln(header, "BEGIN TRACE_CONNECT_RESET");
dncprintln(header, "Successfully reset connection to server " + c.databaseMetaData_.getURL());
dncprintln(header, "User: " + c.databaseMetaData_.getUserName());
dncprintln(header, "Database product name: " + c.databaseMetaData_.getDatabaseProductName());
dncprintln(header, "Database product version: " + c.databaseMetaData_.getDatabaseProductVersion());
dncprintln(header, "Driver name: " + c.databaseMetaData_.getDriverName());
dncprintln(header, "Driver version: " + c.databaseMetaData_.getDriverVersion());
dncprintln(header, "END TRACE_CONNECT_RESET");
} catch (SQLException e) {
dncprintln(header, "Encountered an SQL exception while trying to trace connection reset exit");
dncprintln(header, "END TRACE_CONNECT_RESET");
}
}
}
// properties.toString() will print out passwords,
// so this method was written to escape the password property value.
// printWriter_ synchronized by caller.
private void writeProperties(Properties properties) {
printWriter_.print("{ ");
for (Iterator i = properties.entrySet().iterator(); i.hasNext();) {
Map.Entry e = (Map.Entry) (i.next());
if ("password".equals(e.getKey())) {
printWriter_.print("password=" + escapePassword((String) e.getValue()));
} else {
printWriter_.print(e.getKey() + "=" + e.getValue());
}
if (i.hasNext()) {
printWriter_.print(", ");
}
}
printWriter_.println(" }");
printWriter_.flush();
}
private String escapePassword(String pw) {
StringBuilder sb = new StringBuilder(pw);
for (int j = 0; j < pw.length(); j++) {
sb.setCharAt(j, '*');
}
return sb.toString();
}
//-------------------------tracing driver configuration-----------------------
private void traceDriverConfigurationJdbc2() {
synchronized (printWriter_) {
if (!driverConfigurationHasBeenWrittenToJdbc2Stream_) {
writeDriverConfiguration();
driverConfigurationHasBeenWrittenToJdbc2Stream_ = true;
}
}
}
private void traceDriverConfigurationJdbc1() {
synchronized (printWriter_) {
if (!driverConfigurationHasBeenWrittenToJdbc1Stream_) {
writeDriverConfiguration();
driverConfigurationHasBeenWrittenToJdbc1Stream_ = true;
}
}
}
private void writeDriverConfiguration() {
Version.writeDriverConfiguration(printWriter_);
}
/**
* Obtain a set of Properties for the client data source.
*/
private Properties getProperties(BasicClientDataSource40 cds)
throws SqlException {
Properties properties = BasicClientDataSource40.getProperties(cds);
if (properties.getProperty(Attribute.PASSWORD_ATTR) != null) {
properties.setProperty(Attribute.PASSWORD_ATTR, "********");
}
return properties;
}
}
Ads help maintain this website.