📄 forumdaoimpljdbc.java
字号:
*/
public ForumBean getForum(int forumID)
throws ObjectNotFoundException, DatabaseException {
Connection connection = null;
PreparedStatement statement = null;
ResultSet resultSet = null;
StringBuffer sql = new StringBuffer(512);
sql.append("SELECT CategoryID, LastPostMemberName, ForumName, ForumDesc, ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType, ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount, ForumPostCount");
sql.append(" FROM " + TABLE_NAME);
sql.append(" WHERE ForumID = ?");
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
statement.setInt(1, forumID);
resultSet = statement.executeQuery();
if(!resultSet.next()) {
throw new ObjectNotFoundException("Cannot find the row in table Forum where primary key = (" + forumID + ").");
}
ForumBean bean = new ForumBean();
// @todo: uncomment the following line(s) as needed
bean.setForumID(forumID);
bean.setCategoryID(resultSet.getInt("CategoryID"));
bean.setLastPostMemberName(resultSet.getString("LastPostMemberName"));
bean.setForumName(resultSet.getString("ForumName"));
bean.setForumDesc(resultSet.getString("ForumDesc"));
bean.setForumCreationDate(resultSet.getTimestamp("ForumCreationDate"));
bean.setForumModifiedDate(resultSet.getTimestamp("ForumModifiedDate"));
bean.setForumLastPostDate(resultSet.getTimestamp("ForumLastPostDate"));
bean.setForumOrder(resultSet.getInt("ForumOrder"));
bean.setForumType(resultSet.getInt("ForumType"));
bean.setForumFormatOption(resultSet.getInt("ForumFormatOption"));
bean.setForumOption(resultSet.getInt("ForumOption"));
bean.setForumStatus(resultSet.getInt("ForumStatus"));
bean.setForumModerationMode(resultSet.getInt("ForumModerationMode"));
bean.setForumPassword(resultSet.getString("ForumPassword"));
bean.setForumThreadCount(resultSet.getInt("ForumThreadCount"));
bean.setForumPostCount(resultSet.getInt("ForumPostCount"));
return bean;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.getForum(pk).");
} finally {
DBUtils.closeResultSet(resultSet);
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc,
* ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType,
* ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword,
* ForumThreadCount, ForumPostCount
* Excluded columns:
*/
public Collection getForums()
throws DatabaseException {
Connection connection = null;
PreparedStatement statement = null;
ResultSet resultSet = null;
Collection retValue = new ArrayList();
StringBuffer sql = new StringBuffer(512);
sql.append("SELECT ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc, ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType, ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount, ForumPostCount");
sql.append(" FROM " + TABLE_NAME);
//sql.append(" WHERE "); // @todo: uncomment as needed
sql.append(" ORDER BY CategoryID ASC, ForumOrder ASC "); // @todo: uncomment as needed
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
resultSet = statement.executeQuery();
while (resultSet.next()) {
ForumBean bean = new ForumBean();
bean.setForumID(resultSet.getInt("ForumID"));
bean.setCategoryID(resultSet.getInt("CategoryID"));
bean.setLastPostMemberName(resultSet.getString("LastPostMemberName"));
bean.setForumName(resultSet.getString("ForumName"));
bean.setForumDesc(resultSet.getString("ForumDesc"));
bean.setForumCreationDate(resultSet.getTimestamp("ForumCreationDate"));
bean.setForumModifiedDate(resultSet.getTimestamp("ForumModifiedDate"));
bean.setForumLastPostDate(resultSet.getTimestamp("ForumLastPostDate"));
bean.setForumOrder(resultSet.getInt("ForumOrder"));
bean.setForumType(resultSet.getInt("ForumType"));
bean.setForumFormatOption(resultSet.getInt("ForumFormatOption"));
bean.setForumOption(resultSet.getInt("ForumOption"));
bean.setForumStatus(resultSet.getInt("ForumStatus"));
bean.setForumModerationMode(resultSet.getInt("ForumModerationMode"));
bean.setForumPassword(resultSet.getString("ForumPassword"));
bean.setForumThreadCount(resultSet.getInt("ForumThreadCount"));
bean.setForumPostCount(resultSet.getInt("ForumPostCount"));
retValue.add(bean);
}
return retValue;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.getForums.");
} finally {
DBUtils.closeResultSet(resultSet);
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc,
* ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType,
* ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword,
* ForumThreadCount, ForumPostCount
* Excluded columns:
*/
public Collection getForums_inCategory(int categoryID)
throws DatabaseException {
Connection connection = null;
PreparedStatement statement = null;
ResultSet resultSet = null;
Collection retValue = new ArrayList();
StringBuffer sql = new StringBuffer(512);
sql.append("SELECT ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc, ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType, ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount, ForumPostCount");
sql.append(" FROM " + TABLE_NAME);
sql.append(" WHERE CategoryID = ?");
sql.append(" ORDER BY CategoryID ASC, ForumOrder ASC "); // @todo: uncomment as needed
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
statement.setInt(1, categoryID);
resultSet = statement.executeQuery();
while (resultSet.next()) {
ForumBean bean = new ForumBean();
bean.setForumID(resultSet.getInt("ForumID"));
bean.setCategoryID(resultSet.getInt("CategoryID"));
bean.setLastPostMemberName(resultSet.getString("LastPostMemberName"));
bean.setForumName(resultSet.getString("ForumName"));
bean.setForumDesc(resultSet.getString("ForumDesc"));
bean.setForumCreationDate(resultSet.getTimestamp("ForumCreationDate"));
bean.setForumModifiedDate(resultSet.getTimestamp("ForumModifiedDate"));
bean.setForumLastPostDate(resultSet.getTimestamp("ForumLastPostDate"));
bean.setForumOrder(resultSet.getInt("ForumOrder"));
bean.setForumType(resultSet.getInt("ForumType"));
bean.setForumFormatOption(resultSet.getInt("ForumFormatOption"));
bean.setForumOption(resultSet.getInt("ForumOption"));
bean.setForumStatus(resultSet.getInt("ForumStatus"));
bean.setForumModerationMode(resultSet.getInt("ForumModerationMode"));
bean.setForumPassword(resultSet.getString("ForumPassword"));
bean.setForumThreadCount(resultSet.getInt("ForumThreadCount"));
bean.setForumPostCount(resultSet.getInt("ForumPostCount"));
retValue.add(bean);
}
return retValue;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.getForums_inCategory.");
} finally {
DBUtils.closeResultSet(resultSet);
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/************************************************
* Customized methods come below
************************************************/
/**
* This method should be call only when we can make sure that memberID is in database
*/
public void decreaseForumOrder(int forumID, Timestamp forumModifiedDate)
throws DatabaseException, ObjectNotFoundException {
Connection connection = null;
PreparedStatement statement = null;
String sql = "UPDATE " + TABLE_NAME + " SET ForumOrder = ForumOrder - 1, ForumModifiedDate = ? WHERE ForumID = ?";
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql);
statement.setTimestamp(1, forumModifiedDate);
statement.setInt(2, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update the ForumOrder in table Forum. Please contact Web site Administrator.");
}
//@todo: coi lai cho nay
// ATTENTION !!!
setDirty(true);
} catch (SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.decreaseForumOrder.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/**
* This method should be call only when we can make sure that memberID is in database
*/
public void increaseForumOrder(int forumID, Timestamp forumModifiedDate)
throws DatabaseException, ObjectNotFoundException {
Connection connection = null;
PreparedStatement statement = null;
String sql = "UPDATE " + TABLE_NAME + " SET ForumOrder = ForumOrder + 1, ForumModifiedDate = ? WHERE ForumID = ?";
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql);
statement.setTimestamp(1, forumModifiedDate);
statement.setInt(2, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update the ForumOrder in table Forum. Please contact Web site Administrator.");
}
//@todo: coi lai cho nay
// ATTENTION !!!
setDirty(true);
} catch (SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.increaseForumOrder.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc,
* ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType,
* ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword,
* ForumThreadCount, ForumPostCount
* Excluded columns:
*/
protected static ForumBean getBean_byAlternateKey_ForumName_CategoryID(String forumName, int categoryID)
throws ObjectNotFoundException, DatabaseException {
Connection connection = null;
PreparedStatement statement = null;
ResultSet resultSet = null;
StringBuffer sql = new StringBuffer(512);
sql.append("SELECT ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc, ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType, ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount, ForumPostCount");
sql.append(" FROM " + TABLE_NAME);
sql.append(" WHERE ForumName = ? AND CategoryID = ?");
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
statement.setString(1, forumName);
statement.setInt(2, categoryID);
resultSet = statement.executeQuery();
if(!resultSet.next()) {
throw new ObjectNotFoundException("Cannot find the row in table Forum where alternate key [ForumName, CategoryID] = (" + forumName + ", " + categoryID + ").");
}
ForumBean bean = new ForumBean();
// @todo: uncomment the following line(s) as needed
//bean.setForumName(forumName);
//bean.setCategoryID(categoryID);
bean.setForumID(resultSet.getInt("ForumID"));
bean.setCategoryID(resultSet.getInt("CategoryID"));
bean.setLastPostMemberName(resultSet.getString("LastPostMemberName"));
bean.setForumName(resultSet.getString("ForumName"));
bean.setForumDesc(resultSet.getString("ForumDesc"));
bean.setForumCreationDate(resultSet.getTimestamp("ForumCreationDate"));
bean.setForumModifiedDate(resultSet.getTimestamp("ForumModifiedDate"));
bean.setForumLastPostDate(resultSet.getTimestamp("ForumLastPostDate"));
bean.setForumOrder(resultSet.getInt("ForumOrder"));
bean.setForumType(resultSet.getInt("ForumType"));
bean.setForumFormatOption(resultSet.getInt("ForumFormatOption"));
bean.setForumOption(resultSet.getInt("ForumOption"));
bean.setForumStatus(resultSet.getInt("ForumStatus"));
bean.setForumModerationMode(resultSet.getInt("ForumModerationMode"));
bean.setForumPassword(resultSet.getString("ForumPassword"));
bean.setForumThreadCount(resultSet.getInt("ForumThreadCount"));
bean.setForumPostCount(resultSet.getInt("ForumPostCount"));
return bean;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.getBean_byAlternateKey_ForumName_CategoryID(ak).");
} finally {
DBUtils.closeResultSet(resultSet);
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
}// end of class ForumDAOImplJDBC
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -