additem.java

黑魔方JSP基础教程源代码(耿祥义编著)是这里有课件和jsp源代码

package tom.jiafei;
import java.sql.*;
import java.util.*;
public class AddItem
{  
   String tableName="";   //数据库表名。
   String columsName="";  
   Vector  vector;
   String item="";        //添加的记录。
   String result="";
   public AddItem()
    {
       try{
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
          }
       catch(ClassNotFoundException e){}
       vector=new Vector();
    }
  public void setTableName(String s)
    {
       tableName=s;
    }
 public String getTableName()
    {
       return tableName;
    }
 public String getResult()
    {
       return result;
    }
 public String getColumsName()
    {
      Connection con=null;
      vector.removeAllElements();
      StringBuffer buffer=new StringBuffer();  
      try{ 
            con=DriverManager.getConnection("jdbc:odbc:sun","sa","");
            DatabaseMetaData metadata=con.getMetaData();
            ResultSet rs=metadata.getColumns(null,null,tableName,null);
            //如果tableName表有n个字段，rs1就刚好有n行，每行中含有字段名的信息。
            while(rs.next())
            {
                String name=rs.getString("COLUMN_NAME");
                vector.add(name);
            }
            buffer.append("<Table Border>");
            buffer.append("<tr>");
            for(int t=0;t<vector.size();t++)
            {
                String name=(String)vector.elementAt(t);
                buffer.append("<td>"+name+"</td>");
            }
            buffer.append("</tr>");
            buffer.append("</Table>");
            con.close();
            columsName=new String(buffer);
            return columsName;
          }
    catch(SQLException e)
          {
             columsName=new String("你还没有选择表名，无法添加记录");
             return columsName;
          }
   } 
 public void setItem(String item)
   {
       this.item=item;
       StringTokenizer fenxi=new StringTokenizer(item,"，,"); //逗号做分隔符号。
       int number=fenxi.countTokens();
       String str[]=new String[number];
       int i=0;
       while(fenxi.hasMoreTokens()) 
         {
           String temp=fenxi.nextToken();
           try {
                byte  b[]=temp.getBytes("ISO-8859-1");
                temp=new String(b);
               }
           catch(Exception ee){}
           str[i]=temp;
           i++;
         }
      try
         {
           Connection con=DriverManager.getConnection("jdbc:odbc:sun","sa","");
           Statement sql=
 con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        //返回可滚动的、可更新数据库的结果集：
         ResultSet rs=sql.executeQuery("SELECT * FROM "+tableName);
         for(int num=0;num<vector.size();num++)
            {
               String name=(String)vector.elementAt(num);
               rs.updateString(name,str[num]);     //对结果集做更新操作。
            }
         rs.insertRow();                          //插入记录操作。
         result="添加该记录到数据库";
         }
      catch(SQLException e)
         {
           result="不能添加记录"+e;
         }
   }
}