gpt4 book ai didi

org.apache.shardingsphere.core.yaml.sharding.YamlShardingRuleConfiguration.getShardingRuleConfiguration()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 21:34:03 27 4
gpt4 key购买 nike

本文整理了Java中org.apache.shardingsphere.core.yaml.sharding.YamlShardingRuleConfiguration.getShardingRuleConfiguration()方法的一些代码示例,展示了YamlShardingRuleConfiguration.getShardingRuleConfiguration()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。YamlShardingRuleConfiguration.getShardingRuleConfiguration()方法的具体详情如下:
包路径:org.apache.shardingsphere.core.yaml.sharding.YamlShardingRuleConfiguration
类名称:YamlShardingRuleConfiguration
方法名:getShardingRuleConfiguration

YamlShardingRuleConfiguration.getShardingRuleConfiguration介绍

[英]Get sharding rule configuration.
[中]获取分片规则配置。

代码示例

代码示例来源:origin: apache/incubator-shardingsphere

@Override
  public ShardingRuleConfiguration load(final String data) {
    return new Yaml().loadAs(data, YamlShardingRuleConfiguration.class).getShardingRuleConfiguration();
  }
}

代码示例来源:origin: apache/incubator-shardingsphere

private static Map<String, RuleConfiguration> getRuleConfiguration(final Map<String, YamlProxyRuleConfiguration> localRuleConfigs) {
    Map<String, RuleConfiguration> result = new HashMap<>();
    for (Entry<String, YamlProxyRuleConfiguration> entry : localRuleConfigs.entrySet()) {
      result.put(entry.getKey(), null != entry.getValue().getShardingRule() ? entry.getValue().getShardingRule().getShardingRuleConfiguration()
          : entry.getValue().getMasterSlaveRule().getMasterSlaveRuleConfiguration());
    }
    return result;
  }
}

代码示例来源:origin: apache/incubator-shardingsphere

private static Map<String, RuleConfiguration> getRuleConfiguration(final Map<String, YamlProxyRuleConfiguration> localRuleConfigs) {
    Map<String, RuleConfiguration> result = new HashMap<>();
    for (Entry<String, YamlProxyRuleConfiguration> entry : localRuleConfigs.entrySet()) {
      result.put(entry.getKey(), null != entry.getValue().getShardingRule() ? entry.getValue().getShardingRule().getShardingRuleConfiguration()
          : entry.getValue().getMasterSlaveRule().getMasterSlaveRuleConfiguration());
    }
    return result;
  }
}

代码示例来源:origin: apache/incubator-shardingsphere

private static DataSource createDataSource(final Map<String, DataSource> dataSourceMap, final YamlShardingRuleConfiguration yamlConfig, 
                      final Map<String, Object> configMap, final Properties props, final OrchestrationConfiguration orchestrationConfig) throws SQLException {
  if (null == yamlConfig) {
    return new OrchestrationShardingDataSource(orchestrationConfig);
  } else {
    ShardingDataSource shardingDataSource = new ShardingDataSource(
        dataSourceMap, new ShardingRule(yamlConfig.getShardingRuleConfiguration(), dataSourceMap.keySet()), configMap, props);
    return new OrchestrationShardingDataSource(shardingDataSource, orchestrationConfig);
  }
}

代码示例来源:origin: apache/incubator-shardingsphere

/**
 * Create sharding data source.
 *
 * @param dataSourceMap data source map
 * @param yamlFile yaml file for rule configuration of databases and tables sharding without data sources
 * @return sharding data source
 * @throws SQLException SQL exception
 * @throws IOException IO exception
 */
public static DataSource createDataSource(final Map<String, DataSource> dataSourceMap, final File yamlFile) throws SQLException, IOException {
  YamlShardingConfiguration config = YamlShardingConfiguration.unmarshal(yamlFile);
  return ShardingDataSourceFactory.createDataSource(
      dataSourceMap, config.getShardingRule().getShardingRuleConfiguration(), config.getConfigMap(), config.getProps());
}

代码示例来源:origin: apache/incubator-shardingsphere

/**
   * Create sharding data source.
   *
   * @param dataSourceMap data source map
   * @param yamlBytes yaml bytes for rule configuration of databases and tables sharding without data sources
   * @return sharding data source
   * @throws SQLException SQL exception
   * @throws IOException IO exception
   */
  public static DataSource createDataSource(final Map<String, DataSource> dataSourceMap, final byte[] yamlBytes) throws SQLException, IOException {
    YamlShardingConfiguration config = YamlShardingConfiguration.unmarshal(yamlBytes);
    return ShardingDataSourceFactory.createDataSource(
        dataSourceMap, config.getShardingRule().getShardingRuleConfiguration(), config.getConfigMap(), config.getProps());
  }
}

代码示例来源:origin: apache/incubator-shardingsphere

/**
 * Create sharding data source.
 *
 * @param yamlFile yaml file for rule configuration of databases and tables sharding with data sources
 * @return sharding data source
 * @throws SQLException SQL exception
 * @throws IOException IO exception
 */
public static DataSource createDataSource(final File yamlFile) throws SQLException, IOException {
  YamlShardingConfiguration config = YamlShardingConfiguration.unmarshal(yamlFile);
  return ShardingDataSourceFactory.createDataSource(
      config.getDataSources(), config.getShardingRule().getShardingRuleConfiguration(), config.getConfigMap(), config.getProps());
}

代码示例来源:origin: apache/incubator-shardingsphere

/**
 * Create sharding data source.
 *
 * @param yamlBytes yaml bytes for rule configuration of databases and tables sharding with data sources
 * @return sharding data source
 * @throws SQLException SQL exception
 * @throws IOException IO exception
 */
public static DataSource createDataSource(final byte[] yamlBytes) throws SQLException, IOException {
  YamlShardingConfiguration config = YamlShardingConfiguration.unmarshal(yamlBytes);
  return ShardingDataSourceFactory.createDataSource(
      config.getDataSources(), config.getShardingRule().getShardingRuleConfiguration(), config.getConfigMap(), config.getProps());
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com