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, startedcontext| 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, toStringaddError, addError, addInfo, addInfo, addStatus, addWarn, addWarn, getContext, getDeclaredOrigin, getStatusManager, setContextclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddError, addError, addInfo, addInfo, addStatus, addWarn, addWarn, getContext, setContextprotected 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 LifeCyclestart 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.Throwableprotected abstract void secondarySubAppend(E eventObject, java.sql.Connection connection, long eventId) throws java.lang.Throwable
java.lang.Throwableprotected long selectEventId(java.sql.PreparedStatement insertStatement,
java.sql.Connection connection)
throws java.sql.SQLException,
java.lang.reflect.InvocationTargetException
java.sql.SQLExceptionjava.lang.reflect.InvocationTargetExceptionpublic void stop()
stop in interface LifeCyclestop in class UnsynchronizedAppenderBase<E>