1 package org.apache.fulcrum.security.torque.basic;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 import java.sql.Connection;
21 import java.util.List;
22
23 import org.apache.fulcrum.security.entity.User;
24 import org.apache.fulcrum.security.torque.TorqueAbstractUserManager;
25 import org.apache.fulcrum.security.torque.om.TorqueBasicUserPeer;
26 import org.apache.torque.NoRowsException;
27 import org.apache.torque.TooManyRowsException;
28 import org.apache.torque.TorqueException;
29 import org.apache.torque.criteria.Criteria;
30
31
32
33
34
35
36
37 public class TorqueBasicUserManagerImpl extends TorqueAbstractUserManager
38 {
39
40
41
42 private static final long serialVersionUID = 1L;
43
44
45
46
47 @SuppressWarnings("unchecked")
48 protected <T extends User> List<T> doSelectAllUsers(Connection con) throws TorqueException
49 {
50 Criteria criteria = new Criteria(TorqueBasicUserPeer.DATABASE_NAME);
51
52 return (List<T>)TorqueBasicUserPeer.doSelect(criteria, con);
53 }
54
55
56
57
58 @SuppressWarnings("unchecked")
59 protected <T extends User> T doSelectById(Integer id, Connection con) throws NoRowsException, TooManyRowsException, TorqueException
60 {
61 return (T) TorqueBasicUserPeer.retrieveByPK(id, con);
62 }
63
64
65
66
67 @SuppressWarnings("unchecked")
68 protected <T extends User> T doSelectByName(String name, Connection con) throws NoRowsException, TooManyRowsException, TorqueException
69 {
70 Criteria criteria = new Criteria(TorqueBasicUserPeer.DATABASE_NAME);
71 criteria.where(TorqueBasicUserPeer.LOGIN_NAME, name);
72 criteria.setIgnoreCase(true);
73 criteria.setSingleRecord(true);
74
75 T t = (T)TorqueBasicUserPeer.doSelectSingleRecord(criteria, con);
76 if (t == null)
77 {
78 throw new NoRowsException(name);
79 }
80
81 return t;
82 }
83 }