Commit 1ec71922 authored by cherrylzhao's avatar cherrylzhao
Browse files

migrate saga-example to spi-impl-example repository.

parent c1505d1a

pom.xml

+0 −5
Original line number Diff line number Diff line
@@ -77,11 +77,6 @@ 
                <artifactId>sharding-transaction-xa-core</artifactId>

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

            </dependency>

            <dependency>

                <groupId>io.shardingsphere</groupId>

                <artifactId>sharding-transaction-base-saga</artifactId>

                <version>${sharding-sphere.spi.impl.version}</version>

            </dependency>

            <dependency>

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

                <artifactId>sharding-transaction-base-seata-at</artifactId>

sharding-jdbc-example/transaction-example/pom.xml

+0 −1
Original line number Diff line number Diff line
@@ -13,7 +13,6 @@ 


    <modules>

        <module>transaction-2pc-xa-example</module>

        <module>transaction-base-saga-example</module>

        <module>transaction-base-seata-example</module>

    </modules>

sharding-jdbc-example/transaction-example/transaction-base-saga-example/pom.xml

deleted100755 → 0
+0 −19
Original line number Diff line number Diff line 
<?xml version="1.0" encoding="UTF-8"?>

<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>transaction-example</artifactId>

        <version>4.0.0-RC2-SNAPSHOT</version>

    </parent>

    <artifactId>transation-base-saga-example</artifactId>

    <packaging>pom</packaging>



    <modules>

        <module>transaction-saga-raw-jdbc-example</module>

        <module>transaction-saga-spring-boot-example</module>

        <module>transaction-saga-spring-namespace-example</module>

    </modules>

</project>

sharding-jdbc-example/transaction-example/transaction-base-saga-example/transaction-saga-raw-jdbc-example/pom.xml

deleted100755 → 0
+0 −30
Original line number Diff line number Diff line 
<?xml version="1.0" encoding="UTF-8"?>

<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>transation-base-saga-example</artifactId>

        <version>4.0.0-RC2-SNAPSHOT</version>

    </parent>



    <artifactId>transaction-saga-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>

        <dependency>

            <groupId>io.shardingsphere</groupId>

            <artifactId>sharding-transaction-base-saga</artifactId>

        </dependency>

    </dependencies>



</project>

sharding-jdbc-example/transaction-example/transaction-base-saga-example/transaction-saga-raw-jdbc-example/src/main/java/org/apache/shardingsphere/example/transaction/saga/raw/jdbc/YamlConfigurationTransactionExample.java

deleted100755 → 0
+0 −114
Original line number Diff line number Diff line 
/*

 * 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.transaction.saga.raw.jdbc;



import org.apache.shardingsphere.example.common.entity.OrderItem;

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

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

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

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

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

import org.apache.shardingsphere.transaction.core.TransactionType;

import org.apache.shardingsphere.transaction.core.TransactionTypeHolder;



import javax.sql.DataSource;

import java.io.File;

import java.io.IOException;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;



public class YamlConfigurationTransactionExample {

    

    private static String configFile = "/META-INF/sharding-databases-tables.yaml";

//    private static String configFile = "/META-INF/master-slave.yaml";

    

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

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

        CommonService commonService = getCommonService(dataSource);

        commonService.initEnvironment();

        processSagaTransaction(dataSource, commonService);

        commonService.cleanEnvironment();

    }

    

    private static File getFile(final String fileName) {

        return new File(Thread.currentThread().getClass().getResource(fileName).getFile());

    }

    

    private static CommonService getCommonService(final DataSource dataSource) {

        return new CommonServiceImpl(new OrderRepositoryImpl(dataSource), new OrderItemRepositoryImpl(dataSource));

    }

    

    private static void processSagaTransaction(final DataSource dataSource, final CommonService commonService) throws SQLException {

        TransactionTypeHolder.set(TransactionType.BASE);

        System.out.println("------ start succeed transaction ------");

        try (Connection connection = dataSource.getConnection()) {

            insertSuccess(connection, commonService);

            connection.commit();

            commonService.printData();

        }

        truncateTable(dataSource);

        System.out.println("------ end succeed transaction ------");

        System.out.println("------ start failure transaction ------");

        Connection connection = dataSource.getConnection();

        try {

            insertSuccess(connection, commonService);

            throw new SQLException("exception occur!");

        } catch (final SQLException ex) {

            connection.rollback();

        }

        commonService.printData();

        System.out.println("------ end failure transaction ------");

        truncateTable(dataSource);

    }

    

    private static void insertSuccess(final Connection connection, final CommonService commonService) throws SQLException {

        connection.setAutoCommit(false);

        for (int i = 0; i < 10; i++) {

            OrderItem order = new OrderItem();

            order.setUserId(i);

            order.setStatus("INIT");

            insertOrderItem(connection, order);

        }

        commonService.printData();

    }

    

    private static Long insertOrderItem(final Connection connection, final OrderItem orderItem) {

        String sql = "INSERT INTO t_order_item (order_id, user_id, status) VALUES (?, ?, ?)";

        try (PreparedStatement preparedStatement = connection.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) {

            preparedStatement.setLong(1, 1L);

            preparedStatement.setInt(2, orderItem.getUserId());

            preparedStatement.setString(3, orderItem.getStatus());

            preparedStatement.executeUpdate();

            try (ResultSet resultSet = preparedStatement.getGeneratedKeys()) {

                if (resultSet.next()) {

                    orderItem.setOrderItemId(resultSet.getLong(1));

                }

            }

        } catch (final SQLException ignored) {

        }

        return orderItem.getOrderItemId();

    }

    

    private static void truncateTable(final DataSource dataSource) {

        OrderRepositoryImpl orderRepository = new OrderRepositoryImpl(dataSource);

        orderRepository.truncateTable();

    }

}