Commit 2ae22c55 authored by cherrylzhao's avatar cherrylzhao
Browse files

ShardingHook => Shard Hook.

parent d07827a3

sharding-core/sharding-core-entry/src/main/java/org/apache/shardingsphere/core/BaseShardingEngine.java

+5 −5
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ import org.apache.shardingsphere.api.hint.HintManager; 
import org.apache.shardingsphere.core.constant.DatabaseType;

import org.apache.shardingsphere.core.constant.properties.ShardingProperties;

import org.apache.shardingsphere.core.constant.properties.ShardingPropertiesConstant;

import org.apache.shardingsphere.core.hook.SPIShardingHook;

import org.apache.shardingsphere.core.hook.SPIShardHook;

import org.apache.shardingsphere.core.metadata.ShardingMetaData;

import org.apache.shardingsphere.core.rewrite.SQLBuilder;

import org.apache.shardingsphere.core.rewrite.SQLRewriteEngine;
@@ -53,7 +53,7 @@ public abstract class BaseShardingEngine { 
    

    private final DatabaseType databaseType;

    

    private final SPIShardingHook shardingHook = new SPIShardingHook();

    private final SPIShardHook shardHook = new SPIShardHook();

    

    /**

     * Shard.
@@ -63,7 +63,7 @@ public abstract class BaseShardingEngine { 
     * @return SQL route result

     */

    public SQLRouteResult shard(final String sql, final List<Object> parameters) {

        shardingHook.start(sql);

        shardHook.start(sql);

        try {

            List<Object> clonedParameters = cloneParameters(parameters);

            SQLRouteResult result = route(sql, clonedParameters);
@@ -72,12 +72,12 @@ public abstract class BaseShardingEngine { 
                boolean showSimple = shardingProperties.getValue(ShardingPropertiesConstant.SQL_SIMPLE);

                SQLLogger.logSQL(sql, showSimple, result.getSqlStatement(), result.getRouteUnits());

            }

            shardingHook.finishSuccess(result, metaData.getTable());

            shardHook.finishSuccess(result, metaData.getTable());

            return result;

            // CHECKSTYLE:OFF

        } catch (final Exception ex) {

            // CHECKSTYLE:ON

            shardingHook.finishFailure(ex);

            shardHook.finishFailure(ex);

            throw ex;

        }

    }

sharding-core/sharding-core-entry/src/main/java/org/apache/shardingsphere/core/hook/SPIShardingHook.java→sharding-core/sharding-core-entry/src/main/java/org/apache/shardingsphere/core/hook/SPIShardHook.java

+7 −7
Original line number Diff line number Diff line
@@ -24,35 +24,35 @@ import org.apache.shardingsphere.core.spi.NewInstanceServiceLoader; 
import java.util.Collection;



/**

 * Sharding hook for SPI.

 * Shard hook for SPI.

 *

 * @author zhaojun

 */

public final class SPIShardingHook implements ShardingHook {

public final class SPIShardHook implements ShardHook {

    

    private final Collection<ShardingHook> shardingHooks = NewInstanceServiceLoader.newServiceInstances(ShardingHook.class);

    private final Collection<ShardHook> shardHooks = NewInstanceServiceLoader.newServiceInstances(ShardHook.class);

    

    static {

        NewInstanceServiceLoader.register(ShardingHook.class);

        NewInstanceServiceLoader.register(ShardHook.class);

    }

    

    @Override

    public void start(final String sql) {

        for (ShardingHook each : shardingHooks) {

        for (ShardHook each : shardHooks) {

            each.start(sql);

        }

    }

    

    @Override

    public void finishSuccess(final SQLRouteResult sqlRouteResult, final ShardingTableMetaData shardingTableMetaData) {

        for (ShardingHook each : shardingHooks) {

        for (ShardHook each : shardHooks) {

            each.finishSuccess(sqlRouteResult, shardingTableMetaData);

        }

    }

    

    @Override

    public void finishFailure(final Exception cause) {

        for (ShardingHook each : shardingHooks) {

        for (ShardHook each : shardHooks) {

            each.finishFailure(cause);

        }

    }

sharding-core/sharding-core-entry/src/main/java/org/apache/shardingsphere/core/hook/ShardingHook.java→sharding-core/sharding-core-entry/src/main/java/org/apache/shardingsphere/core/hook/ShardHook.java

+5 −5
Original line number Diff line number Diff line
@@ -21,21 +21,21 @@ import org.apache.shardingsphere.core.metadata.table.ShardingTableMetaData; 
import org.apache.shardingsphere.core.route.SQLRouteResult;



/**

 * Sharding hook.

 * Shard hook.

 *

 * @author zhaojun

 */

public interface ShardingHook {

public interface ShardHook {

    

    /**

     * Handle when sharding started.

     * Handle when shard started.

     *

     * @param sql SQL to be sharding

     */

    void start(String sql);

    

    /**

     * Handle when sharding finished success.

     * Handle when shard finished success.

     *

     * @param sqlRouteResult sql route result

     * @param shardingTableMetaData sharding table meta data
@@ -43,7 +43,7 @@ public interface ShardingHook { 
    void finishSuccess(SQLRouteResult sqlRouteResult, ShardingTableMetaData shardingTableMetaData);

    

    /**

     * Handle when sharding finished failure.

     * Handle when shard finished failure.

     * 

     * @param cause failure cause

     */