public abstract class DBAppenderBase<E> extends UnsynchronizedAppenderBase<E>
Modifier and Type | Field and Description |
---|---|
protected boolean |
cnxSupportsBatchUpdates |
protected boolean |
cnxSupportsGetGeneratedKeys |
protected ConnectionSource |
connectionSource |
protected SQLDialect |
sqlDialect |
name, started
context
Constructor and Description |
---|
DBAppenderBase() |
Modifier and Type | Method and Description |
---|---|
void |
append(E eventObject) |
ConnectionSource |
getConnectionSource() |
protected abstract java.lang.reflect.Method |
getGeneratedKeysMethod() |
protected abstract java.lang.String |
getInsertSQL() |
protected abstract void |
secondarySubAppend(E eventObject,
java.sql.Connection connection,
long eventId) |
protected long |
selectEventId(java.sql.PreparedStatement insertStatement,
java.sql.Connection connection) |
void |
setConnectionSource(ConnectionSource connectionSource) |
void |
start() |
void |
stop() |
protected abstract void |
subAppend(E eventObject,
java.sql.Connection connection,
java.sql.PreparedStatement statement) |
addFilter, clearAllFilters, doAppend, getCopyOfAttachedFiltersList, getFilterChainDecision, getName, isStarted, setName, toString
addError, addError, addInfo, addInfo, addStatus, addWarn, addWarn, getContext, getDeclaredOrigin, getStatusManager, setContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addError, addError, addInfo, addInfo, addStatus, addWarn, addWarn, getContext, setContext
protected ConnectionSource connectionSource
protected boolean cnxSupportsGetGeneratedKeys
protected boolean cnxSupportsBatchUpdates
protected SQLDialect sqlDialect
protected abstract java.lang.reflect.Method getGeneratedKeysMethod()
protected abstract java.lang.String getInsertSQL()
public void start()
start
in interface LifeCycle
start
in class UnsynchronizedAppenderBase<E>
public ConnectionSource getConnectionSource()
public void setConnectionSource(ConnectionSource connectionSource)
connectionSource
- The connectionSource to set.public void append(E eventObject)
append
in class UnsynchronizedAppenderBase<E>
protected abstract void subAppend(E eventObject, java.sql.Connection connection, java.sql.PreparedStatement statement) throws java.lang.Throwable
java.lang.Throwable
protected abstract void secondarySubAppend(E eventObject, java.sql.Connection connection, long eventId) throws java.lang.Throwable
java.lang.Throwable
protected long selectEventId(java.sql.PreparedStatement insertStatement, java.sql.Connection connection) throws java.sql.SQLException, java.lang.reflect.InvocationTargetException
java.sql.SQLException
java.lang.reflect.InvocationTargetException
public void stop()
stop
in interface LifeCycle
stop
in class UnsynchronizedAppenderBase<E>