t_dp_user_dao.java~1~

一个javaweb开的小例子

package cn.com.pkusoft.entity.dao;

import java.util.List;

import cn.com.pkusoft.entity.BaseEntityData;
import cn.com.pkusoft.entity.T_Dp_User_BD;
import java.util.Collection;
import java.util.ArrayList;
import java.sql.ResultSet;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class T_Dp_User_Dao
	extends BaseDao
{
	/**
	 * sequence name
	 */
	public static final String T_SEQUENCE_NAME = "SEQ_DP_USER";


	public T_Dp_User_Dao()
	{
	}

	/**
	 * 根据查询条件，检索出结果，然后返回一个BD 的列表。
	 * @param strFilter String 查询条件
	 * @throws SQLException
	 * @return List
	 */
	public List select(String strFilter) throws java.sql.SQLException
	{
		T_Dp_User_BD userBd = new T_Dp_User_BD();
		List list = new ArrayList();
		/*SELECT USERNUM, LOGINNAME, LOGINPASS,
			LOGINQUES, LOGINANSE, EMAIL,
			TELE, ADDRESS, USERGRADE,
			REMARK, FAX FROM DP_USER*/

		StringBuffer strBuff = new StringBuffer();
		strBuff.append("SELECT ");
		strBuff.append(T_Dp_User_BD.USERNUM);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.LOGINNAME);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.LOGINPASS);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.LOGINQUES);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.LOGINANSE);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.EMAIL);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.TELE);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.ADDRESS);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.USERGRADE);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.REMARK);
		strBuff.append(",");
		strBuff.append(T_Dp_User_BD.FAX);
		strBuff.append(",");
		strBuff.append("FROM ");
		strBuff.append(T_Dp_User_BD.TABLE_NAME);
		strBuff.append("WHERE");
		strBuff.append(" ");
		strBuff.append(strFilter);

		String strSql = strBuff.toString();

		ResultSet rs = this.executeQuery(strSql);

		int i = 0;

		while(rs.next())
		{
			int usernum = rs.getInt("USERNUM");
			String  loginname = rs.getString("LOGINNAME");
			String  loginpass = rs.getString("LOGINPASS");
			String  loginques = rs.getString("LOGINQUES");
			String  loginanse = rs.getString("LOGINANSE");
			String  email = rs.getString("EMAIL");
			String  tele = rs.getString("TELE");
			String  address = rs.getString("ADDRESS");
			String  usergrade = rs.getString("USERGRADE");
			String  remark = rs.getString("REMARK");
			String  fax = rs.getString("FAX");

			userBd.setLoginname(loginname);
			userBd.setLoginpass(loginpass);
			userBd.setLoginques(loginques);
			userBd.setLoginanse(loginanse);
			userBd.setEmail(email);
			userBd.setTele(tele);
			userBd.setAddress(address);
			userBd.setUsergrade(usergrade);
			userBd.setRemark(remark);
			userBd.setFax(fax);

			list.add(userBd);
		}
		return list;


	}

	public int update(BaseEntityData bd) throws java.sql.SQLException
	{
		T_Dp_User_BD userBd = (T_Dp_User_BD) bd;

		/**@todo Implement this cn.com.pkusoft.entity.dao.BaseDao abstract method*/
		throw new java.lang.UnsupportedOperationException("Method update() not yet implemented.");
	}

	/**
	 * 插入一条数据
	 * @param bd BaseEntityData 要进行插入的记录数据
	 * @throws SQLException
	 * @return int
	 */
	public int insert(BaseEntityData bd) throws java.sql.SQLException
	{
		T_Dp_User_BD userBd = (T_Dp_User_BD) bd;

		/*
		 INSERT INTO DP_USER (
		 USERNUM, LOGINNAME, LOGINPASS,
		 LOGINQUES, LOGINANSE, EMAIL,
		 TELE, ADDRESS, USERGRADE,
		 REMARK, FAX)
		 VALUES ( , , ,
		  , , ,
		  , , ,
		  , )
		 */

		StringBuffer sqlBuffer = new StringBuffer("");
		sqlBuffer.append("INSERT INTO ");
		sqlBuffer.append(T_Dp_User_BD.TABLE_NAME);
		sqlBuffer.append("( ");
		sqlBuffer.append(T_Dp_User_BD.USERNUM);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.LOGINNAME);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.LOGINPASS);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.LOGINQUES);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.LOGINANSE);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.EMAIL);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.TELE);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.ADDRESS);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.USERGRADE);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.REMARK);
		sqlBuffer.append(",");
		sqlBuffer.append(T_Dp_User_BD.FAX);
		sqlBuffer.append(") VALUES (");
		sqlBuffer.append(userBd.getUsernum());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getLoginname());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getLoginpass());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getLoginques());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getLoginanse());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getEmail());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getTele());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getAddress());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getUsergrade());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getRemark());
		sqlBuffer.append(",");
		sqlBuffer.append(userBd.getFax());
		sqlBuffer.append(")");

		String strSql = sqlBuffer.toString();
		//delete sqlBuffer;
		int nReturn = this.execute(strSql);

		return nReturn;

	}

	/**
	 * 取得SEQUENCE的名字。
	 * @throws SQLException
	 * @return String
	 */
	protected String getSequenceName() throws java.sql.SQLException
	{
		// 返回SEQUENCE的名字。
		return T_SEQUENCE_NAME;
	}

	/**
	 * 删除一条记录
	 * @param bd BaseEntityData 要进行删除的数据
	 * @throws SQLException
	 * @return int
	 */
	public int delete(BaseEntityData bd) throws java.sql.SQLException
	{
		T_Dp_User_BD userBd = (T_Dp_User_BD) bd;

		/**@todo Implement this cn.com.pkusoft.entity.dao.BaseDao abstract method*/
		throw new java.lang.UnsupportedOperationException("Method delete() not yet implemented.");
	}

}