Commit b79c6baa authored by tristaZero's avatar tristaZero
Browse files

GLOBAL_REGISTRY.getShardingProperties()

parent 03a4d517

sharding-proxy/src/main/java/io/shardingsphere/shardingproxy/backend/netty/NettyBackendHandler.java

+3 −2
Original line number Diff line number Diff line
@@ -216,8 +216,9 @@ public final class NettyBackendHandler extends AbstractBackendHandler { 
    // TODO refresh table meta data by SQL parse result

    private void refreshTableMetaData(final String logicTableName) throws SQLException {

        TableMetaDataLoader tableMetaDataLoader = new TableMetaDataLoader(

                logicSchema.getMetaData().getDataSource(), BackendExecutorContext.getInstance().getExecuteEngine(), new ProxyTableMetaDataConnectionManager(

                        logicSchema.getBackendDataSource()), GLOBAL_REGISTRY.getShardingProperties().<Integer>getValue(ShardingPropertiesConstant.MAX_CONNECTIONS_SIZE_PER_QUERY));

                logicSchema.getMetaData().getDataSource(), BackendExecutorContext.getInstance().getExecuteEngine(), new ProxyTableMetaDataConnectionManager(logicSchema.getBackendDataSource()), 

                GLOBAL_REGISTRY.getShardingProperties().<Integer>getValue(ShardingPropertiesConstant.MAX_CONNECTIONS_SIZE_PER_QUERY), 

                GLOBAL_REGISTRY.getShardingProperties().<Boolean>getValue(ShardingPropertiesConstant.CHECK_TABLE_METADATA_ENABLED));

        logicSchema.getMetaData().getTable().put(logicTableName, tableMetaDataLoader.load(logicTableName, ((ShardingSchema) logicSchema).getShardingRule()));

    }