Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package com.ces.mybatis;
import java.util.ArrayList;
import java.util.List;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.TransactionIsolationLevel;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.test.context.junit4.SpringRunner;
import com.ces.mybatis.dao.IUserDao;
import com.ces.mybatis.model.Context;
import com.ces.mybatis.model.User;
import com.ces.mybatis.service.IUserService;
/**
* Unit test for simple App.
*/
@RunWith(SpringRunner.class)
@SpringBootTest(classes = Application.class)
public class AppTest
{
private static final AnnotationConfigApplicationContext context =
new AnnotationConfigApplicationContext("application.yml");
// 注入“Converter”bean
@Autowired
private IUserService userService;
/**
* 1. 自定义TypeHandler类
*/
@Test
public void test1(){
List<User> user = userService.getAll();
System.out.println(user);
}
/**
* 2. Mybatis 批量插入数据库代码
*/
@Test
public void test2(){
SqlSessionFactory sqlSessionFactory = context
.getBean("sqlSessionFactory", SqlSessionFactory.class);
SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
IUserDao mapper = sqlSession.getMapper(IUserDao.class);
List<User> users = new ArrayList<User>();
for(int i=0;i<3;i++){
User user = new User();
user.setUserId(String.valueOf(i));
user.setUserName("admin"+i);
user.setPassword("123");
Context context = new Context();
context.setCity("city");
context.setProvince("province");
context.setDistrict("district");
user.setContext(context);
users.add(user);
}
boolean isSuccess = mapper.insertOrUpdateByBatch(users);
System.out.println(isSuccess);
// 刷新
sqlSession.flushStatements();
}
}