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 Method |
getGeneratedKeysMethod()
|
protected abstract String |
getInsertSQL()
|
protected abstract void |
secondarySubAppend(E eventObject, Connection
|
protected long |
selectEventId(PreparedStatement
|
void |
setConnectionSource(ConnectionSource
|
void |
start()
|
void |
stop()
|
protected abstract void |
subAppend(E eventObject, Connection
|
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 ConnectionSourceconnectionSource
protected boolean cnxSupportsGetGeneratedKeys
protected boolean cnxSupportsBatchUpdates
protected SQLDialectsqlDialect
protected abstract MethodgetGeneratedKeysMethod()
protected abstract StringgetInsertSQL()
public void start()
public ConnectionSourcegetConnectionSource()
public void setConnectionSource(ConnectionSourceconnectionSource)
connectionSource - The connectionSource to set.
public void append(E eventObject)
protected abstract void subAppend(E eventObject, Connectionconnection, PreparedStatement statement) throws Throwable
Throwable
protected abstract void secondarySubAppend(E eventObject, Connectionconnection, long eventId) throws Throwable
Throwable
protected long selectEventId(PreparedStatementinsertStatement, Connection connection) throws SQLException , InvocationTargetException
public void stop()