t_dp_user_dao.java

一个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;
import java.sql.Connection;
import java.sql.Statement;
import cn.com.pkusoft.entity.ConnectionFactory;
import java.util.HashMap;
import java.util.Map;
import java.util.Iterator;
import java.sql.PreparedStatement;

/**
 * <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 sqlBuffer = new StringBuffer();
		sqlBuffer.append("SELECT ");
		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(" ");
		sqlBuffer.append("FROM ");
		sqlBuffer.append(T_Dp_User_BD.TABLE_NAME);
		sqlBuffer.append(" WHERE ");
		sqlBuffer.append(strFilter);
		//sqlBuffer.append(T_Dp_User_BD.LOGINNAME);
		//sqlBuffer.append(" = ");
		//sqlBuffer.append("?");

		String strSql = sqlBuffer.toString();
		Connection conn = ConnectionFactory.getStaticInstance().getConnection();

		Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,
											  java.sql.ResultSet.CONCUR_READ_ONLY);

		//PreparedStatement stmt = conn.prepareStatement(strSql);
		//stmt.setString(1, strFilter);
		ResultSet rs = stmt.executeQuery(strSql);

		int iCount = 0;
		while (rs.next())
		{
			Map recordMap = new HashMap();
			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");
			iCount++;

			/*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);*/

			String strCount = new Integer(iCount).toString();

			recordMap.put("loginname", loginname);
			recordMap.put("loginpass", loginpass);
			recordMap.put("loginques", loginques);
			recordMap.put("loginanse", loginanse);
			recordMap.put("email", email);
			recordMap.put("tele", tele);
			recordMap.put("address", address);
			recordMap.put("usergrade", usergrade);
			recordMap.put("remark", remark);
			recordMap.put("fax", fax);
			recordMap.put("iCount", strCount);
			//recordMap.put(usernum, usernum);

			list.add(recordMap);

			//list.add(userBd);
		}
		return list;

	}

	public int update(BaseEntityData bd) throws java.sql.SQLException
	{
		T_Dp_User_BD userBd = (T_Dp_User_BD) bd;
		StringBuffer sqlBuffer = new StringBuffer();
		sqlBuffer.append("UPDATE ");
		sqlBuffer.append(T_Dp_User_BD.TABLE_NAME);
		sqlBuffer.append(" SET ");
		sqlBuffer.append(T_Dp_User_BD.LOGINNAME);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getLoginname());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.LOGINPASS);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getLoginpass());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.ADDRESS);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getAddress());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.EMAIL);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getEmail());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.FAX);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getFax());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.LOGINANSE);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getLoginanse());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.LOGINQUES);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getLoginques());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.REMARK);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getRemark());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.TELE);
		sqlBuffer.append(" ='");
		sqlBuffer.append(userBd.getTele());
		sqlBuffer.append("',");
		sqlBuffer.append(T_Dp_User_BD.USERGRADE);
		sqlBuffer.append(" ='");
		sqlBuffer.append(userBd.getUsergrade());
		sqlBuffer.append("' WHERE ");
		sqlBuffer.append(T_Dp_User_BD.LOGINNAME);
		sqlBuffer.append(" = '");
		sqlBuffer.append(userBd.getLoginname());
		sqlBuffer.append("'");

		String strSql = sqlBuffer.toString();
		System.out.println(strSql);

		Connection conn = ConnectionFactory.getStaticInstance().getConnection();

		Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,
											  java.sql.ResultSet.CONCUR_READ_ONLY);

		ResultSet rs = stmt.executeQuery(strSql);

		int nReturn = 1; //stmt.execute(strSql);

		return nReturn;
	}

	/**
	 * 插入一条数据
	 * @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.");
	}

}