msetting.java

网络邮件系统

/*
 * This product includes software developed by the
 * Apache Software Foundation (http://www.apache.org/).
 */
package ch05.module;

import java.sql.*;
import java.util.Hashtable;

import javax.servlet.http.*;

import ch05.CommonConst;

/**
 * 针对注册页面的后台处理类
 * @author ShenYK
 * @version 1.0
 */
public class MSetting
{
    public boolean registerSetting ( HttpSession mySession, 
    		                           String sPop3Ip, 
    		                           String sPop3User, 
    		                           String sPop3Pass,
                                       String sSmtpIp,
                                       String sSmtpUser,
                                       String sSmtpPass,
                                       String sAddress )
    {
        //设置用户信息
        Hashtable myValues = (Hashtable)mySession.getAttribute(CommonConst.VIEWID_SETTING);
        myValues.put("pop3Ip",   sPop3Ip);
        myValues.put("pop3User", sPop3User);
        myValues.put("pop3Pass", sPop3Pass);
        myValues.put("smtpIp",   sSmtpIp);
        myValues.put("smtpUser", sSmtpUser);
        myValues.put("smtpPass", sSmtpPass);
        myValues.put("address", sAddress);
        
        String sUsername = (String)mySession.getAttribute("username");
        
        //尝试设置用户邮箱，如果已经有了，则更新；如果没有，则插入新记录
        try
        {
            //载入MySQL的JDBC驱动类
            Class.forName(CommonConst.DB_DRIVER_CLASSNAME);
            //获得数据库连接
            Connection conn = DriverManager.getConnection( CommonConst.DB_CONN_STRING );

            Statement stmt = null;
            ResultSet rs = null;
            
            try
            {
                //检查数据库中是否已经有该用户的邮箱设置了
                stmt = conn.createStatement();
                //更新DB的SQL语句
                String sUpdateQuery = "";
                
                //执行SQL语句
                String sQuery = "select count(*) from mail_setting where username='" + sUsername + "'";
                rs = stmt.executeQuery( sQuery );
                rs.next();
                int iUserTmp =rs.getInt(1);
                
                //用户名已经存在
                if ( iUserTmp > 0 )
                {
                    sUpdateQuery = "update mail_setting set pop3_ip='" + sPop3Ip + "', "
                                 + "pop3_user='" + sPop3User + "', "
                                 + "pop3_pass='" + sPop3Pass + "', "
                                 + "smtp_ip='" + sSmtpIp + "', "
                                 + "smtp_user='" + sSmtpUser + "', "
                                 + "smtp_pass='" + sSmtpPass + "', "
                                 + "mail_address='" + sAddress + "' "
                                 + "where username = '" + sUsername + "'";
                }
                else
                {
                    sUpdateQuery = "insert into mail_setting values('" + sUsername + "', '"
                                                                       + sPop3Ip + "', '"
                                                                       + sPop3User + "', '"
                                                                       + sPop3Pass + "', '"
                                                                       + sSmtpIp + "', '"
                                                                       + sSmtpUser + "', '"
                                                                       + sSmtpPass + "', '"
                                                                       + sAddress +"') ";
                }
                stmt.executeUpdate( sUpdateQuery );
                
                return true;
            }
            catch(Exception e)
            {
                e.printStackTrace();
                mySession.setAttribute("errMsg","登录邮箱设置时出现错误！");
                return false;
            }
            finally
            {
                try
                {
                    rs.close();
                    stmt.close();
                }catch(Exception ex)
                {
                }
            }
        }catch(Exception ex)
        {
            ex.printStackTrace();
            mySession.setAttribute("errMsg","登录邮箱设置时出现错误！");
            return false;
        }
    }
    
    public boolean getSettingInfo( HttpSession mySession )
    {
//      设置用户信息
        Hashtable myValues = (Hashtable)mySession.getAttribute(CommonConst.VIEWID_SETTING);

        String sPop3Ip = "";
        String sPop3User = "";
        String sPop3Pass = "";
        String sSmtpIp = "";
        String sSmtpUser = "";
        String sSmtpPass = "";
        String sAddress = "";
        
        String sUsername = (String)mySession.getAttribute("username");
        
        //尝试查找用户邮箱，如果已经有了，则取得
        try
        {
            //载入MySQL的JDBC驱动类
            Class.forName(CommonConst.DB_DRIVER_CLASSNAME);
            //获得数据库连接
            Connection conn = DriverManager.getConnection( CommonConst.DB_CONN_STRING );

            Statement stmt = null;
            ResultSet rs = null;
            
            try
            {
                //检查数据库中是否已经有该用户了
                stmt = conn.createStatement();
                //更新DB的SQL语句
                String sUpdateQuery = "";
                
                //执行SQL语句
                String sQuery = "select * from mail_setting where username='" + sUsername + "'";
                rs = stmt.executeQuery( sQuery );
                if (rs.next() )
                {
                    sPop3Ip   = rs.getString(2);
                    sPop3User = rs.getString(3);
                    sPop3Pass = rs.getString(4);
                    sSmtpIp   = rs.getString(5);
                    sSmtpUser = rs.getString(6);
                    sSmtpPass = rs.getString(7);
                    sAddress  = rs.getString(8);
                    
                    myValues.put("pop3Ip",   sPop3Ip);
                    myValues.put("pop3User", sPop3User);
                    myValues.put("pop3Pass", sPop3Pass);
                    myValues.put("smtpIp",   sSmtpIp);
                    myValues.put("smtpUser", sSmtpUser);
                    myValues.put("smtpPass", sSmtpPass);
                    myValues.put("address",  sAddress);
                    
                    return true;
                }
                else
                {
                    return false;
                }
            }
            catch(Exception e)
            {
                e.printStackTrace();
                mySession.setAttribute("errMsg","查找邮箱设置时出现错误！");
                return false;
            }
            finally
            {
                try
                {
                    rs.close();
                    stmt.close();
                }catch(Exception ex)
                {
                }
            }
        }catch(Exception ex)
        {
            ex.printStackTrace();
            mySession.setAttribute("errMsg","查找邮箱设置时出现错误！");
            return false;
        }
    }
}