Commit efef9b80 authored by tristaZero's avatar tristaZero
Browse files

USE... 

USE GLOBAL_REGISTRY.getShardingProperties().<Boolean>getValue(ShardingPropertiesConstant.CHECK_TABLE_METADATA_ENABLED)
parent bf585f7a

sharding-proxy/src/main/java/io/shardingsphere/shardingproxy/backend/jdbc/JDBCBackendHandler.java

+2 −1
Original line number Diff line number Diff line
@@ -104,7 +104,8 @@ public final class JDBCBackendHandler extends AbstractBackendHandler { 
            // TODO refresh table meta data by SQL parse result

            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));

                    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()));

        }

        return merge(sqlStatement);