public class org.apache.log4j.jdbc.JDBCAppender extends org.apache.log4j.AppenderSkeleton implements org.apache.log4j.Appender
{
private static final java.lang.IllegalArgumentException ILLEGAL_PATTERN_FOR_SECURE_EXEC;
protected java.lang.String databaseURL;
protected java.lang.String databaseUser;
protected java.lang.String databasePassword;
protected java.sql.Connection connection;
protected java.lang.String sqlStatement;
private org.apache.log4j.jdbc.JdbcPatternParser preparedStatementParser;
protected int bufferSize;
protected java.util.ArrayList buffer;
private boolean locationInfo;
private boolean isActive;
public void <init>()
{
int v;
org.apache.log4j.jdbc.JDBCAppender v;
java.util.ArrayList v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
specialinvoke v.<org.apache.log4j.AppenderSkeleton: void <init>()>();
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseURL> = "jdbc:odbc:myDB";
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseUser> = "me";
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databasePassword> = "mypassword";
v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection> = null;
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String sqlStatement> = "";
v.<org.apache.log4j.jdbc.JDBCAppender: int bufferSize> = 1;
v.<org.apache.log4j.jdbc.JDBCAppender: boolean locationInfo> = 0;
v.<org.apache.log4j.jdbc.JDBCAppender: boolean isActive> = 0;
v = new java.util.ArrayList;
v = v.<org.apache.log4j.jdbc.JDBCAppender: int bufferSize>;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer> = v;
return;
}
public void activateOptions()
{
org.apache.log4j.jdbc.JdbcPatternParser v;
int v;
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v, v, v, v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String getSql()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String getSql()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: int length()>();
if v != 0 goto label;
label:
staticinvoke <org.apache.log4j.helpers.LogLog: void error(java.lang.String)>("JDBCAppender.sql parameter is mandatory. Skipping all futher processing");
v.<org.apache.log4j.jdbc.JDBCAppender: boolean isActive> = 0;
return;
label:
staticinvoke <org.apache.log4j.helpers.LogLog: void debug(java.lang.String)>("JDBCAppender constructing internal pattern parser");
v = new org.apache.log4j.jdbc.JdbcPatternParser;
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String getSql()>();
specialinvoke v.<org.apache.log4j.jdbc.JdbcPatternParser: void <init>(java.lang.String)>(v);
v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.jdbc.JdbcPatternParser preparedStatementParser> = v;
v.<org.apache.log4j.jdbc.JDBCAppender: boolean isActive> = 1;
return;
}
public boolean getLocationInfo()
{
org.apache.log4j.jdbc.JDBCAppender v;
boolean v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: boolean locationInfo>;
return v;
}
public void setLocationInfo(boolean)
{
org.apache.log4j.jdbc.JDBCAppender v;
boolean v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: boolean;
v.<org.apache.log4j.jdbc.JDBCAppender: boolean locationInfo> = v;
return;
}
public void append(org.apache.log4j.spi.LoggingEvent)
{
org.apache.log4j.spi.LoggingEvent v;
java.util.ArrayList v, v;
int v, v;
org.apache.log4j.jdbc.JDBCAppender v;
boolean v, v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: org.apache.log4j.spi.LoggingEvent;
v = v.<org.apache.log4j.jdbc.JDBCAppender: boolean isActive>;
if v != 0 goto label;
return;
label:
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String getNDC()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String getThreadName()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: void getMDCCopy()>();
v = v.<org.apache.log4j.jdbc.JDBCAppender: boolean locationInfo>;
if v == 0 goto label;
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: org.apache.log4j.spi.LocationInfo getLocationInformation()>();
label:
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String getRenderedMessage()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String[] getThrowableStrRep()>();
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = v.<org.apache.log4j.jdbc.JDBCAppender: int bufferSize>;
if v < v goto label;
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void flushBuffer()>();
label:
return;
}
protected java.lang.String getLogStatement(org.apache.log4j.spi.LoggingEvent)
{
org.apache.log4j.jdbc.JDBCAppender v;
org.apache.log4j.spi.LoggingEvent v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: org.apache.log4j.spi.LoggingEvent;
return "";
}
protected void execute(java.lang.String) throws java.sql.SQLException
{
java.lang.Throwable v;
java.sql.Connection v;
java.sql.Statement v;
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.lang.String;
v = null;
v = null;
label:
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection getConnection()>();
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
interfaceinvoke v.<java.sql.Statement: int executeUpdate(java.lang.String)>(v);
label:
interfaceinvoke v.<java.sql.Statement: void close()>();
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void closeConnection(java.sql.Connection)>(v);
goto label;
label:
v := @caughtexception;
if v == null goto label;
interfaceinvoke v.<java.sql.Statement: void close()>();
label:
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void closeConnection(java.sql.Connection)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected void closeConnection(java.sql.Connection)
{
org.apache.log4j.jdbc.JDBCAppender v;
java.sql.Connection v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.sql.Connection;
return;
}
protected java.sql.Connection getConnection() throws java.sql.SQLException
{
java.sql.Connection v, v, v;
java.util.Enumeration v;
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = staticinvoke <java.sql.DriverManager: java.util.Enumeration getDrivers()>();
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void setDriver(java.lang.String)>("sun.jdbc.odbc.JdbcOdbcDriver");
label:
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection>;
if v != null goto label;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseURL>;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseUser>;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databasePassword>;
v = staticinvoke <java.sql.DriverManager: java.sql.Connection getConnection(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection> = v;
label:
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection>;
return v;
}
public void close()
{
java.sql.SQLException v;
java.sql.Connection v, v, v;
org.apache.log4j.jdbc.JDBCAppender v;
org.apache.log4j.spi.ErrorHandler v;
boolean v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void flushBuffer()>();
label:
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection>;
if v == null goto label;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection>;
v = interfaceinvoke v.<java.sql.Connection: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection connection>;
interfaceinvoke v.<java.sql.Connection: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.spi.ErrorHandler errorHandler>;
interfaceinvoke v.<org.apache.log4j.spi.ErrorHandler: void error(java.lang.String,java.lang.Exception,int)>("Error closing connection", v, 0);
label:
v.<org.apache.log4j.jdbc.JDBCAppender: boolean closed> = 1;
return;
catch java.sql.SQLException from label to label with label;
}
public void flushBuffer()
{
org.apache.log4j.jdbc.JDBCAppender v;
boolean v;
java.util.ArrayList v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer>;
v = virtualinvoke v.<java.util.ArrayList: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
specialinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void flushBufferSecure()>();
return;
}
private void flushBufferSecure()
{
java.lang.Throwable v;
java.sql.Connection v;
java.util.ArrayList v, v, v;
java.sql.SQLException v;
int v;
java.lang.String v, v;
boolean v;
org.apache.log4j.jdbc.JdbcPatternParser v;
org.apache.log4j.spi.ErrorHandler v, v;
java.lang.IllegalArgumentException v;
java.sql.PreparedStatement v;
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.Class v;
org.apache.log4j.Layout v, v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = new java.util.ArrayList;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer>;
virtualinvoke v.<java.util.ArrayList: boolean removeAll(java.util.Collection)>(v);
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.Layout layout>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v == class "Lorg/apache/log4j/PatternLayout;" goto label;
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.spi.ErrorHandler errorHandler>;
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.Layout layout>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.log4j.Layout)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to convert pattern \u to SQL");
v = <org.apache.log4j.jdbc.JDBCAppender: java.lang.IllegalArgumentException ILLEGAL_PATTERN_FOR_SECURE_EXEC>;
interfaceinvoke v.<org.apache.log4j.spi.ErrorHandler: void error(java.lang.String,java.lang.Exception,int)>(v, v, 5);
return;
label:
v = null;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
if v <= 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: java.sql.Connection getConnection()>();
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.jdbc.JdbcPatternParser preparedStatementParser>;
v = virtualinvoke v.<org.apache.log4j.jdbc.JdbcPatternParser: java.lang.String getParameterizedSql()>();
v = interfaceinvoke v.<java.sql.Connection: java.sql.PreparedStatement prepareStatement(java.lang.String)>(v);
specialinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void safelyInsertIntoDB(java.util.ArrayList,boolean,java.sql.PreparedStatement)>(v, v, v);
label:
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void closeConnection(java.sql.Connection)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.spi.ErrorHandler errorHandler>;
interfaceinvoke v.<org.apache.log4j.spi.ErrorHandler: void error(java.lang.String,java.lang.Exception,int)>("Failed to append messages sql", v, 2);
label:
if v == null goto label;
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void closeConnection(java.sql.Connection)>(v);
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void closeConnection(java.sql.Connection)>(v);
label:
throw v;
label:
return;
catch java.sql.SQLException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void safelyInsertIntoDB(java.util.ArrayList, boolean, java.sql.PreparedStatement) throws java.sql.SQLException
{
java.lang.Throwable v;
org.apache.log4j.jdbc.JdbcPatternParser v;
java.util.Iterator v;
org.apache.log4j.spi.ErrorHandler v;
java.sql.PreparedStatement v;
java.util.ArrayList v;
java.sql.SQLException v;
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.util.ArrayList;
v := @parameter: boolean;
v := @parameter: java.sql.PreparedStatement;
label:
v = virtualinvoke v.<java.util.ArrayList: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.jdbc.JdbcPatternParser preparedStatementParser>;
virtualinvoke v.<org.apache.log4j.jdbc.JdbcPatternParser: void setParameters(java.sql.PreparedStatement,org.apache.log4j.spi.LoggingEvent)>(v, v);
if v == 0 goto label;
interfaceinvoke v.<java.sql.PreparedStatement: void addBatch()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.spi.ErrorHandler errorHandler>;
interfaceinvoke v.<org.apache.log4j.spi.ErrorHandler: void error(java.lang.String,java.lang.Exception,int)>("Failed to append parameters", v, 2);
goto label;
label:
if v == 0 goto label;
interfaceinvoke v.<java.sql.PreparedStatement: int[] executeBatch()>();
goto label;
label:
interfaceinvoke v.<java.sql.PreparedStatement: boolean execute()>();
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.sql.SQLException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void finalize()
{
org.apache.log4j.jdbc.JDBCAppender v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void close()>();
return;
}
public boolean requiresLayout()
{
org.apache.log4j.jdbc.JDBCAppender v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
return 1;
}
public void setSql(java.lang.String)
{
org.apache.log4j.jdbc.JDBCAppender v;
org.apache.log4j.Layout v, v;
org.apache.log4j.PatternLayout v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.lang.String;
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String sqlStatement> = v;
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.Layout getLayout()>();
if v != null goto label;
v = new org.apache.log4j.PatternLayout;
specialinvoke v.<org.apache.log4j.PatternLayout: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: void setLayout(org.apache.log4j.Layout)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.Layout getLayout()>();
virtualinvoke v.<org.apache.log4j.PatternLayout: void setConversionPattern(java.lang.String)>(v);
label:
return;
}
public java.lang.String getSql()
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String sqlStatement>;
return v;
}
public void setUser(java.lang.String)
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.lang.String;
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseUser> = v;
return;
}
public void setURL(java.lang.String)
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.lang.String;
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseURL> = v;
return;
}
public void setPassword(java.lang.String)
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.lang.String;
v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databasePassword> = v;
return;
}
public void setBufferSize(int)
{
int v, v;
org.apache.log4j.jdbc.JDBCAppender v;
java.util.ArrayList v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: int;
v.<org.apache.log4j.jdbc.JDBCAppender: int bufferSize> = v;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.util.ArrayList buffer>;
v = v.<org.apache.log4j.jdbc.JDBCAppender: int bufferSize>;
virtualinvoke v.<java.util.ArrayList: void ensureCapacity(int)>(v);
return;
}
public java.lang.String getUser()
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseUser>;
return v;
}
public java.lang.String getURL()
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databaseURL>;
return v;
}
public java.lang.String getPassword()
{
org.apache.log4j.jdbc.JDBCAppender v;
java.lang.String v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: java.lang.String databasePassword>;
return v;
}
public int getBufferSize()
{
int v;
org.apache.log4j.jdbc.JDBCAppender v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v = v.<org.apache.log4j.jdbc.JDBCAppender: int bufferSize>;
return v;
}
public void setDriver(java.lang.String)
{
org.apache.log4j.jdbc.JDBCAppender v;
org.apache.log4j.spi.ErrorHandler v;
java.lang.String v;
java.lang.Exception v;
v := @this: org.apache.log4j.jdbc.JDBCAppender;
v := @parameter: java.lang.String;
label:
staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.log4j.jdbc.JDBCAppender: org.apache.log4j.spi.ErrorHandler errorHandler>;
interfaceinvoke v.<org.apache.log4j.spi.ErrorHandler: void error(java.lang.String,java.lang.Exception,int)>("Failed to load driver", v, 0);
label:
return;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
java.lang.IllegalArgumentException v;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Only org.apache.log4j.PatternLayout is supported for now due to CVE-2022-23305");
<org.apache.log4j.jdbc.JDBCAppender: java.lang.IllegalArgumentException ILLEGAL_PATTERN_FOR_SECURE_EXEC> = v;
return;
}
}