remove broadcast-example, will be integrated into sharding-example.

<?xml version="1.0" encoding="UTF-8"?>

<!--

  ~ Licensed to the Apache Software Foundation (ASF) under one or more

  ~ contributor license agreements.  See the NOTICE file distributed with

  ~ this work for additional information regarding copyright ownership.

  ~ The ASF licenses this file to You 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.

  -->

<project xmlns="http://maven.apache.org/POM/4.0.0"

         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <parent>

        <groupId>org.apache.shardingsphere.example</groupId>

        <artifactId>broadcast-table-example</artifactId>

        <version>4.0.0-RC2</version>

    </parent>

    <artifactId>broadcast-table-raw-jdbc-example</artifactId>

    <dependencies>

        <dependency>

            <groupId>org.apache.shardingsphere.example</groupId>

            <artifactId>repository-jdbc</artifactId>

            <version>${project.version}</version>

        </dependency>

        <dependency>

            <groupId>org.apache.shardingsphere</groupId>

            <artifactId>sharding-jdbc-core</artifactId>

        </dependency>

    </dependencies>

</project>

/*

 * Licensed to the Apache Software Foundation (ASF) under one or more

 * contributor license agreements.  See the NOTICE file distributed with

 * this work for additional information regarding copyright ownership.

 * The ASF licenses this file to You 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.

 */

/*

 * Please make sure master-slave data sync on MySQL is running correctly. Otherwise this example will query empty data from slave.

 */

package org.apache.shardingsphere.example.broadcast.table.raw.jdbc;

import org.apache.shardingsphere.example.broadcast.table.raw.jdbc.config.ShardingDatabasesConfiguration;

import org.apache.shardingsphere.example.common.jdbc.repository.CountryRepositoryImpl;

import org.apache.shardingsphere.example.common.jdbc.repository.SportsmanRepositoryImpl;

import org.apache.shardingsphere.example.common.jdbc.service.SportsmanServiceImpl;

import org.apache.shardingsphere.example.common.service.CommonService;

import javax.sql.DataSource;

import java.sql.SQLException;

public class JavaConfigurationExample {

    public static void main(final String[] args) throws SQLException {

        DataSource dataSource = new ShardingDatabasesConfiguration().getDataSource();

        CommonService countryService = getCountryService(dataSource);

        countryService.initEnvironment();

        countryService.processSuccess();

        countryService.cleanEnvironment();

    }

    private static CommonService getCountryService(final DataSource dataSource) {

        return new SportsmanServiceImpl(new CountryRepositoryImpl(dataSource), new SportsmanRepositoryImpl(dataSource));

    }

}

/*

 * Licensed to the Apache Software Foundation (ASF) under one or more

 * contributor license agreements.  See the NOTICE file distributed with

 * this work for additional information regarding copyright ownership.

 * The ASF licenses this file to You 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 org.apache.shardingsphere.example.broadcast.table.raw.jdbc;

import org.apache.shardingsphere.example.common.jdbc.repository.CountryRepositoryImpl;

import org.apache.shardingsphere.example.common.jdbc.repository.SportsmanRepositoryImpl;

import org.apache.shardingsphere.example.common.jdbc.service.SportsmanServiceImpl;

import org.apache.shardingsphere.example.common.service.CommonService;

import org.apache.shardingsphere.shardingjdbc.api.yaml.YamlShardingDataSourceFactory;

import javax.sql.DataSource;

import java.io.File;

import java.io.IOException;

import java.sql.SQLException;

public class YamlConfigurationExample {

    public static void main(final String[] args) throws SQLException, IOException {

        DataSource dataSource = YamlShardingDataSourceFactory.createDataSource(getFile());

        CommonService countryService = getCountryService(dataSource);

        countryService.initEnvironment();

        countryService.processSuccess();

        countryService.cleanEnvironment();

    }

    private static File getFile() {

        return new File(Thread.currentThread().getClass().getResource("/META-INF/sharding-databases.yaml").getFile());

    }

    private static CommonService getCountryService(final DataSource dataSource) {

        return new SportsmanServiceImpl(new CountryRepositoryImpl(dataSource), new SportsmanRepositoryImpl(dataSource));

    }

}

/*

 * Licensed to the Apache Software Foundation (ASF) under one or more

 * contributor license agreements.  See the NOTICE file distributed with

 * this work for additional information regarding copyright ownership.

 * The ASF licenses this file to You 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 org.apache.shardingsphere.example.broadcast.table.raw.jdbc.config;

import org.apache.shardingsphere.api.config.sharding.KeyGeneratorConfiguration;

import org.apache.shardingsphere.api.config.sharding.ShardingRuleConfiguration;

import org.apache.shardingsphere.api.config.sharding.TableRuleConfiguration;

import org.apache.shardingsphere.api.config.sharding.strategy.InlineShardingStrategyConfiguration;

import org.apache.shardingsphere.example.common.DataSourceUtil;

import org.apache.shardingsphere.example.config.ExampleConfiguration;

import org.apache.shardingsphere.shardingjdbc.api.ShardingDataSourceFactory;

import javax.sql.DataSource;

import java.sql.SQLException;

import java.util.HashMap;

import java.util.Map;

import java.util.Properties;

public class ShardingDatabasesConfiguration implements ExampleConfiguration {

    @Override

    public DataSource getDataSource() throws SQLException {

        ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();

        shardingRuleConfig.getTableRuleConfigs().add(getSportsmanTableRuleConfiguration());

        shardingRuleConfig.getBroadcastTables().add("t_country");

        shardingRuleConfig.setDefaultDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("id", "demo_ds_${id % 2}"));

        return ShardingDataSourceFactory.createDataSource(createDataSourceMap(), shardingRuleConfig, new Properties());

    }

    private TableRuleConfiguration getSportsmanTableRuleConfiguration() {

        TableRuleConfiguration result = new TableRuleConfiguration("t_sportsman");

        Properties properties = new Properties();

        properties.setProperty("worker.id", "123");

        result.setKeyGeneratorConfig(new KeyGeneratorConfiguration("SNOWFLAKE", "id", properties));

        return result;

    }

    private static Map<String, DataSource> createDataSourceMap() {

        Map<String, DataSource> result = new HashMap<>();

        result.put("demo_ds_0", DataSourceUtil.createDataSource("demo_ds_0"));

        result.put("demo_ds_1", DataSourceUtil.createDataSource("demo_ds_1"));

        return result;

    }

}

dataSources:

  ds_0: !!com.zaxxer.hikari.HikariDataSource

    driverClassName: com.mysql.jdbc.Driver

    jdbcUrl: jdbc:mysql://localhost:3306/demo_ds_0?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=UTF-8

    username: root

    password:

  ds_1: !!com.zaxxer.hikari.HikariDataSource

    driverClassName: com.mysql.jdbc.Driver

    jdbcUrl: jdbc:mysql://localhost:3306/demo_ds_1?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=UTF-8

    username: root

    password:

shardingRule:

  tables:

    t_sportsman:

      actualDataNodes: ds_${0..1}.t_sportsman

      keyGenerator:

        type: SNOWFLAKE

        column: id

        props:

          worker.id: 123

  defaultDatabaseStrategy:

    inline:

      shardingColumn: id

      algorithmExpression: ds_${id % 2}

  broadcastTables:

    - t_country

props:

  sql.show: false