Commit 0bd14a33 authored by terrymanu's avatar terrymanu
Browse files

refactor proxy example

parent e32c2517

sharding-proxy-example/src/main/java/io/shardingsphere/example/proxy/main/DataSourceUtil.java

0 → 100644
+17 −0
Original line number Diff line number Diff line 
package io.shardingsphere.example.proxy.main;



import org.apache.commons.dbcp.BasicDataSource;



import javax.sql.DataSource;



public final class DataSourceUtil {

    

    public static DataSource createDataSource(final String ip, final int port) {

        BasicDataSource result = new BasicDataSource();

        result.setDriverClassName(com.mysql.jdbc.Driver.class.getName());

        result.setUrl(String.format("jdbc:mysql://%s:%d/sharding_db?useServerPrepStmts=true&cachePrepStmts=true", ip, port));

        result.setUsername("root");

        result.setPassword("root");

        return result;

    }

}

sharding-proxy-example/src/main/java/io/shardingsphere/example/proxy/main/ProxyMain.java

+1 −11
Original line number Diff line number Diff line
@@ -20,7 +20,6 @@ package io.shardingsphere.example.proxy.main; 
import io.shardingsphere.example.repository.jdbc.repository.RawOrderItemRepository;

import io.shardingsphere.example.repository.jdbc.repository.RawOrderRepository;

import io.shardingsphere.example.repository.jdbc.service.RawDemoService;

import org.apache.commons.dbcp.BasicDataSource;



import javax.sql.DataSource;
@@ -35,16 +34,7 @@ public final class ProxyMain { 
    private static final int PROXY_PORT = 3307;

    

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

        DataSource dataSource = createDataSource();

        DataSource dataSource = DataSourceUtil.createDataSource(PROXY_IP, PROXY_PORT);

        new RawDemoService(new RawOrderRepository(dataSource), new RawOrderItemRepository(dataSource)).demo();

    }

    

    private static DataSource createDataSource() {

        BasicDataSource result = new BasicDataSource();

        result.setDriverClassName(com.mysql.jdbc.Driver.class.getName());

        result.setUrl(String.format("jdbc:mysql://%s:%d/sharding_db?useServerPrepStmts=true&cachePrepStmts=true", PROXY_IP, PROXY_PORT));

        result.setUsername("root");

        result.setPassword("root");

        return result;

    }

}

sharding-proxy-example/src/main/java/io/shardingsphere/example/proxy/main/ProxyXaMain.java

+2 −11
Original line number Diff line number Diff line
@@ -20,7 +20,6 @@ package io.shardingsphere.example.proxy.main; 
import io.shardingsphere.example.repository.jdbc.repository.XaOrderItemRepository;

import io.shardingsphere.example.repository.jdbc.repository.XaOrderRepository;

import io.shardingsphere.example.repository.jdbc.service.XaDemoService;

import org.apache.commons.dbcp.BasicDataSource;



import javax.sql.DataSource;
@@ -30,21 +29,13 @@ import javax.sql.DataSource; 
 * 3. Please make sure sharding-proxy is running before you run this example.

 */

public class ProxyXaMain {

    

    private static final String PROXY_IP = "localhost";

    

    private static final int PROXY_PORT = 3307;

    

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

        DataSource dataSource = createDataSource();

        DataSource dataSource = DataSourceUtil.createDataSource(PROXY_IP, PROXY_PORT);

        new XaDemoService(new XaOrderRepository(dataSource), new XaOrderItemRepository(dataSource)).demo();

    }

    

    private static DataSource createDataSource() {

        BasicDataSource result = new BasicDataSource();

        result.setDriverClassName(com.mysql.jdbc.Driver.class.getName());

        result.setUrl(String.format("jdbc:mysql://%s:%d/sharding_db?useServerPrepStmts=true&cachePrepStmts=true", PROXY_IP, PROXY_PORT));

        result.setUsername("root");

        result.setPassword("root");

        return result;

    }

}

sharding-proxy-example/src/main/resources/config.yaml→sharding-proxy-example/src/main/resources/config-sharding.yaml

+2 −0
Original line number Diff line number Diff line 
schemaName: sharding_db



dataSources:

  ds_0:

    url: jdbc:mysql://127.0.0.1:3306/demo_ds_0

sharding-proxy-example/src/main/resources/logback.xml

+2 −4
Original line number Diff line number Diff line 
<?xml version="1.0" encoding="UTF-8"?>

<configuration>



    <property name="log.context.name" value="sharding-proxy-example" />

    <property name="log.charset" value="UTF-8" />

    <property name="log.pattern" value="[%-5level] %date --%thread-- [%logger] %msg %n" />



    <contextName>${log.context.name}</contextName>

    

    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">