?? forumdaoimpljdbc.java
字號(hào):
if ( !forumName.equals(bean.getForumName()) ||
(categoryID != bean.getCategoryID()) ) {
// Forum tries to change its alternate key <ForumName, CategoryID>, so we must check if it already exist
try {
findByAlternateKey_ForumName_CategoryID(forumName, categoryID);
throw new DuplicateKeyException("Alternate key <ForumName, CategoryID> (" + forumName + ", " + categoryID + ")already exists. Cannot update Forum.");
} catch(ObjectNotFoundException e) {
//Otherwise we can go ahead
}
}
try {
// @todo: modify the parameter list as needed
// If this method does not change the foreign key columns, you can comment this block of code.
DAOFactory.getCategoryDAO().findByPrimaryKey(categoryID);
} catch(ObjectNotFoundException e) {
throw new ForeignKeyNotFoundException("Foreign key refers to table 'Category' does not exist. Cannot update table 'Forum'.");
}
Connection connection = null;
PreparedStatement statement = null;
StringBuffer sql = new StringBuffer(512);
sql.append("UPDATE " + TABLE_NAME + " SET CategoryID = ?, ForumName = ?, ForumDesc = ?, ForumModifiedDate = ?, ForumOrder = ?, ForumType = ?, ForumFormatOption = ?, ForumOption = ?, ForumStatus = ?, ForumModerationMode = ?");
sql.append(" WHERE ForumID = ?");
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
// // column(s) to update
statement.setInt(1, categoryID);
statement.setString(2, forumName);
statement.setString(3, forumDesc);
statement.setTimestamp(4, forumModifiedDate);
statement.setInt(5, forumOrder);
statement.setInt(6, forumType);
statement.setInt(7, forumFormatOption);
statement.setInt(8, forumOption);
statement.setInt(9, forumStatus);
statement.setInt(10, forumModerationMode);
// primary key column(s)
statement.setInt(11, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update table Forum where primary key = (" + forumID + ").");
}
m_dirty = true;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.update.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: LastPostMemberName
* Excluded columns: ForumID, CategoryID, ForumName, ForumDesc, ForumCreationDate,
* ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType, ForumFormatOption,
* ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount,
* ForumPostCount
*/
public void updateLastPostMemberName(int forumID, // primary key
String lastPostMemberName)
throws ObjectNotFoundException, DatabaseException, ForeignKeyNotFoundException {
//allow anonymous/guests to send posts (if admin allows that)
if ((lastPostMemberName!=null) && (lastPostMemberName.length()>0)) {
try {
// @todo: modify the parameter list as needed
// If this method does not change the foreign key columns, you can comment this block of code.
DAOFactory.getMemberDAO().findByAlternateKey_MemberName(lastPostMemberName);
} catch(ObjectNotFoundException e) {
throw new ForeignKeyNotFoundException("Foreign key refers to table 'Member' does not exist. Cannot update table 'Forum'.");
}
} else lastPostMemberName=""; //so we don't get 'null' in sql query
Connection connection = null;
PreparedStatement statement = null;
StringBuffer sql = new StringBuffer(512);
sql.append("UPDATE " + TABLE_NAME + " SET LastPostMemberName = ?");
sql.append(" WHERE ForumID = ?");
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
// // column(s) to update
statement.setString(1, lastPostMemberName);
// primary key column(s)
statement.setInt(2, forumID);
if (statement.executeUpdate() != 1) {
// Some drivers dont update database if it detect old and new data are the same
// @todo: should check driver, not check database
// Currently there is only one driver: Caucho MySql driver
if ( DBUtils.getDatabaseType() != DBUtils.DATABASE_MYSQL ) {
throw new ObjectNotFoundException("Cannot update table Forum where primary key = (" + forumID + ").");
} else {
log.warn("WARNING: By pass the check for Caucho MySql driver.");
}
}
//@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.update.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: ForumLastPostDate
* Excluded columns: ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc,
* ForumCreationDate, ForumModifiedDate, ForumOrder, ForumType, ForumFormatOption,
* ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount,
* ForumPostCount
*/
public void updateLastPostDate(int forumID, // primary key
Timestamp forumLastPostDate)
throws ObjectNotFoundException, DatabaseException {
Connection connection = null;
PreparedStatement statement = null;
StringBuffer sql = new StringBuffer(512);
sql.append("UPDATE " + TABLE_NAME + " SET ForumLastPostDate = ?");
sql.append(" WHERE ForumID = ?");
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
// // column(s) to update
statement.setTimestamp(1, forumLastPostDate);
// primary key column(s)
statement.setInt(2, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update table Forum where primary key = (" + forumID + ").");
}
m_dirty = true;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.update.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: ForumThreadCount, ForumPostCount
* Excluded columns: ForumID, CategoryID, LastPostMemberName, ForumName, ForumDesc,
* ForumCreationDate, ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType,
* ForumFormatOption, ForumOption, ForumStatus, ForumModerationMode, ForumPassword
*/
public void updateStatistics(int forumID, // primary key
int forumThreadCount, int forumPostCount)
throws ObjectNotFoundException, DatabaseException {
Connection connection = null;
PreparedStatement statement = null;
StringBuffer sql = new StringBuffer(512);
sql.append("UPDATE " + TABLE_NAME + " SET ForumThreadCount = ?, ForumPostCount = ?");
sql.append(" WHERE ForumID = ?");
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql.toString());
// // column(s) to update
statement.setInt(1, forumThreadCount);
statement.setInt(2, forumPostCount);
// primary key column(s)
statement.setInt(3, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update table Forum where primary key = (" + forumID + ").");
}
m_dirty = true;
} catch(SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error executing SQL in ForumDAOImplJDBC.update.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/**
* This method should be call only when we can make sure that threadID is in database
*/
public void increasePostCount(int forumID)
throws DatabaseException, ObjectNotFoundException {
Connection connection = null;
PreparedStatement statement = null;
String sql = "UPDATE " + TABLE_NAME + " SET ForumPostCount = ForumPostCount + 1 WHERE ForumID = ?";
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql);
statement.setInt(1, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update the ForumPostCount 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 occured when update Forum: column name = ForumPostCount.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/**
* This method should be call only when we can make sure that threadID is in database
*/
public void increaseThreadCount(int forumID)
throws DatabaseException, ObjectNotFoundException {
Connection connection = null;
PreparedStatement statement = null;
String sql = "UPDATE " + TABLE_NAME + " SET ForumThreadCount = ForumThreadCount + 1 WHERE ForumID = ?";
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql);
statement.setInt(1, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update the ForumThreadCount in table Forum. Please contact Web site Administrator.");
}
setDirty(true);
} catch (SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error occured when update Forum: column name = ForumThreadCount.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/**
* This method should be call only when we can make sure that threadID is in database
*/
public void decreaseThreadCount(int forumID)
throws DatabaseException, ObjectNotFoundException {
Connection connection = null;
PreparedStatement statement = null;
String sql = "UPDATE " + TABLE_NAME + " SET ForumThreadCount = ForumThreadCount - 1 WHERE ForumID = ?";
try {
connection = DBUtils.getConnection();
statement = connection.prepareStatement(sql);
statement.setInt(1, forumID);
if (statement.executeUpdate() != 1) {
throw new ObjectNotFoundException("Cannot update the ForumThreadCount in table Forum. Please contact Web site Administrator.");
}
setDirty(true);
} catch (SQLException sqle) {
log.error("Sql Execution Error!", sqle);
throw new DatabaseException("Error occured when update Forum: column name = ForumThreadCount.");
} finally {
DBUtils.closeStatement(statement);
DBUtils.closeConnection(connection);
}
}
/*
* Included columns: CategoryID, LastPostMemberName, ForumName, ForumDesc, ForumCreationDate,
* ForumModifiedDate, ForumLastPostDate, ForumOrder, ForumType, ForumFormatOption,
* ForumOption, ForumStatus, ForumModerationMode, ForumPassword, ForumThreadCount,
* ForumPostCount
* Excluded columns: ForumID
*/
public ForumBean getBean(int forumID)
throws ObjectNotFoundException, DatabaseException {
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -