KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > mvnforum > phpbb2mvnforum > db > jdbc > PhpbbUserDAOImpl


1 package org.mvnforum.phpbb2mvnforum.db.jdbc;
2
3 import java.sql.Connection JavaDoc;
4 import java.sql.PreparedStatement JavaDoc;
5 import java.sql.ResultSet JavaDoc;
6 import java.sql.SQLException JavaDoc;
7 import java.util.ArrayList JavaDoc;
8 import java.util.Collection JavaDoc;
9
10 import net.myvietnam.mvncore.exception.DatabaseException;
11 import net.myvietnam.mvncore.exception.ObjectNotFoundException;
12
13 import org.mvnforum.phpbb2mvnforum.db.PhpbbUserDAO;
14 import org.mvnforum.phpbb2mvnforum.db.PhpbbUsers;
15 import org.mvnforum.util.DBUtils;
16
17 public class PhpbbUserDAOImpl implements PhpbbUserDAO{
18     
19     public static String JavaDoc TABLE_NAME = "phpbb_users";
20     
21     public String JavaDoc getUserNameFromUserID (int userID) throws ObjectNotFoundException, DatabaseException {
22         
23         Connection JavaDoc connection = null;
24         PreparedStatement JavaDoc statement = null;
25         ResultSet JavaDoc resultSet = null;
26
27         StringBuffer JavaDoc sql = new StringBuffer JavaDoc(512);
28         sql.append("SELECT username");
29         sql.append(" FROM " + TABLE_NAME);
30         sql.append(" WHERE user_id = ?");
31         
32         String JavaDoc memName = "";
33         
34         try {
35             connection = DBUtils.getPhpbbConnection();
36             statement = connection.prepareStatement(sql.toString());
37             statement.setInt(1, userID);
38             resultSet = statement.executeQuery();
39             if (!resultSet.next()) {
40                 throw new ObjectNotFoundException("Cannot find user [userID] (" + userID
41                         + ") in table 'phpbb_users'.");
42             }
43             memName = resultSet.getString("username");
44         } catch (SQLException JavaDoc sqle) {
45             sqle.printStackTrace();
46             throw new DatabaseException("Error executing SQL in PhpbbUserDAOImpl.getUserNameFromUserID");
47         } finally {
48             DBUtils.closeResultSet(resultSet);
49             DBUtils.closeStatement(statement);
50             DBUtils.closeConnection(connection);
51         }
52         return memName;
53     }
54     
55     /*
56      * Included columns: user_id, user_active, username, user_password, user_session_time,
57      * user_session_page, user_lastvisit, user_regdate, user_level, user_posts,
58      * user_timezone, user_style, user_lang, user_dateformat, user_new_privmsg,
59      * user_unread_privmsg, user_last_privmsg, user_emailtime, user_viewemail, user_attachsig,
60      * user_allowhtml, user_allowbbcode, user_allowsmile, user_allowavatar, user_allow_pm,
61      * user_allow_viewonline, user_notify, user_notify_pm, user_popup_pm, user_rank,
62      * user_avatar, user_avatar_type, user_email, user_icq, user_website,
63      * user_from, user_sig, user_sig_bbcode_uid, user_aim, user_yim,
64      * user_msnm, user_occ, user_interests, user_actkey, user_newpasswd
65      * Excluded columns:
66      */

67     public Collection JavaDoc getBeans() throws DatabaseException {
68
69         Connection JavaDoc connection = null;
70         PreparedStatement JavaDoc statement = null;
71         ResultSet JavaDoc resultSet = null;
72         Collection JavaDoc retValue = new ArrayList JavaDoc();
73         StringBuffer JavaDoc sql = new StringBuffer JavaDoc(512);
74         sql.append("SELECT user_id, user_active, username, user_password, user_session_time, user_session_page, user_lastvisit, user_regdate, user_level, user_posts, user_timezone, user_style, user_lang, user_dateformat, user_new_privmsg, user_unread_privmsg, user_last_privmsg, user_emailtime, user_viewemail, user_attachsig, user_allowhtml, user_allowbbcode, user_allowsmile, user_allowavatar, user_allow_pm, user_allow_viewonline, user_notify, user_notify_pm, user_popup_pm, user_rank, user_avatar, user_avatar_type, user_email, user_icq, user_website, user_from, user_sig, user_sig_bbcode_uid, user_aim, user_yim, user_msnm, user_occ, user_interests, user_actkey, user_newpasswd");
75         sql.append(" FROM " + TABLE_NAME);
76         //sql.append(" WHERE "); // @todo: uncomment as needed
77
//sql.append(" ORDER BY ColumnName ASC|DESC "); // @todo: uncomment as needed
78
try {
79             connection = DBUtils.getPhpbbConnection();
80             statement = connection.prepareStatement(sql.toString());
81             resultSet = statement.executeQuery();
82             while (resultSet.next()) {
83                 PhpbbUsers bean = new PhpbbUsers();
84                 bean.setUserId(resultSet.getInt("user_id"));
85                 bean.setUserActive(resultSet.getInt("user_active"));
86                 bean.setUsername(resultSet.getString("username"));
87                 bean.setUserPassword(resultSet.getString("user_password"));
88                 bean.setUserSessionTime(resultSet.getLong("user_session_time"));
89                 bean.setUserSessionPage(resultSet.getInt("user_session_page"));
90                 bean.setUserLastvisit(resultSet.getLong("user_lastvisit"));
91                 bean.setUserRegdate(resultSet.getLong("user_regdate"));
92                 bean.setUserLevel(resultSet.getInt("user_level"));
93                 bean.setUserPosts(resultSet.getInt("user_posts"));
94                 bean.setUserTimezone(resultSet.getBigDecimal("user_timezone"));
95                 bean.setUserStyle(resultSet.getInt("user_style"));
96                 bean.setUserLang(resultSet.getString("user_lang"));
97                 bean.setUserDateformat(resultSet.getString("user_dateformat"));
98                 bean.setUserNewPrivmsg(resultSet.getInt("user_new_privmsg"));
99                 bean.setUserUnreadPrivmsg(resultSet.getInt("user_unread_privmsg"));
100                 bean.setUserLastPrivmsg(resultSet.getLong("user_last_privmsg"));
101                 bean.setUserEmailtime(resultSet.getInt("user_emailtime"));
102                 bean.setUserViewemail(resultSet.getInt("user_viewemail"));
103                 bean.setUserAttachsig(resultSet.getInt("user_attachsig"));
104                 bean.setUserAllowhtml(resultSet.getInt("user_allowhtml"));
105                 bean.setUserAllowbbcode(resultSet.getInt("user_allowbbcode"));
106                 bean.setUserAllowsmile(resultSet.getInt("user_allowsmile"));
107                 bean.setUserAllowavatar(resultSet.getInt("user_allowavatar"));
108                 bean.setUserAllowPm(resultSet.getInt("user_allow_pm"));
109                 bean.setUserAllowViewonline(resultSet.getInt("user_allow_viewonline"));
110                 bean.setUserNotify(resultSet.getInt("user_notify"));
111                 bean.setUserNotifyPm(resultSet.getInt("user_notify_pm"));
112                 bean.setUserPopupPm(resultSet.getInt("user_popup_pm"));
113                 bean.setUserRank(resultSet.getInt("user_rank"));
114                 bean.setUserAvatar(resultSet.getString("user_avatar"));
115                 bean.setUserAvatarType(resultSet.getInt("user_avatar_type"));
116                 bean.setUserEmail(resultSet.getString("user_email"));
117                 bean.setUserIcq(resultSet.getString("user_icq"));
118                 bean.setUserWebsite(resultSet.getString("user_website"));
119                 bean.setUserFrom(resultSet.getString("user_from"));
120                 bean.setUserSig(resultSet.getString("user_sig"));
121                 bean.setUserSigBbcodeUid(resultSet.getString("user_sig_bbcode_uid"));
122                 bean.setUserAim(resultSet.getString("user_aim"));
123                 bean.setUserYim(resultSet.getString("user_yim"));
124                 bean.setUserMsnm(resultSet.getString("user_msnm"));
125                 bean.setUserOcc(resultSet.getString("user_occ"));
126                 bean.setUserInterests(resultSet.getString("user_interests"));
127                 bean.setUserActkey(resultSet.getString("user_actkey"));
128                 bean.setUserNewpasswd(resultSet.getString("user_newpasswd"));
129                 retValue.add(bean);
130             }
131             return retValue;
132         } catch(SQLException JavaDoc sqle) {
133             throw new DatabaseException("Error executing SQL in phpbb_usersDAOImplJDBC.getBeans.");
134         } finally {
135             DBUtils.closeResultSet(resultSet);
136             DBUtils.closeStatement(statement);
137             DBUtils.closeConnection(connection);
138         }
139     }
140
141     
142     
143 }
144
Popular Tags