problembean.java

购物网站

package com;
import java.sql.*;
import java.util.*;
import java.io.*;
/**
 *ProblemBean包含和TABLE_PROBLEM表相关的操作
 */
public class ProblemBean{
	private Connection con;
	//构造方法，获得数据库的连接。
	public ProblemBean(){
		try
		{
			con=DBConnection.getConnection();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}

	}
	/**
	 *搜索所有的信息。
	 *返回由Problem值对象组成的Collection
	 */
	public Collection getAllProblem()throws Exception{
		Statement stmt=con.createStatement();
		ResultSet rst=stmt.executeQuery("select * from TABLE_PROBLEM");
		Collection ret=new ArrayList();
		while(rst.next()){
			Problem temp=new Problem();
			temp.setProblemId(rst.getInt("PROBLEM_ID"));
			temp.setProblemTitle(rst.getString("PROBLEM_TITLE"));
			temp.setProblemRevert(rst.getString("PROBLEM_REVERT"));

			ret.add(temp);
		}
		con.close();
		return ret;
	}
	
	
	/**
	 *添加一个问题，使用Problem值对象作为参数传给这个方法。
	 */
	public void addProblem(Problem problem)throws Exception{
		
		PreparedStatement	pstmt=con.prepareStatement("insert into TABLE_PROBLEM values(?,?)");
		pstmt.setString(1,problem.getProblemTitle());
		pstmt.setString(2,problem.getProblemRevert());
		pstmt.execute();
		
	}
	
	/**
	 *更改问题的信息，使用值对象作为参数传给这个方法。
	 */
	public void modifyProblem(Problem problem)throws Exception{
		
		PreparedStatement	pstmt=con.prepareStatement("update TABLE_PROBLEM set PROBLEM_TITLE=?,PROBLEM_REVERT=? where PROBLEM_ID=?");
		pstmt.setString(1,problem.getProblemTitle());
		pstmt.setString(2,problem.getProblemRevert());
		try{
			pstmt.execute();
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
				
	}
	
	/**
	 *删除问题
	 */
	public void deleteProblem (String problemId)throws Exception{
		Statement stmt=con.createStatement();
		stmt.execute("delete from TABLE_PROBLEM where PROBLEM_ID='"+problemId+"'");
	}
	/**
	 *按照问题的ID查找商品，
	 *返回由Problem值对象组成的Collection
	 */
	public Problem getProblemById(String problemId)throws Exception
	{
		
		Statement stmt=con.createStatement();
		ResultSet rst=stmt.executeQuery("select * from TABLE_PROBLEM where PROBLEM_ID='"+problemId+"'");
		Problem problem=null;
		while(rst.next())
		{
			problem=new Problem();
			problem.setProblemId(rst.getInt("PROBLEM_ID"));
			problem.setProblemTitle(rst.getString("PROBLEM_TITLE"));
			problem.setProblemRevert(rst.getString("PROBLEM_REVERT"));
			
		}
		return problem;
	}
}