public void flushBuffer()
{
//Do the actual logging
removes.ensureCapacity(buffer.size());
for (Iterator i = buffer.iterator(); i.hasNext();)
{
try
{
LoggingEvent logEvent = (LoggingEvent)i.next();
String sql = getLogStatement(logEvent);
//System.out.println(sql);
sql = formatSql(sql);
//System.out.println(sql);
if(sql!=null && sql.length()!=0)
{
execute(sql);
}
removes.add(logEvent);
}
catch (SQLException e)
{
errorHandler.error("Failed to excute sql", e,ErrorCode.FLUSH_FAILURE);
}
}
// remove from the buffer any events that were reported
buffer.removeAll(removes);
// clear the buffer of reported events
removes.clear();
}
}