org.apache.shardingsphere.shardingjdbc.executor

Class AbstractStatementExecutor

java.lang.Object

org.apache.shardingsphere.shardingjdbc.executor.AbstractStatementExecutor

Direct Known Subclasses:

BatchPreparedStatementExecutor, PreparedStatementExecutor, StatementExecutor

public abstract class AbstractStatementExecutor
extends Object

Abstract statement executor.

Author:

panjuan, maxiaoguang

Constructor Summary

Constructors

Constructor and Description
AbstractStatementExecutor(int resultSetType, int resultSetConcurrency, int resultSetHoldability, ShardingConnection shardingConnection)

Method Summary

Modifier and Type	Method and Description
protected void	cacheStatements()
void	clear() Clear data.
protected <T> List<T>	executeCallback(org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteCallback<T> executeCallback) To make sure SkyWalking will be available at the next release of ShardingSphere, a new plugin should be provided to SkyWalking project if this API changed.
protected boolean	isAccumulate()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractStatementExecutor

public AbstractStatementExecutor(int resultSetType,
                                 int resultSetConcurrency,
                                 int resultSetHoldability,
                                 ShardingConnection shardingConnection)

Method Detail

cacheStatements

protected final void cacheStatements()

executeCallback

protected final <T> List<T> executeCallback(org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteCallback<T> executeCallback)
                                     throws SQLException

To make sure SkyWalking will be available at the next release of ShardingSphere, a new plugin should be provided to SkyWalking project if this API changed.

Throws:

SQLException

See Also:

Plugin Development Guide

isAccumulate

protected final boolean isAccumulate()

clear

public void clear()
           throws SQLException

Clear data.

Throws:

SQLException - sql exception