A B C D E F G H I L M N O Q R S T W

A

AggregationDistinctQueryMetaData - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Aggregation distinct query metadata.

AggregationDistinctQueryMetaData(Collection<AggregationDistinctSelectItem>, Multimap<String, Integer>) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

AggregationDistinctQueryResult - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Aggregation distinct query result.

AggregationDistinctQueryResult(Collection<QueryResult>, List<AggregationDistinctSelectItem>) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

B

build() - Static method in class org.apache.shardingsphere.core.execute.ShardingThreadFactoryBuilder

Build default sharding thread factory.

build(String) - Static method in class org.apache.shardingsphere.core.execute.ShardingThreadFactoryBuilder

Build sharding thread factory.

C

close() - Method in class org.apache.shardingsphere.core.execute.ShardingExecuteEngine

close() - Method in class org.apache.shardingsphere.core.execute.ShardingExecutorService

Close executor service.

createStatementExecuteUnit(Connection, RouteUnit, ConnectionMode) - Method in interface org.apache.shardingsphere.core.execute.sql.prepare.SQLExecutePrepareCallback

Create SQL execute unit.

D

DistinctQueryResult - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Distinct query result.

DistinctQueryResult(Collection<QueryResult>, List<String>) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

divide() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

Divide one distinct query result to multiple child ones.

divide() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

Divide one distinct query result to multiple child ones.

E

equals(Object) - Method in class org.apache.shardingsphere.core.execute.sql.execute.row.QueryRow

execute(I, boolean, Map<String, Object>) - Method in interface org.apache.shardingsphere.core.execute.ShardingExecuteCallback

Execute callback.

execute(Collection<I>, boolean, Map<String, Object>) - Method in interface org.apache.shardingsphere.core.execute.ShardingGroupExecuteCallback

Execute callback.

execute(Collection<StatementExecuteUnit>, boolean, Map<String, Object>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteCallback

executeGroup(Collection<ShardingExecuteGroup<? extends StatementExecuteUnit>>, SQLExecuteCallback<T>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteTemplate

Execute group.

executeGroup(Collection<ShardingExecuteGroup<? extends StatementExecuteUnit>>, SQLExecuteCallback<T>, SQLExecuteCallback<T>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteTemplate

Execute group.

executeSQL(RouteUnit, Statement, ConnectionMode) - Method in class org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteCallback

ExecutorExceptionHandler - Class in org.apache.shardingsphere.core.execute.sql.execute.threadlocal

Executor runtime exception handler.

ExecutorExceptionHandler() - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.threadlocal.ExecutorExceptionHandler

F

finish(int) - Method in interface org.apache.shardingsphere.core.execute.hook.RootInvokeHook

Handle when root invoke finished.

finish(int) - Method in class org.apache.shardingsphere.core.execute.hook.SPIRootInvokeHook

finishFailure(Exception) - Method in class org.apache.shardingsphere.core.execute.hook.SPISQLExecutionHook

finishFailure(Exception) - Method in interface org.apache.shardingsphere.core.execute.hook.SQLExecutionHook

Handle when SQL execution finished failure.

finishSuccess() - Method in class org.apache.shardingsphere.core.execute.hook.SPISQLExecutionHook

finishSuccess() - Method in interface org.apache.shardingsphere.core.execute.hook.SQLExecutionHook

Handle when SQL execution finished success.

G

getAggregationDistinctColumnIndex(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Get aggregation distinct column index.

getAggregationDistinctColumnIndex(String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Get aggregation distinct column index.

getAggregationDistinctColumnLabel(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Get aggregation distinct column label.

getAggregationType(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Get aggregation type.

getCalendarValue(int, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getCalendarValue(String, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getCalendarValue(int, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getCalendarValue(String, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getCalendarValue(int, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getCalendarValue(String, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getCalendarValue(int, Class<?>, Calendar) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get calendar value.

getCalendarValue(String, Class<?>, Calendar) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get calendar value.

getCalendarValue(int, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getCalendarValue(String, Class<?>, Calendar) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getColumnCount() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getColumnCount() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getColumnCount() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getColumnCount() - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get column count.

getColumnCount() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

Get column count.

getColumnCount() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getColumnIndex(String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getColumnIndex(String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getColumnIndex(String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

Get column index.

getColumnLabel(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getColumnLabel(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getColumnLabel(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getColumnLabel(int) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get column label.

getColumnLabel(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

Get column label.

getColumnLabel(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getColumnName(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

Get column name.

getColumnValue(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.row.QueryRow

Get column value.

getConnection(String) - Method in interface org.apache.shardingsphere.core.execute.metadata.TableMetaDataConnectionManager

Get connection.

getConnections(ConnectionMode, String, int) - Method in interface org.apache.shardingsphere.core.execute.sql.prepare.SQLExecutePrepareCallback

Get connection.

getDataMap() - Static method in class org.apache.shardingsphere.core.execute.ShardingExecuteDataMap

Get data map.

getExecuteUnitGroups(Collection<RouteUnit>, SQLExecutePrepareCallback) - Method in class org.apache.shardingsphere.core.execute.sql.prepare.SQLExecutePrepareTemplate

Get execute unit groups.

getInputStream(int, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getInputStream(String, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getInputStream(int, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getInputStream(String, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getInputStream(Object) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getInputStream(int, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getInputStream(String, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getInputStream(int, String) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get InputStream.

getInputStream(String, String) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get InputStream.

getInputStream(int, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getInputStream(String, String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getShardingEncryptor(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

Get sharding encryptor.

getValue(int, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getValue(String, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

getValue(int, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getValue(String, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

getValue(int, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getValue(String, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

getValue(int, Class<?>) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get data value.

getValue(String, Class<?>) - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Get data value.

getValue(int, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getValue(String, Class<?>) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

getValueByColumnType(ResultSet, int) - Static method in class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultUtil

Get value by column type.

groupExecute(Collection<ShardingExecuteGroup<I>>, ShardingGroupExecuteCallback<I, O>) - Method in class org.apache.shardingsphere.core.execute.ShardingExecuteEngine

Execute for group.

groupExecute(Collection<ShardingExecuteGroup<I>>, ShardingGroupExecuteCallback<I, O>, ShardingGroupExecuteCallback<I, O>, boolean) - Method in class org.apache.shardingsphere.core.execute.ShardingExecuteEngine

Execute for group.

H

handleException(Exception) - Static method in class org.apache.shardingsphere.core.execute.sql.execute.threadlocal.ExecutorExceptionHandler

Handle exception.

hashCode() - Method in class org.apache.shardingsphere.core.execute.sql.execute.row.QueryRow

I

isAggregationDistinctColumnIndex(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Is aggregation distinct column index.

isAggregationDistinctColumnLabel(String) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Is aggregation distinct column label.

isDerivedCountColumnIndex(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Is derived count column index.

isDerivedSumColumnIndex(int) - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryMetaData

Is derived sum column index.

isExceptionThrown() - Static method in class org.apache.shardingsphere.core.execute.sql.execute.threadlocal.ExecutorExceptionHandler

Get throw exception if error occur or not.

L

load(String, ShardingRule) - Method in class org.apache.shardingsphere.core.execute.metadata.TableMetaDataInitializer

Load table meta data.

load(ShardingRule) - Method in class org.apache.shardingsphere.core.execute.metadata.TableMetaDataInitializer

Load all table meta data.

load(String, ShardingRule) - Method in class org.apache.shardingsphere.core.execute.metadata.TableMetaDataLoader

Load table meta data.

M

MemoryQueryResult - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Query result for memory loading.

MemoryQueryResult(ResultSet, ShardingRule, ShardingEncryptorEngine) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

MemoryQueryResult(ResultSet) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

N

next() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

next() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

next() - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

iterate next data.

next() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

O

org.apache.shardingsphere.core.execute - package org.apache.shardingsphere.core.execute

org.apache.shardingsphere.core.execute.hook - package org.apache.shardingsphere.core.execute.hook

org.apache.shardingsphere.core.execute.metadata - package org.apache.shardingsphere.core.execute.metadata

org.apache.shardingsphere.core.execute.sql.execute - package org.apache.shardingsphere.core.execute.sql.execute

org.apache.shardingsphere.core.execute.sql.execute.result - package org.apache.shardingsphere.core.execute.sql.execute.result

org.apache.shardingsphere.core.execute.sql.execute.row - package org.apache.shardingsphere.core.execute.sql.execute.row

org.apache.shardingsphere.core.execute.sql.execute.threadlocal - package org.apache.shardingsphere.core.execute.sql.execute.threadlocal

org.apache.shardingsphere.core.execute.sql.prepare - package org.apache.shardingsphere.core.execute.sql.prepare

Q

QueryResult - Interface in org.apache.shardingsphere.core.execute.sql.execute.result

Query result form database.

QueryResultMetaData - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Query result meta data.

QueryResultMetaData(ResultSetMetaData, ShardingRule, ShardingEncryptorEngine) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

QueryResultMetaData(ResultSetMetaData) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultMetaData

QueryResultUtil - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Query result util.

QueryResultUtil() - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.QueryResultUtil

QueryRow - Class in org.apache.shardingsphere.core.execute.sql.execute.row

Query row.

QueryRow(List<Object>) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.row.QueryRow

R

RootInvokeHook - Interface in org.apache.shardingsphere.core.execute.hook

Root invoke hook.

S

setDataMap(Map<String, Object>) - Static method in class org.apache.shardingsphere.core.execute.ShardingExecuteDataMap

Set data map.

setExceptionThrown(boolean) - Static method in class org.apache.shardingsphere.core.execute.sql.execute.threadlocal.ExecutorExceptionHandler

Set throw exception if error occur or not.

ShardingExecuteCallback<I,O> - Interface in org.apache.shardingsphere.core.execute

Sharding execute callback.

ShardingExecuteDataMap - Class in org.apache.shardingsphere.core.execute

Sharding execute data map for threadlocal even cross multiple threads.

ShardingExecuteDataMap() - Constructor for class org.apache.shardingsphere.core.execute.ShardingExecuteDataMap

ShardingExecuteEngine - Class in org.apache.shardingsphere.core.execute

Sharding execute engine.

ShardingExecuteEngine(int) - Constructor for class org.apache.shardingsphere.core.execute.ShardingExecuteEngine

ShardingExecuteGroup<T> - Class in org.apache.shardingsphere.core.execute

Sharding execute group.

ShardingExecuteGroup() - Constructor for class org.apache.shardingsphere.core.execute.ShardingExecuteGroup

ShardingExecutorService - Class in org.apache.shardingsphere.core.execute

Sharding executor service.

ShardingExecutorService(int) - Constructor for class org.apache.shardingsphere.core.execute.ShardingExecutorService

ShardingExecutorService(int, String) - Constructor for class org.apache.shardingsphere.core.execute.ShardingExecutorService

ShardingGroupExecuteCallback<I,O> - Interface in org.apache.shardingsphere.core.execute

Sharding group execute callback.

ShardingThreadFactoryBuilder - Class in org.apache.shardingsphere.core.execute

Sharding thread factory builder.

ShardingThreadFactoryBuilder() - Constructor for class org.apache.shardingsphere.core.execute.ShardingThreadFactoryBuilder

SPIRootInvokeHook - Class in org.apache.shardingsphere.core.execute.hook

Root invoke hook for SPI.

SPIRootInvokeHook() - Constructor for class org.apache.shardingsphere.core.execute.hook.SPIRootInvokeHook

SPISQLExecutionHook - Class in org.apache.shardingsphere.core.execute.hook

SQL Execution hook for SPI.

SPISQLExecutionHook() - Constructor for class org.apache.shardingsphere.core.execute.hook.SPISQLExecutionHook

SQLExecuteCallback<T> - Class in org.apache.shardingsphere.core.execute.sql.execute

Statement execute callback interface.

SQLExecuteCallback() - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteCallback

SQLExecutePrepareCallback - Interface in org.apache.shardingsphere.core.execute.sql.prepare

SQL execute prepare callback.

SQLExecutePrepareTemplate - Class in org.apache.shardingsphere.core.execute.sql.prepare

SQL execute prepare template.

SQLExecutePrepareTemplate() - Constructor for class org.apache.shardingsphere.core.execute.sql.prepare.SQLExecutePrepareTemplate

SQLExecuteTemplate - Class in org.apache.shardingsphere.core.execute.sql.execute

SQL execute template.

SQLExecuteTemplate() - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.SQLExecuteTemplate

SQLExecutionHook - Interface in org.apache.shardingsphere.core.execute.hook

SQL Execution hook.

start() - Method in interface org.apache.shardingsphere.core.execute.hook.RootInvokeHook

Handle when root invoke started.

start() - Method in class org.apache.shardingsphere.core.execute.hook.SPIRootInvokeHook

start(RouteUnit, DataSourceMetaData, boolean, Map<String, Object>) - Method in class org.apache.shardingsphere.core.execute.hook.SPISQLExecutionHook

start(RouteUnit, DataSourceMetaData, boolean, Map<String, Object>) - Method in interface org.apache.shardingsphere.core.execute.hook.SQLExecutionHook

Handle when SQL execution started.

StatementExecuteUnit - Class in org.apache.shardingsphere.core.execute

Execute unit for JDBC statement.

StatementExecuteUnit() - Constructor for class org.apache.shardingsphere.core.execute.StatementExecuteUnit

StreamQueryResult - Class in org.apache.shardingsphere.core.execute.sql.execute.result

Query result for stream loading.

StreamQueryResult(ResultSet, ShardingRule, ShardingEncryptorEngine) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

StreamQueryResult(ResultSet) - Constructor for class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

T

TableMetaDataConnectionManager - Interface in org.apache.shardingsphere.core.execute.metadata

Manager of connection which for table meta data loader.

TableMetaDataInitializer - Class in org.apache.shardingsphere.core.execute.metadata

Table meta data initializer.

TableMetaDataInitializer(ShardingDataSourceMetaData, ShardingExecuteEngine, TableMetaDataConnectionManager, int, boolean) - Constructor for class org.apache.shardingsphere.core.execute.metadata.TableMetaDataInitializer

TableMetaDataLoader - Class in org.apache.shardingsphere.core.execute.metadata

Table meta data loader.

TableMetaDataLoader() - Constructor for class org.apache.shardingsphere.core.execute.metadata.TableMetaDataLoader

W

wasNull() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.AggregationDistinctQueryResult

wasNull() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.DistinctQueryResult

wasNull() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.MemoryQueryResult

wasNull() - Method in interface org.apache.shardingsphere.core.execute.sql.execute.result.QueryResult

Judge ResultSet is null or not.

wasNull() - Method in class org.apache.shardingsphere.core.execute.sql.execute.result.StreamQueryResult

A B C D E F G H I L M N O Q R S T W