|
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.PhpbbUserGroup;
13 import org.mvnforum.phpbb2mvnforum.db.PhpbbUserGroupDAO;
14 import org.mvnforum.util.DBUtils;
15
16 public class PhpbbUserGroupDAOImpl implements PhpbbUserGroupDAO {
17
18 public Collection getBeansByGroupID(int groupID) throws DatabaseException {
19 Connection connection = null;
21 PreparedStatement statement = null;
22 ResultSet resultSet = null;
23 Collection retValue = new ArrayList ();
24 StringBuffer sql = new StringBuffer (512);
25 sql.append("SELECT group_id, user_id, user_pending");
26 sql.append(" FROM " + TABLE_NAME);
27 sql.append(" WHERE group_id=?");
28 try {
30 connection = DBUtils.getPhpbbConnection();
31 statement = connection.prepareStatement(sql.toString());
32 statement.setInt(1, groupID);
33 resultSet = statement.executeQuery();
34 while (resultSet.next()) {
35 PhpbbUserGroup bean = new PhpbbUserGroup();
36 bean.setgroup_id(resultSet.getInt("group_id"));
37 bean.setuser_id(resultSet.getInt("user_id"));
38 bean.setuser_pending(resultSet.getInt("user_pending"));
39 retValue.add(bean);
40 }
41 return retValue;
42 } catch(SQLException sqle) {
43 throw new DatabaseException("Error executing SQL in phpbb_user_groupDAOImplJDBC.getBeans.");
44 } finally {
45 DBUtils.closeResultSet(resultSet);
46 DBUtils.closeStatement(statement);
47 DBUtils.closeConnection(connection);
48 }
49 }
50
51 }
52 |
Popular Tags |
Java API By Example, From Geeks To Geeks.