jspselect.java

javamail发送程序

//jsp文件调用类
package myjsp;
import java.io.*;
import java.sql.*;
import java.util.*;
//数据库查询函数
public class JspSelect
{
  public String SqlSelect(String jspSql)
  {
     try
     {
          Class.forName(DirverName);
          //DataConnection=DriverManager.getConnection(OdbcURL,"sa","");
          DataConnection=DriverManager.getConnection(OdbcURL);
          statement=DataConnection.createStatement();
          //查询邮件地址列表
          System.out.println(jspSql);
          DataResultSet1=statement.executeQuery(jspSql);
          //将邮件地列表写入向量集
          this.getRetData();
          //关闭数据库连接
          statement.close();
          return "ok";
      }
      catch(ClassNotFoundException cnfe)
      {
          System.err.println(cnfe+"A");
          return "false";
      }
      catch(SQLException sqle)
      {
          System.err.println(sqle+"A");
          return "false";
      }
   }
   //获得邮件收件人各行各列的数据
   public void getRetData()
  {
      try
      {
        dataRows.clear();
        ResultSetMetaData metadata = DataResultSet1.getMetaData();   //建立 ResultSetMetaData 对象
        int columns =  metadata.getColumnCount();    //获得字段总数
        String[] rowData;
        while(DataResultSet1.next())
      {
        rowData = new String[columns];
        for(int i = 0; i < columns; i++)
        {
           rowData[i] = DataResultSet1.getString(i+1);//第一列从1开始
        }
        dataRows.addElement(rowData);
      }
      //关闭记录集
      DataResultSet1.close();
      }
      catch(SQLException sqle)
      {
          System.err.println(sqle+"B");
      }
  }
  ////////////////
  //获得邮件收件人集中的总条目
   public int getRowCount()
  {
      if(dataRows == null)
           return 0;
      else
           return dataRows.size();
  }
  ////////////////
  //获得邮件收件人某行某列的记录
  public Object getValueAt(int row, int column)
  {
      return ((String[])(dataRows.elementAt(row)))[column];
  }
  public String SqlInsert(String sName,String sEmail,String sDanwei,String sBeizhu)
  {
    try
     {
          Class.forName(DirverName);
          DataConnection=DriverManager.getConnection(OdbcURL);
          statement=DataConnection.createStatement();
          //添加一个新记录
          int num=statement.executeUpdate("insert into xiao(name,tomail,danwei,leixing,cishu,jilu,biaozhu)values('"+sName+"','"+sEmail+"','"+sDanwei+"','"+sBeizhu+"',0,'sYes',0)");
          //关闭数据库连接
          statement.close();
          return sName+"已经成功添加";
      }
      catch(ClassNotFoundException cnfe)
      {
          System.err.println(cnfe+"A");
          return sName+"添加失败";
      }
      catch(SQLException sqle)
      {
          System.err.println(sqle+"A");
          return sName+"添加失败";
      }
  }
  //////////////
  private static Connection DataConnection;
  private static Statement statement;
  private static ResultSet DataResultSet1;
  private Vector dataRows=new Vector();
  private static String DirverName ="sun.jdbc.odbc.JdbcOdbcDriver";
  private static String OdbcURL="jdbc:odbc:emaillist1";
  //private static String OdbcURL="jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=C:/jakarta-tomcat-4.0-b1/jakarta-tomcat-4.0-b1/webapps/ROOT/emailsend/email.mdb";
}