log4j logging to database

Hello,

Good Day..

I am trying out some example regarding logging in the database from JDBCAppender of Log4J from the book that I am reading but can't seem to make it work.

Here is the code where the book tried extending the JDBCAppender

import org.apache.log4j.jdbc.JDBCAppender;
import java.sql.PreparedStatement;
import java.sql.Connection;
import java.sql.SQLException;
import org.apache.log4j.spi.LoggingEvent;
import org.apache.log4j.Logger;
import org.apache.log4j.PatternLayout;
import java.util.StringTokenizer;
 
public class CustomJDBCAppender extends JDBCAppender {
 
private static Logger logger = Logger.getLogger(CustomJDBCAppender.class.getPackage().getName());

/** Holds value of property values. */
    private String values;
 
    /**the prepared statement object**/
    private PreparedStatement stmt = null;
 
    /** Holds value of property preparedSQL. */
    private String preparedSQL;
 
    /** Creates a new instance of CustomJDBCAppender */
    public CustomJDBCAppender() {
    System.out.println("Custom Apppender exist");
    }
 
    public void doAppend(LoggingEvent event) {
        buffer.add(event);
        if(buffer.size()>=bufferSize) {
          flushBuffer();
        }
    }
 
    /**
     * overridden method from the JDBCAppender. This method sets the
     * parameters for the prepared statement
     * before executing the statement
     **/
    public void execute(String sql) throws SQLException {
    System.out.println("Entering the execute statement....");
    
        PreparedStatement stmt = getPreparedStatement();
        StringTokenizer tokenizer = new StringTokenizer(sql, ",");
        int i=1;
        while(tokenizer.hasMoreTokens()) {
            String token = tokenizer.nextToken();
            stmt.setString(i, token);
            i++;
        }
        stmt.executeUpdate();
 
    }
 
    private PreparedStatement getPreparedStatement() throws SQLException {
        //resuse the getConnection() method from the super class
    
    System.out.println("Trying to get a connection.....");
        Connection conn = getConnection();
        
        if (conn == null)
        {
        System.out.println("Got Connection");
        }
        else
        {
        System.out.println("Null Connection");
        }
        if(stmt==null) {
        System.out.println("Getting statement from prepared SQL");
            stmt = conn.prepareStatement(getPreparedSQL());
        }
        return stmt;
    }

public String getValues() {
        return this.values;
    }
 
    public void setValues(String values) {
        PatternLayout layout = new PatternLayout(values);
        this.setLayout(layout);
        this.values = values;
    }
 
    public String getPreparedSQL() {
        return this.preparedSQL;
    }
 
    public void setPreparedSQL(String preparedSQL) {
        this.preparedSQL = preparedSQL;
    }
}

...and here's my modified properties file

From what I am seeing, it was able to instantiate the class CustomJDBCAppender because the constructor was called but the overriden method was not called...

I would really appreciate all your pointers. Thanks.

Your CustomJDBCAppender class doesn't seem to have a "package" declaration. Add the following package declaration to that class:

Hello,

Sorry..I forgot to include that when I copied the definition of my class but my class is package accordingly.

But still the overriden execute method was not executed accordingly. Maybe I am missing something that I need to place in the code, Thanks.