io.undertow.server.handlers

public Class JDBCLogHandler

Class Inheritance

extends Object
implements HttpHandler, Runnable

java.lang.Object
io.undertow.server.handlers.JDBCLogHandler

All Implemented Interfaces

java.lang.Runnable, io.undertow.server.HttpHandler

Imports

io.undertow.UndertowLogger, .UndertowMessages, io.undertow.security.api.SecurityContext, io.undertow.server.ExchangeCompletionListener, .HandlerWrapper, .HttpHandler, .HttpServerExchange, io.undertow.server.handlers.builder.HandlerBuilder, io.undertow.util.Headers, java.net.InetSocketAddress, java.sql.Connection, .PreparedStatement, .SQLException, .Timestamp, java.util.ArrayList, .Collections, .Deque, .HashMap, .List, .Map, .Set, java.util.concurrent.ConcurrentLinkedDeque, .Executor, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, javax.naming.InitialContext, .NamingException, javax.sql.DataSource

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static class	JDBCLogHandler.Builder
private static class	JDBCLogHandler.JDBCLogAttribute
private class	JDBCLogHandler.JDBCLogCompletionListener
private static class	JDBCLogHandler.Wrapper

Field Summary

Modifier and Type	Field and Description
private String	bytesField
private final DataSource	dataSource
private final ExchangeCompletionListener	exchangeCompletionListener
private volatile Executor	executor
private final String	formatString
private String	methodField
private final HttpHandler	next
private final Deque<JDBCLogHandler.JDBCLogAttribute>	pendingMessages
private String	queryField
private String	refererField
private String	remoteHostField
private volatile int	state
private static final AtomicIntegerFieldUpdater<JDBCLogHandler>	stateUpdater
private String	statusField
private String	tableName
private String	timestampField
protected boolean	useLongContentLength
private String	userAgentField
private String	userField
private String	virtualHostField

Constructor Summary

Access	Constructor and Description
public	JDBCLogHandler(final HttpHandler next, final Executor logWriteExecutor, final String formatString, DataSource dataSource) Deprecated
public	JDBCLogHandler(final HttpHandler next, final String formatString, DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
pack-priv void	awaitWrittenForTest() For tests only.
public String	getBytesField()
public String	getMethodField()
public String	getQueryField()
public String	getRefererField()
public String	getRemoteHostField()
public String	getStatusField()
public String	getTableName()
public String	getTimestampField()
public String	getUserAgentField()
public String	getUserField()
public String	getVirtualHostField()
public void	handleRequest(HttpServerExchange the HTTP request/response exchange exchange) Implements io.undertow.server.HttpHandler.handleRequest. Handle the request.
public boolean	isUseLongContentLength()
public void	logMessage(String pattern, HttpServerExchange exchange)
private PreparedStatement	prepareStatement(Connection conn)
public void	run() Implements java.lang.Runnable.run. insert the log record to database
public void	setBytesField(String bytesField)
public void	setMethodField(String methodField)
public void	setQueryField(String queryField)
public void	setRefererField(String refererField)
public void	setRemoteHostField(String remoteHostField)
public void	setStatusField(String statusField)
public void	setTableName(String tableName)
public void	setTimestampField(String timestampField)
public void	setUseLongContentLength(boolean useLongContentLength)
public void	setUserAgentField(String userAgentField)
public void	setUserField(String userField)
public void	setVirtualHostField(String virtualHostField)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
private void	writeMessage(List<JDBCLogHandler.JDBCLogAttribute> messages)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

bytesField	back to summary
private String bytesField

dataSource	back to summary
private final DataSource dataSource

exchangeCompletionListener	back to summary
private final ExchangeCompletionListener exchangeCompletionListener

executor	back to summary
private volatile Executor executor Annotations @SuppressWarnings:unused

formatString	back to summary
private final String formatString

methodField	back to summary
private String methodField

next	back to summary
private final HttpHandler next

pendingMessages	back to summary
private final Deque<JDBCLogHandler.JDBCLogAttribute> pendingMessages

queryField	back to summary
private String queryField

refererField	back to summary
private String refererField

remoteHostField	back to summary
private String remoteHostField

state	back to summary
private volatile int state Annotations @SuppressWarnings:unused

stateUpdater	back to summary
private static final AtomicIntegerFieldUpdater<JDBCLogHandler> stateUpdater

statusField	back to summary
private String statusField

tableName	back to summary
private String tableName

timestampField	back to summary
private String timestampField

useLongContentLength	back to summary
protected boolean useLongContentLength

userAgentField	back to summary
private String userAgentField

userField	back to summary
private String userField

virtualHostField	back to summary
private String virtualHostField

Constructor Detail

JDBCLogHandler	back to summary
public JDBCLogHandler(final HttpHandler next, final Executor logWriteExecutor, final String formatString, DataSource dataSource) Deprecated Annotations @Deprecated

JDBCLogHandler	back to summary
public JDBCLogHandler(final HttpHandler next, final String formatString, DataSource dataSource)

Method Detail

awaitWrittenForTest	back to summary
pack-priv void awaitWrittenForTest() throws InterruptedException For tests only. Blocks the current thread until all messages are written Just does a busy wait. DO NOT USE THIS OUTSIDE OF A TEST

awaitWrittenForTest

back to summary

pack-priv void awaitWrittenForTest() throws InterruptedException

For tests only. Blocks the current thread until all messages are written Just does a busy wait.

DO NOT USE THIS OUTSIDE OF A TEST

getBytesField	back to summary
public String getBytesField()

getMethodField	back to summary
public String getMethodField()

getQueryField	back to summary
public String getQueryField()

getRefererField	back to summary
public String getRefererField()

getRemoteHostField	back to summary
public String getRemoteHostField()

getStatusField	back to summary
public String getStatusField()

getTableName	back to summary
public String getTableName()

getTimestampField	back to summary
public String getTimestampField()

getUserAgentField	back to summary
public String getUserAgentField()

getUserField	back to summary
public String getUserField()

getVirtualHostField	back to summary
public String getVirtualHostField()

handleRequest	back to summary
public void handleRequest(HttpServerExchange exchange) throws Exception Implements io.undertow.server.HttpHandler.handleRequest. Doc from io.undertow.server.HttpHandler.handleRequest. Handle the request. Parameters exchange:HttpServerExchange the HTTP request/response exchange Annotations @Override

handleRequest

back to summary

public void handleRequest(HttpServerExchange exchange) throws Exception

Implements io.undertow.server.HttpHandler.handleRequest.

Doc from io.undertow.server.HttpHandler.handleRequest.

Handle the request.

Parameters

exchange:HttpServerExchange: the HTTP request/response exchange

Annotations

@Override

isUseLongContentLength	back to summary
public boolean isUseLongContentLength()

logMessage	back to summary
public void logMessage(String pattern, HttpServerExchange exchange)

prepareStatement	back to summary
private PreparedStatement prepareStatement(Connection conn) throws SQLException

run	back to summary
public void run() Implements java.lang.Runnable.run. insert the log record to database Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

insert the log record to database

Annotations

@Override

setBytesField	back to summary
public void setBytesField(String bytesField)

setMethodField	back to summary
public void setMethodField(String methodField)

setQueryField	back to summary
public void setQueryField(String queryField)

setRefererField	back to summary
public void setRefererField(String refererField)

setRemoteHostField	back to summary
public void setRemoteHostField(String remoteHostField)

setStatusField	back to summary
public void setStatusField(String statusField)

setTableName	back to summary
public void setTableName(String tableName)

setTimestampField	back to summary
public void setTimestampField(String timestampField)

setUseLongContentLength	back to summary
public void setUseLongContentLength(boolean useLongContentLength)

setUserAgentField	back to summary
public void setUserAgentField(String userAgentField)

setUserField	back to summary
public void setUserField(String userField)

setVirtualHostField	back to summary
public void setVirtualHostField(String virtualHostField)

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

writeMessage	back to summary
private void writeMessage(List<JDBCLogHandler.JDBCLogAttribute> messages)

io.undertow.server.handlers back to summary

public Class JDBCLogHandler.Builder

Class Inheritance

extends Object
implements HandlerBuilder

java.lang.Object
io.undertow.server.handlers.JDBCLogHandler.Builder

All Implemented Interfaces

io.undertow.server.handlers.builder.HandlerBuilder

Constructor Summary

Access	Constructor and Description
public	Builder()

Method Summary

Modifier and Type	Method and Description
public HandlerWrapper	build(Map<String, Object> The handler config config) Implements io.undertow.server.handlers.builder.HandlerBuilder.build. Creates the handler
public String	defaultParameter() Implements io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter.
public String	name() Implements io.undertow.server.handlers.builder.HandlerBuilder.name. The string representation of the handler name.
public Map<String, Class<?>>	parameters() Implements io.undertow.server.handlers.builder.HandlerBuilder.parameters. Returns a map of parameters and their types.
public Set<String>	requiredParameters() Implements io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

Builder	back to summary
public Builder()

Method Detail

build

back to summary

public HandlerWrapper build(Map<String, Object> config)

Implements io.undertow.server.handlers.builder.HandlerBuilder.build.

Doc from io.undertow.server.handlers.builder.HandlerBuilder.build.

Creates the handler

Parameters

config:Map<String, Object>: The handler config

Returns:HandlerWrapper

The new predicate

Annotations

@Override

defaultParameter

back to summary

public String defaultParameter()

Implements io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter.

Returns:String

Doc from io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter.

The default parameter name, or null if it does not have a default parameter

Annotations

@Override

name

back to summary

public String name()

Implements io.undertow.server.handlers.builder.HandlerBuilder.name.

Doc from io.undertow.server.handlers.builder.HandlerBuilder.name.

The string representation of the handler name.

Returns:String

The handler name

Annotations

@Override

parameters

back to summary

public Map<String, Class<?>> parameters()

Implements io.undertow.server.handlers.builder.HandlerBuilder.parameters.

Doc from io.undertow.server.handlers.builder.HandlerBuilder.parameters.

Returns a map of parameters and their types.

Annotations

@Override

requiredParameters

back to summary

public Set<String> requiredParameters()

Implements io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters.

Returns:Set<String>

Doc from io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters.

The required parameters

Annotations

@Override

io.undertow.server.handlers back to summary

private Class JDBCLogHandler.JDBCLogAttribute

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.handlers.JDBCLogHandler.JDBCLogAttribute

Field Summary

Modifier and Type	Field and Description
protected long	bytes
protected String	method
protected String	pattern
protected String	query
protected String	referer
protected String	remoteHost
protected int	status
protected Timestamp	timestamp
protected String	user
protected String	userAgent
protected String	virtualHost

Constructor Summary

Access	Constructor and Description
private	JDBCLogAttribute()

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bytes	back to summary
protected long bytes

method	back to summary
protected String method

pattern	back to summary
protected String pattern

query	back to summary
protected String query

referer	back to summary
protected String referer

remoteHost	back to summary
protected String remoteHost

status	back to summary
protected int status

timestamp	back to summary
protected Timestamp timestamp

user	back to summary
protected String user

userAgent	back to summary
protected String userAgent

virtualHost	back to summary
protected String virtualHost

Constructor Detail

JDBCLogAttribute	back to summary
private JDBCLogAttribute()

io.undertow.server.handlers back to summary

private Class JDBCLogHandler.JDBCLogCompletionListener

Class Inheritance

extends Object
implements ExchangeCompletionListener

java.lang.Object
io.undertow.server.handlers.JDBCLogHandler.JDBCLogCompletionListener

All Implemented Interfaces

io.undertow.server.ExchangeCompletionListener

Constructor Summary

Access	Constructor and Description
private	JDBCLogCompletionListener()

Method Summary

Modifier and Type	Method and Description
public void	exchangeEvent(final HttpServerExchange exchange, final ExchangeCompletionListener.NextListener nextListener) Implements io.undertow.server.ExchangeCompletionListener.exchangeEvent.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

JDBCLogCompletionListener	back to summary
private JDBCLogCompletionListener()

Method Detail

exchangeEvent

back to summary

public void exchangeEvent(final HttpServerExchange exchange, final ExchangeCompletionListener.NextListener nextListener)

Implements io.undertow.server.ExchangeCompletionListener.exchangeEvent.

Annotations

@Override

io.undertow.server.handlers back to summary

private Class JDBCLogHandler.Wrapper

Class Inheritance

extends Object
implements HandlerWrapper

java.lang.Object
io.undertow.server.handlers.JDBCLogHandler.Wrapper

All Implemented Interfaces

io.undertow.server.HandlerWrapper

Field Summary

Modifier and Type	Field and Description
private final String	bytesField
private final DataSource	datasource
private final String	format
private final String	methodField
private final String	queryField
private final String	refererField
private final String	remoteHostField
private final String	statusField
private final String	tableName
private final String	timestampField
private final String	userAgentField
private final String	userField
private final String	virtualHostField

Constructor Summary

Access	Constructor and Description
private	Wrapper(String format, DataSource datasource, String tableName, String remoteHostField, String userField, String timestampField, String virtualHostField, String methodField, String queryField, String statusField, String bytesField, String refererField, String userAgentField)

Method Summary

Modifier and Type	Method and Description
public HttpHandler	wrap(HttpHandler handler) Implements io.undertow.server.HandlerWrapper.wrap.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bytesField

back to summary

private final String bytesField

datasource

back to summary

private final DataSource datasource

format

back to summary

private final String format

methodField

back to summary

private final String methodField

queryField

back to summary

private final String queryField

refererField

back to summary

private final String refererField

remoteHostField

back to summary

private final String remoteHostField

statusField

back to summary

private final String statusField

tableName

back to summary

private final String tableName

timestampField

back to summary

private final String timestampField

userAgentField

back to summary

private final String userAgentField

userField

back to summary

private final String userField

virtualHostField

back to summary

private final String virtualHostField

Constructor Detail

Wrapper

back to summary

private Wrapper(String format, DataSource datasource, String tableName, String remoteHostField, String userField, String timestampField, String virtualHostField, String methodField, String queryField, String statusField, String bytesField, String refererField, String userAgentField)

Method Detail

wrap

back to summary

public HttpHandler wrap(HttpHandler handler)

Implements io.undertow.server.HandlerWrapper.wrap.

Annotations

@Override