/* * Copyright 1999-2015 dangdang.com. *
* Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. *
*/ package io.shardingjdbc.orchestration.yaml.sharding; import io.shardingjdbc.core.jdbc.core.datasource.ShardingDataSource; import io.shardingjdbc.core.yaml.sharding.YamlShardingRuleConfiguration; import org.yaml.snakeyaml.Yaml; import org.yaml.snakeyaml.constructor.Constructor; import javax.sql.DataSource; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStreamReader; import java.sql.SQLException; import java.util.Collections; import java.util.Map; /** * Orchestration sharding datasource for yaml. * * @author caohao */ public class YamlOrchestrationShardingDataSource extends ShardingDataSource { public YamlOrchestrationShardingDataSource(final File yamlFile) throws IOException, SQLException { super(unmarshal(yamlFile).getShardingRule(Collections.