test: transaction test

This commit is contained in:
aisensiy 2017-08-22 11:22:29 +08:00
parent 8e7ec76774
commit 49030da9ca
4 changed files with 59 additions and 1 deletions

View File

@ -0,0 +1,9 @@
package io.spring;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.annotation.EnableTransactionManagement;
@Configuration
@EnableTransactionManagement
public class MyBatisConfig {
}

View File

@ -5,6 +5,7 @@ import io.spring.core.article.ArticleRepository;
import io.spring.core.article.Tag; import io.spring.core.article.Tag;
import io.spring.infrastructure.mybatis.mapper.ArticleMapper; import io.spring.infrastructure.mybatis.mapper.ArticleMapper;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import java.util.Optional; import java.util.Optional;
@ -17,6 +18,7 @@ public class MyBatisArticleRepository implements ArticleRepository {
} }
@Override @Override
@Transactional
public void save(Article article) { public void save(Article article) {
if (articleMapper.findById(article.getId()) == null) { if (articleMapper.findById(article.getId()) == null) {
createNew(article); createNew(article);
@ -26,13 +28,13 @@ public class MyBatisArticleRepository implements ArticleRepository {
} }
private void createNew(Article article) { private void createNew(Article article) {
articleMapper.insert(article);
for (Tag tag : article.getTags()) { for (Tag tag : article.getTags()) {
if (!articleMapper.findTag(tag.getName())) { if (!articleMapper.findTag(tag.getName())) {
articleMapper.insertTag(tag); articleMapper.insertTag(tag);
} }
articleMapper.insertArticleTagRelation(article.getId(), tag.getId()); articleMapper.insertArticleTagRelation(article.getId(), tag.getId());
} }
articleMapper.insert(article);
} }
@Override @Override

View File

@ -0,0 +1,46 @@
package io.spring.infrastructure.article;
import io.spring.core.article.Article;
import io.spring.core.article.ArticleRepository;
import io.spring.core.user.User;
import io.spring.core.user.UserRepository;
import io.spring.infrastructure.mybatis.mapper.ArticleMapper;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertThat;
@RunWith(SpringRunner.class)
@SpringBootTest
@AutoConfigureTestDatabase
public class ArticleRepositoryTransactionTest {
@Autowired
private ArticleRepository articleRepository;
@Autowired
private UserRepository userRepository;
@Autowired
private ArticleMapper articleMapper;
@Test
public void transactional_test() throws Exception {
User user = new User("aisensiy@gmail.com", "aisensiy", "123", "bio", "default");
userRepository.save(user);
Article article = new Article("test", "desc", "body", new String[]{"java", "spring"}, user.getId());
articleRepository.save(article);
Article anotherArticle = new Article("test", "desc", "body", new String[]{"java", "spring", "other"}, user.getId());
try {
articleRepository.save(anotherArticle);
} catch (Exception e) {
assertThat(articleMapper.findTag("other"), is(false));
}
}
}

View File

@ -30,6 +30,7 @@ public class MyBatisArticleRepositoryTest {
@Autowired @Autowired
private UserRepository userRepository; private UserRepository userRepository;
private User user; private User user;
private Article article; private Article article;