KickJava   Java API By Example, From Geeks To Geeks.

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


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
12 import org.mvnforum.phpbb2mvnforum.db.PhpbbCategories;
13 import org.mvnforum.phpbb2mvnforum.db.PhpbbCategoriesDAO;
14 import org.mvnforum.util.DBUtils;
15
16 public class PhpbbCategoriesDAOImpl implements PhpbbCategoriesDAO {
17     
18     private static final String JavaDoc TABLE_NAME = "phpbb_categories";
19     
20     /*
21      * Included columns: cat_id, cat_title, cat_order
22      * Excluded columns:
23      */

24     public Collection JavaDoc getBeans()
25         throws DatabaseException {
26
27         Connection JavaDoc connection = null;
28         PreparedStatement JavaDoc statement = null;
29         ResultSet JavaDoc resultSet = null;
30         Collection JavaDoc retValue = new ArrayList JavaDoc();
31         StringBuffer JavaDoc sql = new StringBuffer JavaDoc(512);
32         sql.append("SELECT cat_id, cat_title, cat_order");
33         sql.append(" FROM " + TABLE_NAME);
34         //sql.append(" WHERE "); // @todo: uncomment as needed
35
//sql.append(" ORDER BY ColumnName ASC|DESC "); // @todo: uncomment as needed
36
try {
37             connection = DBUtils.getPhpbbConnection();
38             statement = connection.prepareStatement(sql.toString());
39             resultSet = statement.executeQuery();
40             while (resultSet.next()) {
41                 PhpbbCategories bean = new PhpbbCategories();
42                 bean.setCatId(resultSet.getInt("cat_id"));
43                 bean.setCatTitle(resultSet.getString("cat_title"));
44                 bean.setCatOrder(resultSet.getInt("cat_order"));
45                 retValue.add(bean);
46             }
47             return retValue;
48         } catch(SQLException JavaDoc sqle) {
49             throw new DatabaseException("Error executing SQL in phpbb_categoriesDAOImplJDBC.getBeans.");
50         } finally {
51             DBUtils.closeResultSet(resultSet);
52             DBUtils.closeStatement(statement);
53             DBUtils.closeConnection(connection);
54         }
55     }
56
57
58
59
60 }
61
Popular Tags