1 package com.melloware.jukes.db.audit;
2
3 import java.io.Serializable;
4 import java.util.Date;
5 import java.util.Iterator;
6
7 import org.apache.commons.lang.StringUtils;
8 import org.apache.commons.lang.SystemUtils;
9 import org.apache.commons.logging.Log;
10 import org.apache.commons.logging.LogFactory;
11 import org.hibernate.CallbackException;
12 import org.hibernate.EntityMode;
13 import org.hibernate.Interceptor;
14 import org.hibernate.Transaction;
15 import org.hibernate.type.Type;
16
17
18
19
20
21
22
23
24
25
26 public class AuditInterceptor
27 implements Interceptor,
28 Serializable {
29
30 private static final Log LOG = LogFactory.getLog(AuditInterceptor.class);
31 private final String user;
32
33
34
35
36 public AuditInterceptor() {
37 super();
38 LOG.info("AuditInterceptor is created.");
39 user = StringUtils.defaultIfEmpty(SystemUtils.USER_NAME, "java");
40 }
41
42
43
44
45 public Object getEntity(String arg0, Serializable arg1)
46 throws CallbackException {
47 return null;
48 }
49
50
51
52
53 public String getEntityName(Object arg0)
54 throws CallbackException {
55 return null;
56 }
57
58
59
60
61 public Boolean isTransient(Object arg0) {
62 return null;
63 }
64
65
66
67
68 public void afterTransactionBegin(Transaction arg0) {
69
70
71 }
72
73
74
75
76 public void afterTransactionCompletion(Transaction arg0) {
77
78
79 }
80
81
82
83
84 public void beforeTransactionCompletion(Transaction arg0) {
85
86
87 }
88
89
90
91
92
93 public int[] findDirty(Object arg0, Serializable arg1, Object[] arg2, Object[] arg3, String[] arg4, Type[] arg5) {
94 return null;
95 }
96
97
98
99
100 public Object instantiate(String arg0, EntityMode arg1, Serializable arg2)
101 throws CallbackException {
102 return null;
103 }
104
105
106
107
108 public void onCollectionRecreate(Object arg0, Serializable arg1)
109 throws CallbackException {
110
111
112 }
113
114
115
116
117 public void onCollectionRemove(Object arg0, Serializable arg1)
118 throws CallbackException {
119
120 }
121
122
123
124
125 public void onCollectionUpdate(Object arg0, Serializable arg1)
126 throws CallbackException {
127
128
129 }
130
131
132
133
134
135 public void onDelete(Object arg0, Serializable arg1, Object[] arg2, String[] arg3, Type[] arg4)
136 throws CallbackException {
137
138
139 }
140
141 public boolean onFlushDirty(Object entity,
142 Serializable id,
143 Object[] currentState,
144 Object[] previousState,
145 String[] propertyNames,
146 Type[] types)
147 throws CallbackException {
148
149 boolean result = false;
150
151 if (entity instanceof Auditable) {
152 for (int i = 0; i < propertyNames.length; i++) {
153 if ("modifiedUser".equals(propertyNames[i])) {
154 currentState[i] = this.user;
155 result = true;
156 }
157 }
158 }
159 return result;
160 }
161
162
163
164
165
166 public boolean onLoad(Object arg0, Serializable arg1, Object[] arg2, String[] arg3, Type[] arg4)
167 throws CallbackException {
168 return false;
169 }
170
171
172
173
174 public String onPrepareStatement(String arg0) {
175 return arg0;
176 }
177
178 public boolean onSave(Object entity, Serializable id, Object[] state, String[] propertyNames, Type[] types)
179 throws CallbackException {
180
181 boolean result = false;
182
183 if (entity instanceof Auditable) {
184 for (int i = 0; i < propertyNames.length; i++) {
185 if ("createdUser".equals(propertyNames[i])) {
186 state[i] = this.user;
187 result = true;
188 }
189 if ("modifiedUser".equals(propertyNames[i])) {
190 state[i] = this.user;
191 result = true;
192 }
193 if (("createdDate".equals(propertyNames[i])) && (state[i] == null)) {
194 state[i] = new Date();
195 result = true;
196 }
197 if ("modifiedDate".equals(propertyNames[i])) {
198 state[i] = new Date();
199 result = true;
200 }
201 }
202 }
203 return result;
204 }
205
206
207
208
209 public void postFlush(Iterator arg0)
210 throws CallbackException {
211
212
213 }
214
215
216
217
218 public void preFlush(Iterator arg0)
219 throws CallbackException {
220
221
222 }
223
224 }