Package ru.cg.webbpm.modules.database.impl.processor

Class LimitSqlSelectRequestProcessorImpl

java.lang.Object

org.jooq.impl.DefaultExecuteListener

ru.cg.webbpm.modules.database.impl.analytics.BaseExecuteListener

ru.cg.webbpm.modules.database.impl.processor.LimitSqlSelectRequestProcessorImpl

All Implemented Interfaces:

Serializable, EventListener, org.jooq.ExecuteListener, SqlRequestProcessor

@Component
public class LimitSqlSelectRequestProcessorImpl
extends BaseExecuteListener
implements SqlRequestProcessor

Author:

Kochetkov

See Also:

• Serialized Form

Field Summary

Fields inherited from class ru.cg.webbpm.modules.database.impl.analytics.BaseExecuteListener

executionContextHelper

Constructor Summary

Constructors

Constructor	Description
LimitSqlSelectRequestProcessorImpl(Integer selectRecordsMaxLimit, Integer selectRecordsMinLimit, boolean queryLimitEnabled)

Method Summary

Modifier and Type	Method	Description
String	processSQL(String sql)
void	resultEnd(org.jooq.ExecuteContext ctx)

Methods inherited from class ru.cg.webbpm.modules.database.impl.analytics.BaseExecuteListener

getExecutionContext, getFormattedQueryWithValues, queryWithValues

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jooq.ExecuteListener

bindEnd, bindStart, end, exception, executeEnd, executeStart, fetchEnd, fetchStart, outEnd, outStart, prepareEnd, prepareStart, recordEnd, recordStart, renderEnd, renderStart, resultStart, start, warning

Constructor Details

LimitSqlSelectRequestProcessorImpl

@Autowired
public LimitSqlSelectRequestProcessorImpl(@Value("${webbpm.db.select_records_max_limit:100000}")
 Integer selectRecordsMaxLimit,
 @Value("${webbpm.db.select_records_min_limit:1000}")
 Integer selectRecordsMinLimit,
 @Value("${webbpm.db.query_limit_enabled:false}")
 boolean queryLimitEnabled)

Method Details

processSQL

public String processSQL(String sql)

Specified by:

processSQL in interface SqlRequestProcessor

resultEnd

public void resultEnd(org.jooq.ExecuteContext ctx)

Specified by:

resultEnd in interface org.jooq.ExecuteListener