Commit 10b42b09 authored by tristaZero's avatar tristaZero
Browse files

use... 

use GLOBAL_REGISTRY.getShardingProperties().<Boolean>getValue(ShardingPropertiesConstant.CHECK_TABLE_METADATA_ENABLED)
parent a216182a

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

+7 −7
Original line number Diff line number Diff line
@@ -17,14 +17,8 @@ 


package io.shardingsphere.shardingproxy.backend.jdbc;



import java.sql.SQLException;

import java.util.ArrayList;

import java.util.Collection;

import java.util.List;



import com.google.common.base.Function;

import com.google.common.collect.Lists;



import io.shardingsphere.api.config.rule.ShardingRuleConfiguration;

import io.shardingsphere.core.constant.DatabaseType;

import io.shardingsphere.core.constant.SQLType;
@@ -65,6 +59,11 @@ import io.shardingsphere.shardingproxy.transport.mysql.packet.generic.OKPacket; 
import io.shardingsphere.transaction.api.TransactionType;

import lombok.RequiredArgsConstructor;



import java.sql.SQLException;

import java.util.ArrayList;

import java.util.Collection;

import java.util.List;



/**

 * Backend handler via JDBC to connect databases.

 *
@@ -114,7 +113,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()));

            }

        }