1.pom添加依賴
|
1
2
3
4
5
6
7
8
9
10
|
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.42</version> </dependency> |
2.添加數(shù)據(jù)源配置（DataSource啥的，一系列對(duì)象spring boot 都會(huì)給你注入的，配置配置即可！）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
spring.datasource.url=jdbc:mysql://localhost/test?characterEncoding=utf8&useSSL=truespring.datasource.username=rootspring.datasource.password=123456spring.datasource.driver-class-name=com.mysql.jdbc.Driver#database pool config# Number of ms to wait before throwing an exception if no connection is available.spring.datasource.tomcat.max-wait=10000# Maximum number of active connections that can be allocated from this pool at the same time.spring.datasource.tomcat.max-active=300# Validate the connection before borrowing it from the pool.spring.datasource.tomcat.test-on-borrow=true# initial pool sizespring.datasource.tomcat.initial-size=20#=====================jpa config================================#實(shí)體類維護(hù)數(shù)據(jù)庫表結(jié)構(gòu)的具體行為：update/create/create-drop/validate/nonespring.jpa.hibernate.ddl-auto=none#打印sql語句spring.jpa.show-sql=true#格式化輸出的json字符串spring.jackson.serialization.indent_output=true |
3.新建實(shí)體
|
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
|
@Entity@Table(name="user")public class User { @Id @Column(name="id") @GeneratedValue(strategy = GenerationType.IDENTITY) private Integer id; @Column(name="number") private String number; @Column(name="name") private String name; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getNumber() { return number; } public void setNumber(String number) { this.number = number; } public String getName() { return name; } public void setName(String name) { this.name = name; }} |
4.dao層
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
public interface UserDao{ User getById(int id); User getByNumber(String number); int addUser(User user); void deleteUserById(int id); User updateUser(User user);} |
|
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
|
@Repositorypublic class UserDaoImpl implements UserDao { @PersistenceContext private EntityManager entityManager; @Override public User getById(int id) { //find by primary key return this.entityManager.find(User.class,id); } @Override public User getByNumber(String number) { Query query = this.entityManager.createQuery("from User u where u.number=:number",User.class); query.setParameter("number",number); User user = (User)query.getSingleResult(); return user; } @Override public int addUser(User user) { this.entityManager.persist(user); //print the id System.out.println(user.getId()); return user.getId(); } @Override public void deleteUserById(int id) { User user = this.entityManager.find(User.class,id); //關(guān)聯(lián)到記錄，方可刪除 this.entityManager.remove(user); } @Override public User updateUser(User user) { User userNew = this.entityManager.merge(user); return userNew; }} |
5.service層
|
1
2
3
4
5
6
7
8
9
10
11
12
|
public interface UserService { User getById(int id); User getByNumber(String number); int addUser(User user,boolean throwEx); void deleteUserById(int id); User updateUser(User user);} |
|
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
|
@Service@Transactionalpublic class UserServiceImpl implements UserService { @Autowired private UserDao userDao; @Override @Transactional(readOnly = true) public User getById(int id) { return userDao.getById(id); } @Override @Transactional(readOnly = true) public User getByNumber(String number) { return userDao.getByNumber(number); } @Override public int addUser(User user,boolean throwEx) { int id= this.userDao.addUser(user); if(throwEx){ throw new RuntimeException("throw a ex"); } return id; } @Override public void deleteUserById(int id) { this.userDao.deleteUserById(id); } @Override public User updateUser(User user) { return this.userDao.updateUser(user); }} |
6.controller層
|
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
|
@Controller("user1")@RequestMapping("/jpa/user")public class UserController { /** * 日志（slf4j->logback） */ private static final Logger logger = LoggerFactory.getLogger(UserController.class); @Autowired private UserService userService; /** * 返回text格式數(shù)據(jù) * @param id 主鍵id * @return 用戶json字符串 */ @RequestMapping("/get/id/{id}") @ResponseBody public String getUserById(@PathVariable("id")String id){ logger.info("request /user/get/id/{id}, parameter is "+id); User user = userService.getById(Integer.parseInt(id)); return JSONObject.toJSONString(user); } /** * 返回json格式數(shù)據(jù) * @param number 編號(hào) * @return 用戶 */ @RequestMapping("/get/number/{number}") @ResponseBody public User getUserByNumber(@PathVariable("number")String number){ User user = userService.getByNumber(number); return user; } @RequestMapping("/add/{number}/{name}") @ResponseBody public String addUser(@PathVariable("number")String number,@PathVariable("name")String name,boolean throwEx){ User user = new User(); user.setNumber(number); user.setName(name); int id = -1; try{ id = userService.addUser(user,throwEx); }catch (RuntimeException ex){ System.out.println(ex.getMessage()); } return String.valueOf(id); } @RequestMapping("/delete/{id}") @ResponseBody public void getUserById(@PathVariable("id")int id){ this.userService.deleteUserById(id); } @RequestMapping("/update/{id}/{number}/{name}") @ResponseBody public User addUser(@PathVariable("id")int id, @PathVariable("number")String number, @PathVariable("name")String name){ User user = new User(); user.setId(id); user.setNumber(number); user.setName(name); return userService.updateUser(user); }} |
7. spring data jpa新使用方式，更高級(jí)
|
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
1.dao@Repositorypublic interface UserRepository extends JpaRepository<User, Integer> { /** * spring data jpa 會(huì)自動(dòng)注入實(shí)現(xiàn)（根據(jù)方法命名規(guī)范） * @return */ User findByNumber(String number); @Modifying @Query("delete from User u where u.id = :id") void deleteUser(@Param("id")int id);}2.servicepublic interface UserService { User findById(int id); User findByNumber(String number); List<User> findAllUserByPage(int page,int size); User updateUser(User user,boolean throwEx); void deleteUser(int id);}@Service@Transactionalpublic class UserServiceImpl implements UserService { @Autowired private UserRepository userRepository; @Override public User findById(int id) { return this.userRepository.findOne(id); } @Override public User findByNumber(String number) { return this.userRepository.findByNumber(number); } @Override public List<User> findAllUserByPage(int page,int size) { Pageable pageable = new PageRequest(page, size); Page<User> users = this.userRepository.findAll(pageable); return users.getContent(); } @Override public User updateUser(User user,boolean throwEx) { User userNew = this.userRepository.save(user); if(throwEx){ throw new RuntimeException("throw a ex"); } return userNew; } @Override public void deleteUser(int id) { this.userRepository.deleteUser(id); }}3.controller@Controller("user2")@RequestMapping("/datajpa/user")public class UserController { /** * 日志（slf4j->logback） */ private static final Logger logger = LoggerFactory.getLogger(UserController.class); @Autowired private UserService userService; /** * 返回text格式數(shù)據(jù) * @param id 主鍵id * @return 用戶json字符串 */ @RequestMapping("/get/id/{id}") @ResponseBody public String getUserById(@PathVariable("id")String id){ logger.info("request /user/get/id/{id}, parameter is "+id); User user = userService.findById(Integer.parseInt(id)); return JSONObject.toJSONString(user); } /** * 返回json格式數(shù)據(jù) * @param number 編號(hào) * @return 用戶 */ @RequestMapping("/get/number/{number}") @ResponseBody public User getUserByNumber(@PathVariable("number")String number){ User user = userService.findByNumber(number); return user; } @RequestMapping("/get/all/{page}/{size}") @ResponseBody public List<User> getAllUserByPage(@PathVariable("page")int page,@PathVariable("size")int size){ return this.userService.findAllUserByPage(page,size); } @RequestMapping("/update/{id}/{number}/{name}") @ResponseBody public User addUser(@PathVariable("id")int id, @PathVariable("number")String number, @PathVariable("name")String name,boolean throwEx){ User user = new User(); user.setId(id); user.setNumber(number); user.setName(name); User userNew = null; try{ userService.updateUser(user,throwEx); }catch (RuntimeException ex){ System.out.println(ex.getMessage()); } return userNew; } @RequestMapping("/delete/{id}") @ResponseBody public void getUserById(@PathVariable("id")int id){ this.userService.deleteUser(id); }} |
8.注入jdbcTemplate和transactionTemplate,使用傳統(tǒng)方式操作數(shù)據(jù)庫，更加靈活，方法如下
|
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
|
@Autowired private JdbcTemplate jdbcTemplate; @Autowired private TransactionTemplate transactionTemplate; /** * 手動(dòng)控制事物測(cè)試 * @param throwEx */ @Override public void testTransactionManually(boolean throwEx) { try { transactionTemplate.execute(new TransactionCallback<Boolean>() { /** * 事物代碼 * * @param transactionStatus 事物狀態(tài) * @return 是否成功 */ @Override public Boolean doInTransaction(TransactionStatus transactionStatus) { User user = new User(); user.setId(1); int a = new Random().nextInt(10); //0-9 user.setNumber("10000u" + a); jdbcTemplate.update("UPDATE USER SET NUMBER=? WHERE ID=?", new Object[]{user.getNumber(), user.getId()}, new int[]{Types.VARCHAR, Types.INTEGER}); if (throwEx) { throw new RuntimeException("try throw exception"); //看看會(huì)不會(huì)回滾 } return true; } }); }catch (RuntimeException ex){ System.out.println(ex.getMessage()); } } /** * 手動(dòng)執(zhí)行jdbc測(cè)試 */ @Override public void testJdbcTemplate() { User user = new User(); int a = new Random().nextInt(10); //0-9 user.setNumber("10000i"+ a ); user.setName("name"+a); this.jdbcTemplate.update("INSERT into USER(NUMBER,NAME )VALUES (?,?)",user.getNumber(),user.getName()); } |
至此，我已經(jīng)講了三種方式（jpa兩種+jdbcTemplate）如何操作數(shù)據(jù)庫了，你愛怎么用就怎么用，上述代碼均是實(shí)踐證明可行的！
以上這篇基于spring boot 1.5.4 集成 jpa+hibernate+jdbcTemplate(詳解)就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持服務(wù)器之家。
