dbinsertbean.java

这是一个在线订购的例子

package mybeans;
import java.util.ArrayList;
import java.sql.*;
import java.io.*;
public class DBInsertBean
{  
  private String name = null;  
  private String passwd = null;
/*设置当前用户的姓名*/
  public synchronized void setName(String name)
 {
    this.name = name;
  }  
/*设置当前用户的密码*/  
  public synchronized void setPasswd(String passwd)
 {
    this.passwd = passwd;
  }  
  private Connection dctx = null;
  //定义数据库连接  
/*把所选中的商品插入数据库*/
  public synchronized String processOrder (ArrayList order)
   { 
    if ((order == null) || (order.size() == 0))
       {
      return ("没有商品");
    }
    try {
       Class.forName("org.gjt.mm.mysql.Driver");
 	dctx = DriverManager.getConnection("jdbc:mysql://localhost/jsp?user=root&useUnicode=true&characterEncoding=gb2312");
      int bz = DBInsert(order);    
      /*判断用户密码*/
      if(bz==1)
      return ("成功提交");
      else
      return("用户密码错误");
    }  catch (SQLException e) {
          return ("SQL Error:" + e.getMessage());
     } catch (ClassNotFoundException ex){
     	  return(ex.toString());
	}
      catch(java.io.UnsupportedEncodingException ex2){
      	return(ex2.toString());
	}	
      finally {
       try {
/*释放数据库连接*/
          dctx.close();
       } catch (SQLException e) {
           }
      }
  }
  private int DBInsert(ArrayList order) throws SQLException,java.io.UnsupportedEncodingException  {  
    String items = new String(order.toString().getBytes("iso-8859-1"));
    Statement bm1 = dctx.createStatement();
    ResultSet rs1 = bm1.executeQuery("select passwd from custominfo where name='"+name+"'");
    if(rs1.next())
{
    if(passwd.equals(rs1.getString(1).toString()))
  {
     Statement bm3 = dctx.createStatement();
     bm3.executeUpdate("insert into items values('"+name+"','"+items.substring(1,items.length()-1)+"')");
     return 1;
//设置标志位
    }
    else
    return -1;
//设置标志位
	}
    else{
     Statement bm2 = dctx.createStatement();
     bm2.executeUpdate("insert into custominfo values('"+name+"','"+passwd+"')");
     Statement bm3 = dctx.createStatement();
     bm3.executeUpdate("insert into items values('"+name+"','"+items.substring(1,items.length()-1)+"')");
     return 1;
	}	  
  }
}