planebean.java

我用java jsp 编写的“航空订票系统”的小项目

package mvc;
import java.io.*;

import java.util.Date;
import java.util.*;
import java.sql.*;
import javax.servlet.http.*;
import javax.servlet.*;

public class PlaneBean
{
	 
//add
	public void addnew(HttpServletRequest req) throws Exception
	{
	  DbOrder  db=new DbOrder();
	  try
	  {
	   	String addsql="insert into plane_tab(hbh,num,photo,hnum,bnum) values(?,?,?,?,?)";
	   	Connection sqlCon=db.getConn();
	   	PreparedStatement  pstm=sqlCon.prepareStatement(addsql);
	   	pstm.setString(1,new String(req.getParameter("hbh").getBytes("ISO8859_1"),"gb2312"));
        pstm.setString(2,new String(req.getParameter("num").getBytes("ISO8859_1"),"gb2312")); 
       	pstm.setString(3,req.getParameter("photo"));
       pstm.setString(4,req.getParameter("hnum"));
       	pstm.setString(5,req.getParameter("bnum"));
       	
       pstm.executeUpdate();
       	pstm.close();
       	sqlCon.close();	  	 
	   } 
	   catch(Exception e)
	   {
	   }
	
	}
//delete
	public void delete(HttpServletRequest req) throws Exception
	{
	  DbOrder  db=new DbOrder();
	  try
	  {
	   	String sql="delete from plane_tab where id=?";
	   	Connection sqlCon=db.getConn();
	   	PreparedStatement  pstm=sqlCon.prepareStatement(sql);
 
       	pstm.setInt (1,Integer.parseInt(req.getParameter("id")));
        
       	pstm.executeUpdate();
       	pstm.close();
       	sqlCon.close();	  	 
	   } 
	   catch(Exception e)
	   {
	   }
	}
//uqdate
	public void update(HttpServletRequest req) throws Exception
	{
	  DbOrder db=new DbOrder();
	  try
	  {
	   	String addsql="update plane_tab set hbh=?,num=?,photo=?,hnum=?,bnum=? where id=?";
	   	Connection sqlCon=db.getConn();
	   	PreparedStatement  pstm=sqlCon.prepareStatement(addsql);
	   	pstm.setString(1,new String(req.getParameter("hbh").getBytes("ISO8859_1"),"gb2312"));
        pstm.setString(2,new String(req.getParameter("num").getBytes("ISO8859_1"),"gb2312")); 
       	pstm.setString(3,req.getParameter("photo"));
        pstm.setString(4,req.getParameter("hnum"));
       	pstm.setString(5,req.getParameter("bnum"));
      
       	pstm.setInt(6,Integer.parseInt(req.getParameter("id")));
       	
       	pstm.executeUpdate();
       	pstm.close();
       	sqlCon.close();	  	 
	   } 
	   catch(Exception e)
	   {
	   }
	}
//select
	public void select(HttpServletRequest req) throws Exception
	{
	 DbOrder  db=new DbOrder();
	  try
	  {
	   	String addsql="select * from txl_tab order by id desc"; 
	   	Connection sqlCon=db.getConn();
	   Statement stmt=sqlCon.createStatement();
	   ResultSet rs= stmt.executeQuery(addsql);
	   rs.next();
	   
	   
       	
	   } 
	   catch(Exception e)
	   {
	   }
	}
	
		//登陆方法
	public String  login(HttpServletRequest req) throws Exception
	{
	   String userName=req.getParameter("username");
	   String passWord=null;
	  DbOrder  db=new DbOrder();
	 try
	  {
	   	String addsql="select*  from user_tab  where username='"+userName+"'";
	   	Connection sqlCon=db.getConn();
	   	Statement stat=sqlCon.createStatement();
	       ResultSet rs = stat.executeQuery(addsql);
            rs.next();
        passWord= rs.getString(3);
         
       	stat.close();
       	sqlCon.close();	  	 
	   } 
	   catch(Exception e)
	   {
	   }
	return passWord; 
	}
		
}