Commit 9718af17 authored by cherrylzhao's avatar cherrylzhao
Browse files

implement t_user interface for raw-jdbc.

parent a9569d4e

example-common/repository-jdbc/src/main/java/org/apache/shardingsphere/example/common/jdbc/service/UserServiceImpl.java

0 → 100644
+92 −0
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.common.jdbc.service;



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

import org.apache.shardingsphere.example.common.repository.UserRepository;

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



import java.util.ArrayList;

import java.util.List;



public final class UserServiceImpl implements CommonService {

    

    private final UserRepository userRepository;

    

    public UserServiceImpl(UserRepository userRepository) {

        this.userRepository = userRepository;

    }

    

    @Override

    public void initEnvironment() {

        userRepository.createTableIfNotExists();

        userRepository.truncateTable();

    }

    

    @Override

    public void cleanEnvironment() {

        userRepository.dropTable();

    }

    

    @Override

    public void processSuccess() {

        System.out.println("-------------- Process Success Begin ---------------");

        List<Long> userIds = insertData();

        printData();

        deleteData(userIds);

        printData();

        System.out.println("-------------- Process Success Finish --------------");

    }

    

    @Override

    public void processFailure() {

        System.out.println("-------------- Process Failure Begin ---------------");

        insertData();

        System.out.println("-------------- Process Failure Finish --------------");

        throw new RuntimeException("Exception occur for transaction test.");

    }

    

    private List<Long> insertData() {

        System.out.println("---------------------------- Insert Data ----------------------------");

        List<Long> result = new ArrayList<>(10);

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

            User user = new User();

            user.setUserId(i);

            user.setUserName("test_" + i);

            user.setPwd("pwd" + i);

            userRepository.insert(user);

            result.add((long) user.getUserId());

        }

        return result;

    }

    

    private void deleteData(final List<Long> userIds) {

        System.out.println("---------------------------- Delete Data ----------------------------");

        for (Long each : userIds) {

            userRepository.delete(each);

        }

    }

    

    @Override

    public void printData() {

        System.out.println("---------------------------- Print User Data -----------------------");

        for (Object each : userRepository.selectAll()) {

            System.out.println(each);

        }

    }

}

example-common/repository-jpa/src/main/java/org/apache/shardingsphere/example/common/jpa/service/UserCommonServiceImpl.java

+2 −2
Original line number Diff line number Diff line
@@ -66,8 +66,8 @@ public class UserCommonServiceImpl implements UseService { 
        for (int i = 1; i <= 10; i++) {

            UserEntity user = new UserEntity();

            user.setUserId(i);

            user.setUserName("test_" + i);

            user.setPwd("pwd" + i);

            user.setUserName("test_jpa_" + i);

            user.setPwd("pwd_jpa_" + i);

            userRepository.insert(user);

            result.add((long) user.getUserId());

        }

example-common/repository-mybatis/src/main/java/org/apache/shardingsphere/example/common/mybatis/service/SpringUserServiceImpl.java

+2 −2
Original line number Diff line number Diff line
@@ -60,8 +60,8 @@ public class SpringUserServiceImpl implements UserService { 
        for (int i = 1; i <= 10; i++) {

            User user = new User();

            user.setUserId(i);

            user.setUserName("test_" + i);

            user.setPwd("pwd" + i);

            user.setUserName("test_mybatis_" + i);

            user.setPwd("pwd_mybatis_" + i);

            userRepository.insert(user);

            result.add((long) user.getUserId());

        }