summaryrefslogtreecommitdiff
path: root/spring-framework/07-user-jdbc-ds-transaction/src/main/java/com/example/fp/tx/TxUserManager.java
blob: 4bb6d0534d1dc226506ad0717f11962a8e87b6fe (plain)
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
package com.example.fp.tx;

import java.util.List;

import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

import com.example.fp.User;
import com.example.fp.UserManager;

/**
 * This class decorates a given AccountManager by adding transaction boundaries.
 * 
 * @author kamal
 *
 */
public class TxUserManager implements UserManager {

	private UserManager userManager;

	public void setUserManager(UserManager userManager) {
		this.userManager = userManager;
	}

	private TransactionTemplate txTemplate;

	public void setTxManager(DataSourceTransactionManager txManager) {
		txTemplate = new TransactionTemplate(txManager);
	}

	
	@Override
	public User find(int uid) {
		return userManager.find(uid);
	}


	@Override
	public void delete(int uid) {
		txTemplate.execute(new TransactionCallbackWithoutResult() {

			@Override
			protected void doInTransactionWithoutResult(TransactionStatus arg0) {
				userManager.delete(uid);
			}
		});
	}

	@Override
	public void create(User user) {
		txTemplate.execute(new TransactionCallbackWithoutResult() {

			@Override
			protected void doInTransactionWithoutResult(TransactionStatus arg0) {
				userManager.create(user);
			}
		});		
	}

	@Override
	public List<User> findAll() {
		return userManager.findAll();
	}

	@Override
	public void update(User user) {
		txTemplate.execute(new TransactionCallbackWithoutResult() {

			@Override
			protected void doInTransactionWithoutResult(TransactionStatus arg0) {
				userManager.update(user);
			}
		});
	}

	@Override
	public void setPassword(int uid, String plainTextPassword) {
		txTemplate.execute(new TransactionCallbackWithoutResult() {

			@Override
			protected void doInTransactionWithoutResult(TransactionStatus arg0) {
				userManager.setPassword(uid, plainTextPassword);
			}
		});
	}
}