sendmail.java

来自「一个很有用的电子刊物发布系统」· Java 代码 · 共 276 行

package com.am;

import java.util.*;
import java.sql.*;
import java.text.*;

public class sendMail
{ 
    public long ID;
	public String subject;
	public String content;
	public String sender;
	public String receiver;
	public String createDatetime;
	public int mailType;
 	public int tag;
    private String strSql;
    private Connection dbConn;
    private int errNum;
    private String errDesc;
    private SimpleDateFormat dateFormatter;

    public sendMail()
    {
        dateFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        ID=0;
    	subject="";
    	content="";
    	sender="";
    	receiver="";
    	createDatetime=dateFormatter.format(new java.util.Date());  
    	mailType=0;
		tag=0;        
        strSql="";        
        errNum=0;
        errDesc="";
   }
  
   public void add()
   {
        createDatetime=dateFormatter.format(new java.util.Date());
        strSql="insert into email";
        strSql=strSql + " (";
        strSql=strSql + "subject,";
        strSql=strSql + "content,";
        strSql=strSql + "sender,";
        strSql=strSql + "receiver,"; 
        strSql=strSql + "createDatetime,";
        strSql=strSql + "mailType,";
        strSql=strSql + "tag"; 
        strSql=strSql + ") ";
		strSql=strSql + "values(";
		strSql=strSql + "'" + subject + "',";
		strSql=strSql + "'" + content + "',";
		strSql=strSql + "'" + sender + "',";
		strSql=strSql + "'" + receiver + "',";
		strSql=strSql + "'" + createDatetime + "',";	
		strSql=strSql + "'" + 0 + "',";
		strSql=strSql + "'" + tag + "'";              
		strSql=strSql + ")";   
		System.out.println(strSql);			
		exeSql(strSql);	
			
   }


   public void addSave()
   {
        createDatetime=dateFormatter.format(new java.util.Date());
       
		    strSql="insert into email ";
	        strSql=strSql + "(";
	        strSql=strSql + "subject,";
	        strSql=strSql + "content,";
	        strSql=strSql + "sender,";
	        strSql=strSql + "receiver,"; 
	        strSql=strSql + "createDatetime,";
	        strSql=strSql + "mailType,";
	        strSql=strSql + "tag"; 
	        strSql=strSql + ") ";
			strSql=strSql + "values(";
			strSql=strSql + "'" + subject + "',";
			strSql=strSql + "'" + content + "',";
			strSql=strSql + "'" + sender + "',";
			strSql=strSql + "'" + receiver + "',";
			strSql=strSql + "'" + createDatetime + "',";	
			strSql=strSql + "'" + 1 + "',";
			strSql=strSql + "'" + tag + "'";              
			strSql=strSql + ")";  
			System.out.println(strSql);	 		
			exeSql(strSql);
		
		
   }

   
   public void deleteRec()
   {
        strSql="delete from email where receiver='";
        strSql=strSql + this.receiver + "' and mailType=0";

        exeSql(strSql);

   }
 
   public void deleteSender()
   {
        strSql="delete from email where sender='";
        strSql=strSql + this.sender + "' and mailType = 1";

        exeSql(strSql);

   }

  
   public boolean  init()
   {
    	strSql="select * from email where ID=";
        strSql=strSql + "'" + this.ID + "'";
        try
		{
   			Statement stmt=dbConn.createStatement();
			ResultSet rs =stmt.executeQuery(strSql);
            if (rs.next())
            {
                ID=rs.getLong("ID");
                subject=rs.getString("subject");
                content=rs.getString("content");
                sender=rs.getString("sender");
                receiver=rs.getString("receiver");
                createDatetime=rs.getString("createDatetime"); 
                mailType=rs.getInt("mailType");
                tag=rs.getInt("tag");
                
                this.errNum=0;
                this.errDesc="";
                return true;
            }
            else
            {
                this.errNum=-1;
                this.errDesc="init faild!";
                return false;

            }

		}
		catch(Exception ex)
		{			
            this.errNum=-1;
            this.errDesc=ex.toString();
            return false;
		}
   }

  
   public ResultSet  emailList()
   {
    	strSql="select * from email where receiver=";
        strSql=strSql + "'" + this.receiver + "' and mailType=0";
        try
		{
   			Statement stmt=dbConn.createStatement();
			ResultSet rs =stmt.executeQuery(strSql);                       
            this.errNum=0;
            this.errDesc="";
            return rs;          
		}
		catch(Exception ex)
		{			
            this.errNum=-1;
            this.errDesc=ex.toString();
            return null;
		}
   }
   
  
   public ResultSet  sendEmailList()
   {
    	strSql="select * from email where sender=";
        strSql=strSql + "'" + this.sender + "' and mailType=1";
        try
		{
   			Statement stmt=dbConn.createStatement();
			ResultSet rs =stmt.executeQuery(strSql);                        
                this.errNum=0;
                this.errDesc="";
                return rs;  
		}
		catch(Exception ex)
		{			
            this.errNum=-1;
            this.errDesc=ex.toString();
            return null;
		}
   }
   
 
   public int newEmailCount()
   {
    	strSql="select count(*) as x from email where receiver=";
        strSql=strSql + "'" + this.receiver + "' and mailType=0";
        try
		{
   			Statement stmt=dbConn.createStatement();
			ResultSet rs =stmt.executeQuery(strSql);
			int newEmail = 0;
            if (rs.next())
            {                  
                newEmail = rs.getInt("x");
            }           
            this.errNum=0;
            this.errDesc="";
            return newEmail;

		}
		catch(Exception ex)
		{			
            this.errNum=-1;
            this.errDesc=ex.toString();
            return -1;
		}
   }
   
   
      public void updateTag()
      {
	       strSql="update email set ";
	       strSql=strSql + "tag=" + "'" + 1 + "'";
	       strSql=strSql + " where ID='" + ID + "'";
	       exeSql(strSql);

      }
   
  
   public void  setConnection(Connection dbConn)
   {
   		this.dbConn=dbConn;
   }
   
   private void exeSql(String strSql)
   {
        Statement stmt=null;
        try
		{
   			stmt=dbConn.createStatement();
			stmt.executeUpdate(strSql);
            this.errNum=0;
            this.errDesc="";
		}
		catch(Exception ex)
		{
			System.out.println(ex.toString());
            this.errNum=-1;
            this.errDesc=ex.toString();

		}
        finally
        {
            stmt=null;
        }
   }

   
    public int getErrNum()
    {
        return errNum;

    }
    
    public String getErrDesc()
    {
        return errDesc;
    }
}