|
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
12 import org.mvnforum.phpbb2mvnforum.db.PhpbbPrivmMsgs;
13 import org.mvnforum.phpbb2mvnforum.db.PhpbbPrivmMsgsDAO;
14 import org.mvnforum.util.DBUtils;
15
16 public class PhpbbPrivmMsgsDAOImpl implements PhpbbPrivmMsgsDAO {
17
18
24 public Collection getBeans()
25 throws DatabaseException {
26
27 Connection connection = null;
28 PreparedStatement statement = null;
29 ResultSet resultSet = null;
30 Collection retValue = new ArrayList ();
31 StringBuffer sql = new StringBuffer (512);
32 sql
33 .append("SELECT privmsgs_id, privmsgs_type, privmsgs_subject, privmsgs_from_userid, privmsgs_to_userid, privmsgs_date, privmsgs_ip, privmsgs_enable_bbcode, privmsgs_enable_html, privmsgs_enable_smilies, privmsgs_attach_sig");
34 sql.append(" FROM " + TABLE_NAME);
35 try {
38 connection = DBUtils.getPhpbbConnection();
39 statement = connection.prepareStatement(sql.toString());
40 resultSet = statement.executeQuery();
41 while (resultSet.next()) {
42 PhpbbPrivmMsgs bean = new PhpbbPrivmMsgs();
43 bean.setprivmsgs_id(resultSet.getInt("privmsgs_id"));
44 bean.setprivmsgs_type(resultSet.getInt("privmsgs_type"));
45 bean.setprivmsgs_subject(resultSet.getString("privmsgs_subject"));
46 bean.setprivmsgs_from_userid(resultSet.getInt("privmsgs_from_userid"));
47 bean.setprivmsgs_to_userid(resultSet.getInt("privmsgs_to_userid"));
48 bean.setprivmsgs_date(resultSet.getInt("privmsgs_date"));
49 bean.setprivmsgs_ip(resultSet.getString("privmsgs_ip"));
50 bean.setprivmsgs_enable_bbcode(resultSet.getInt("privmsgs_enable_bbcode"));
51 bean.setprivmsgs_enable_html(resultSet.getInt("privmsgs_enable_html"));
52 bean.setprivmsgs_enable_smilies(resultSet.getInt("privmsgs_enable_smilies"));
53 bean.setprivmsgs_attach_sig(resultSet.getInt("privmsgs_attach_sig"));
54 retValue.add(bean);
55 }
56 return retValue;
57 } catch (SQLException sqle) {
58 throw new DatabaseException("Error executing SQL in phpbb_privmsgsDAOImplJDBC.getBeans.");
59 } finally {
60 DBUtils.closeResultSet(resultSet);
61 DBUtils.closeStatement(statement);
62 DBUtils.closeConnection(connection);
63 }
64 }
65
66 public Collection getBeansBySenderID(int senderID)
67 throws DatabaseException {
68 Connection connection = null;
70 PreparedStatement statement = null;
71 ResultSet resultSet = null;
72 Collection retValue = new ArrayList ();
73 StringBuffer sql = new StringBuffer (512);
74 sql
75 .append("SELECT privmsgs_id, privmsgs_type, privmsgs_subject, privmsgs_from_userid, privmsgs_to_userid, privmsgs_date, privmsgs_ip, privmsgs_enable_bbcode, privmsgs_enable_html, privmsgs_enable_smilies, privmsgs_attach_sig");
76 sql.append(" FROM " + TABLE_NAME);
77 sql.append(" WHERE privmsgs_from_userid=?"); try {
80 connection = DBUtils.getPhpbbConnection();
81 statement = connection.prepareStatement(sql.toString());
82 statement.setInt(1, senderID);
83 resultSet = statement.executeQuery();
84 while (resultSet.next()) {
85 PhpbbPrivmMsgs bean = new PhpbbPrivmMsgs();
86 bean.setprivmsgs_id(resultSet.getInt("privmsgs_id"));
87 bean.setprivmsgs_type(resultSet.getInt("privmsgs_type"));
88 bean.setprivmsgs_subject(resultSet.getString("privmsgs_subject"));
89 bean.setprivmsgs_from_userid(resultSet.getInt("privmsgs_from_userid"));
90 bean.setprivmsgs_to_userid(resultSet.getInt("privmsgs_to_userid"));
91 bean.setprivmsgs_date(resultSet.getInt("privmsgs_date"));
92 bean.setprivmsgs_ip(resultSet.getString("privmsgs_ip"));
93 bean.setprivmsgs_enable_bbcode(resultSet.getInt("privmsgs_enable_bbcode"));
94 bean.setprivmsgs_enable_html(resultSet.getInt("privmsgs_enable_html"));
95 bean.setprivmsgs_enable_smilies(resultSet.getInt("privmsgs_enable_smilies"));
96 bean.setprivmsgs_attach_sig(resultSet.getInt("privmsgs_attach_sig"));
97 retValue.add(bean);
98 }
99 return retValue;
100 } catch (SQLException sqle) {
101 throw new DatabaseException("Error executing SQL in phpbb_privmsgsDAOImplJDBC.getBeans.");
102 } finally {
103 DBUtils.closeResultSet(resultSet);
104 DBUtils.closeStatement(statement);
105 DBUtils.closeConnection(connection);
106 }
107 }
108
109 public Collection getBeansByReceiverID(int receiverID)
110 throws DatabaseException {
111 Connection connection = null;
113 PreparedStatement statement = null;
114 ResultSet resultSet = null;
115 Collection retValue = new ArrayList ();
116 StringBuffer sql = new StringBuffer (512);
117 sql
118 .append("SELECT privmsgs_id, privmsgs_type, privmsgs_subject, privmsgs_from_userid, privmsgs_to_userid, privmsgs_date, privmsgs_ip, privmsgs_enable_bbcode, privmsgs_enable_html, privmsgs_enable_smilies, privmsgs_attach_sig");
119 sql.append(" FROM " + TABLE_NAME);
120 sql.append(" WHERE privmsgs_to_userid=?"); try {
123 connection = DBUtils.getPhpbbConnection();
124 statement = connection.prepareStatement(sql.toString());
125 statement.setInt(1, receiverID);
126 resultSet = statement.executeQuery();
127 while (resultSet.next()) {
128 PhpbbPrivmMsgs bean = new PhpbbPrivmMsgs();
129 bean.setprivmsgs_id(resultSet.getInt("privmsgs_id"));
130 bean.setprivmsgs_type(resultSet.getInt("privmsgs_type"));
131 bean.setprivmsgs_subject(resultSet.getString("privmsgs_subject"));
132 bean.setprivmsgs_from_userid(resultSet.getInt("privmsgs_from_userid"));
133 bean.setprivmsgs_to_userid(resultSet.getInt("privmsgs_to_userid"));
134 bean.setprivmsgs_date(resultSet.getInt("privmsgs_date"));
135 bean.setprivmsgs_ip(resultSet.getString("privmsgs_ip"));
136 bean.setprivmsgs_enable_bbcode(resultSet.getInt("privmsgs_enable_bbcode"));
137 bean.setprivmsgs_enable_html(resultSet.getInt("privmsgs_enable_html"));
138 bean.setprivmsgs_enable_smilies(resultSet.getInt("privmsgs_enable_smilies"));
139 bean.setprivmsgs_attach_sig(resultSet.getInt("privmsgs_attach_sig"));
140 retValue.add(bean);
141 }
142 return retValue;
143 } catch (SQLException sqle) {
144 throw new DatabaseException("Error executing SQL in phpbb_privmsgsDAOImplJDBC.getBeans.");
145 } finally {
146 DBUtils.closeResultSet(resultSet);
147 DBUtils.closeStatement(statement);
148 DBUtils.closeConnection(connection);
149 }
150 }
151
152 public Collection getBeansByType(int privmsgsType, int memberID)
153 throws DatabaseException {
154 Connection connection = null;
155 PreparedStatement statement = null;
156 ResultSet resultSet = null;
157 Collection retValue = new ArrayList ();
158 StringBuffer sql = new StringBuffer (512);
159 sql
160 .append("SELECT privmsgs_id, privmsgs_type, privmsgs_subject, privmsgs_from_userid, privmsgs_to_userid, privmsgs_date, privmsgs_ip, privmsgs_enable_bbcode, privmsgs_enable_html, privmsgs_enable_smilies, privmsgs_attach_sig");
161 sql.append(" FROM " + TABLE_NAME);
162 sql.append(" WHERE privmsgs_type=? and privmsgs_to_userid=?"); try {
165 connection = DBUtils.getPhpbbConnection();
166 statement = connection.prepareStatement(sql.toString());
167 statement.setInt(1, privmsgsType);
168 statement.setInt(2, memberID);
169 resultSet = statement.executeQuery();
170 while (resultSet.next()) {
171 PhpbbPrivmMsgs bean = new PhpbbPrivmMsgs();
172 bean.setprivmsgs_id(resultSet.getInt("privmsgs_id"));
173 bean.setprivmsgs_type(resultSet.getInt("privmsgs_type"));
174 bean.setprivmsgs_subject(resultSet.getString("privmsgs_subject"));
175 bean.setprivmsgs_from_userid(resultSet.getInt("privmsgs_from_userid"));
176 bean.setprivmsgs_to_userid(resultSet.getInt("privmsgs_to_userid"));
177 bean.setprivmsgs_date(resultSet.getInt("privmsgs_date"));
178 bean.setprivmsgs_ip(resultSet.getString("privmsgs_ip"));
179 bean.setprivmsgs_enable_bbcode(resultSet.getInt("privmsgs_enable_bbcode"));
180 bean.setprivmsgs_enable_html(resultSet.getInt("privmsgs_enable_html"));
181 bean.setprivmsgs_enable_smilies(resultSet.getInt("privmsgs_enable_smilies"));
182 bean.setprivmsgs_attach_sig(resultSet.getInt("privmsgs_attach_sig"));
183 retValue.add(bean);
184 }
185 return retValue;
186 } catch (SQLException sqle) {
187 throw new DatabaseException("Error executing SQL in phpbb_privmsgsDAOImplJDBC.getBeans.");
188 } finally {
189 DBUtils.closeResultSet(resultSet);
190 DBUtils.closeStatement(statement);
191 DBUtils.closeConnection(connection);
192 }
193 }
194
195 public Collection getBeansByTypeAndReceiveUser(int privmsgsType, int memberID)
196 throws DatabaseException {
197 Connection connection = null;
199 PreparedStatement statement = null;
200 ResultSet resultSet = null;
201 Collection retValue = new ArrayList ();
202 StringBuffer sql = new StringBuffer (512);
203 sql
204 .append("SELECT privmsgs_id, privmsgs_type, privmsgs_subject, privmsgs_from_userid, privmsgs_to_userid, privmsgs_date, privmsgs_ip, privmsgs_enable_bbcode, privmsgs_enable_html, privmsgs_enable_smilies, privmsgs_attach_sig");
205 sql.append(" FROM " + TABLE_NAME);
206 sql.append(" WHERE privmsgs_type=? and privmsgs_from_userid=?"); try {
209 connection = DBUtils.getPhpbbConnection();
210 statement = connection.prepareStatement(sql.toString());
211 statement.setInt(1, privmsgsType);
212 statement.setInt(2, memberID);
213 resultSet = statement.executeQuery();
214 while (resultSet.next()) {
215 PhpbbPrivmMsgs bean = new PhpbbPrivmMsgs();
216 bean.setprivmsgs_id(resultSet.getInt("privmsgs_id"));
217 bean.setprivmsgs_type(resultSet.getInt("privmsgs_type"));
218 bean.setprivmsgs_subject(resultSet.getString("privmsgs_subject"));
219 bean.setprivmsgs_from_userid(resultSet.getInt("privmsgs_from_userid"));
220 bean.setprivmsgs_to_userid(resultSet.getInt("privmsgs_to_userid"));
221 bean.setprivmsgs_date(resultSet.getInt("privmsgs_date"));
222 bean.setprivmsgs_ip(resultSet.getString("privmsgs_ip"));
223 bean.setprivmsgs_enable_bbcode(resultSet.getInt("privmsgs_enable_bbcode"));
224 bean.setprivmsgs_enable_html(resultSet.getInt("privmsgs_enable_html"));
225 bean.setprivmsgs_enable_smilies(resultSet.getInt("privmsgs_enable_smilies"));
226 bean.setprivmsgs_attach_sig(resultSet.getInt("privmsgs_attach_sig"));
227 retValue.add(bean);
228 }
229 return retValue;
230 } catch (SQLException sqle) {
231 throw new DatabaseException("Error executing SQL in phpbb_privmsgsDAOImplJDBC.getBeans.");
232 } finally {
233 DBUtils.closeResultSet(resultSet);
234 DBUtils.closeStatement(statement);
235 DBUtils.closeConnection(connection);
236 }
237 }
238 }
239 |
Popular Tags |
Java API By Example, From Geeks To Geeks.