1 package org.mvnforum.phpbb2mvnforum.db.jdbc; 2 3 import java.sql.Connection ; 4 import java.sql.PreparedStatement ; 5 import java.sql.ResultSet ; 6 import java.sql.SQLException ; 7 import java.util.ArrayList ; 8 import java.util.Collection ; 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 TABLE_NAME = "phpbb_users"; 20 21 public String getUserNameFromUserID (int userID) throws ObjectNotFoundException, DatabaseException { 22 23 Connection connection = null; 24 PreparedStatement statement = null; 25 ResultSet resultSet = null; 26 27 StringBuffer sql = new StringBuffer (512); 28 sql.append("SELECT username"); 29 sql.append(" FROM " + TABLE_NAME); 30 sql.append(" WHERE user_id = ?"); 31 32 String 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 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 67 public Collection getBeans() throws DatabaseException { 68 69 Connection connection = null; 70 PreparedStatement statement = null; 71 ResultSet resultSet = null; 72 Collection retValue = new ArrayList (); 73 StringBuffer sql = new StringBuffer (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 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 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 |