userinterestsdao.java

该源码包括了基于J2EE的数据持久层设计,设计中使用了DAO,Service,等模式,并在Struts下进行了测试．

package org.conference.datapersistence.Dao;

import java.io.Serializable;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

import javax.sql.DataSource;


import org.conference.datapersistence.Bo.UserVO;
import org.conference.datapersistence.Bo.UserInterestsVO;
import org.javawing.component.dao.DataAccessException;
import org.javawing.component.jdbc.core.RowCallbackHandler;
import org.javawing.component.jdbc.core.support.JdbcDaoSupport;

public class UserInterestsDao extends JdbcDaoSupport implements Serializable {
	private static final long serialVersionUID = 1L;

	public UserInterestsDao(DataSource dataSource) {
		this.setDataSource(dataSource);
	}
	
	public List doFindbyUserid(final int userid ){
		final List interests = new ArrayList();
		String Query="select iid from uinterest where uid="+userid;
		this.getJdbcTemplate().query(
				Query,new RowCallbackHandler() {
					public void processRow(ResultSet rs) throws SQLException {
						interests.add(new Integer(rs.getInt("iid")));
					}
				});
				return interests;
	}
	
	public  List doFindbyInterestid(int iid){
		final List users = new ArrayList();
		String Query="select uid from uinterest where iid="+iid;
		this.getJdbcTemplate().query(
				Query,new RowCallbackHandler() {
					public void processRow(ResultSet rs) throws SQLException {
						users.add(new Integer(rs.getInt("uid")));
					}
				});
				return users;
	}
	
	public int doInstore(int userid,int interestid){
		String storeQuery = "insert into `uinterest` (uid,iid) values("
			+ userid + "," + interestid + ")";
		return this.getJdbcTemplate().update(storeQuery);
	}
	
	public int doUpdatebyId(UserVO user) throws DataAccessException {
		String updateQuery = null;
		updateQuery = "update uinterest set uinterest='" + user.getInterests() 
		+ "' where uid="+user.getUserid();
		System.out.println("\n"+updateQuery);
		return this.getJdbcTemplate().update(updateQuery);
	}
	

	public  int  dodeletebyuserid(int userid){
		String deleteQuery="delete from uinterest where uid="+userid;
		return this.getJdbcTemplate().update(deleteQuery);
	}


}