Commit 134cf0a7 authored by tristaZero's avatar tristaZero
Browse files

ShardingOnlyWithTables.java

parent 457bd35c
Loading
Loading
Loading
Loading
+2 −2
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ import io.shardingsphere.api.config.TableRuleConfiguration;
import io.shardingsphere.example.jdbc.util.DataSourceUtil;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemRepository;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;
import io.shardingsphere.example.repository.jdbc.service.DemoService;
import io.shardingsphere.example.repository.jdbc.service.RawDemoService;
import io.shardingsphere.shardingjdbc.api.ShardingDataSourceFactory;

import javax.sql.DataSource;
@@ -35,7 +35,7 @@ public class ShardingOnlyWithTables {
    
    public static void main(final String[] args) throws SQLException {
        DataSource dataSource = getDataSource();
        new DemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        new RawDemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
    }
    
    private static DataSource getDataSource() throws SQLException {
+2 −2
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ package io.shardingsphere.example.jdbc.main.nodep.yaml;

import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemRepository;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;
import io.shardingsphere.example.repository.jdbc.service.DemoService;
import io.shardingsphere.example.repository.jdbc.service.RawDemoService;
import io.shardingsphere.shardingjdbc.api.yaml.YamlShardingDataSourceFactory;

import javax.sql.DataSource;
@@ -29,7 +29,7 @@ public class ShardingOnlyWithTables {
    
    public static void main(final String[] args) throws Exception {
        DataSource dataSource = YamlShardingDataSourceFactory.createDataSource(getYamlFile());
        new DemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        new RawDemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
    }
    
    private static File getYamlFile() {
+2 −2
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ import io.shardingsphere.api.config.TableRuleConfiguration;
import io.shardingsphere.example.jdbc.util.DataSourceUtil;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemRepository;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;
import io.shardingsphere.example.repository.jdbc.service.DemoService;
import io.shardingsphere.example.repository.jdbc.service.RawDemoService;
import io.shardingsphere.orchestration.config.OrchestrationConfiguration;
import io.shardingsphere.orchestration.config.OrchestrationType;
import io.shardingsphere.orchestration.reg.api.RegistryCenterConfiguration;
@@ -44,7 +44,7 @@ public class ShardingOnlyWithTables {
    
    public static void main(final String[] args) throws SQLException {
        DataSource dataSource = getDataSource();
        new DemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        new RawDemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        ((OrchestrationShardingDataSource) dataSource).close();
    }
    
+2 −2
Original line number Diff line number Diff line
@@ -22,7 +22,7 @@ import io.shardingsphere.api.config.TableRuleConfiguration;
import io.shardingsphere.example.jdbc.util.DataSourceUtil;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemRepository;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;
import io.shardingsphere.example.repository.jdbc.service.DemoService;
import io.shardingsphere.example.repository.jdbc.service.RawDemoService;
import io.shardingsphere.orchestration.config.OrchestrationConfiguration;
import io.shardingsphere.orchestration.config.OrchestrationType;
import io.shardingsphere.orchestration.reg.api.RegistryCenterConfiguration;
@@ -46,7 +46,7 @@ public class ShardingOnlyWithTables {
    
    public static void main(final String[] args) throws SQLException {
        DataSource dataSource = getDataSource();
        new DemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        new RawDemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        ((OrchestrationShardingDataSource) dataSource).close();
    }
    
+2 −2
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ package io.shardingsphere.example.jdbc.main.orche.yaml.etcd;

import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemRepository;
import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;
import io.shardingsphere.example.repository.jdbc.service.DemoService;
import io.shardingsphere.example.repository.jdbc.service.RawDemoService;
import io.shardingsphere.shardingjdbc.orchestration.api.yaml.YamlOrchestrationShardingDataSourceFactory;
import io.shardingsphere.shardingjdbc.orchestration.internal.datasource.OrchestrationShardingDataSource;

@@ -32,7 +32,7 @@ public class ShardingOnlyWithTables {
    
    public static void main(final String[] args) throws Exception {
        DataSource dataSource = YamlOrchestrationShardingDataSourceFactory.createDataSource(getYamlFile());
        new DemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        new RawDemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();
        ((OrchestrationShardingDataSource) dataSource).close();
    }
    
Loading