folder.cs

自己做的的一个小的邮件系统,上传上去大家一起分享一下

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;

using System.Data.SqlClient;

public interface IFolder
{
    /// <summary>
    /// 获取所有邮箱
    /// </summary>
    /// <returns></returns>
    SqlDataReader GetFolders();
    /// <summary>
    /// 获取单个邮箱
    /// </summary>
    /// <param name="nFolderID"></param>
    /// <returns></returns>
    SqlDataReader GetSingleFolder(int nFolderID);
    /// <summary>
    /// 新建邮箱
    /// </summary>
    /// <param name="sName"></param>
    /// <returns></returns>
    int NewFolder(string sName);
    /// <summary>
    /// 重命名邮箱
    /// </summary>
    /// <param name="nFolderID"></param>
    /// <param name="sName"></param>
    /// <returns></returns>
    int RenameFolder(int nFolderID, string sName);
    /// <summary>
    /// 删除邮箱
    /// </summary>
    /// <param name="nFolderID"></param>
    /// <returns></returns>
    int DeleteFolder(int nFolderID);

    //设置邮件数量
    void SetMails(int nFolderID,int nFoderID1);

    void SetMailDelete(int nFolderID);

    void SetMailDeleteT(int nFolderID);
}

/// <summary>
/// Folder 的说明
/// </summary>
public class Folder : IFolder
{
    #region IFolder 成员

    public SqlDataReader GetFolders()
    {
        ///创建链接
        SqlConnection myConnection = new SqlConnection(
            ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString);

        ///定义SQL语句
        string cmdText = "SELECT * FROM Folders";
        ///创建Command
        SqlCommand myCommand = new SqlCommand(cmdText, myConnection);

        ///定义DataReader
        SqlDataReader dr = null;
        try
        {
            ///打开链接
            myConnection.Open();
            ///读取数据
            dr = myCommand.ExecuteReader(CommandBehavior.CloseConnection);
        }
        catch (SqlException ex)
        {
            ///抛出异常
            throw new Exception(ex.Message, ex);
        }
        ///返回DataReader
        return dr;
    }

    public SqlDataReader GetSingleFolder(int nFolderID)
    {
        ///创建链接
        SqlConnection myConnection = new SqlConnection(
            ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString);

        ///定义SQL语句
        string cmdText = "SELECT * FROM Folders WHERE FolderID='" + nFolderID.ToString() + "'";
        ///创建Command
        SqlCommand myCommand = new SqlCommand(cmdText, myConnection);

        ///定义DataReader
        SqlDataReader dr = null;
        try
        {
            ///打开链接
            myConnection.Open();
            ///读取数据
            dr = myCommand.ExecuteReader(CommandBehavior.CloseConnection);
        }
        catch (SqlException ex)
        {
            ///抛出异常
            throw new Exception(ex.Message, ex);
        }
        ///返回DataReader
        return dr;
    }

    public int NewFolder(string sName)
    {
        ///创建链接
        SqlConnection myConnection = new SqlConnection(
            ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString);

        ///定义SQL语句
        string cmdText = "INSERT INTO Folders (Name,Total,NoReader,Contain,Flag,CreateDate)VALUES("
            + "'" + sName + "',"
            + "'0" + "',"
            + "'0" + "',"
            + "'0" + "',"
            + "'1" + "',"
            + "GetDate()"
            + ")";
        ///创建Command
        SqlCommand myCommand = new SqlCommand(cmdText, myConnection);

        ///定义返回值
        int nResult = -1;

        try
        {
            ///打开链接
            myConnection.Open();
            ///执行SQL语句
            nResult = myCommand.ExecuteNonQuery();
        }
        catch (SqlException ex)
        {
            ///抛出异常
            throw new Exception(ex.Message, ex);
        }
        finally
        {   ///关闭链接
            myConnection.Close();
        }
        ///返回nResult
        return nResult;
    }

    public int RenameFolder(int nFolderID, string sName)
    {
        ///创建链接
        SqlConnection myConnection = new SqlConnection(
            ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString);

        ///定义SQL语句
        string cmdText = "UPDATE Folders SET Name ="
            + "'" + sName + "'"
            + " WHERE FolderID='" + nFolderID.ToString() + "'";
        ///创建Command
        SqlCommand myCommand = new SqlCommand(cmdText, myConnection);

        ///定义返回值
        int nResult = -1;

        try
        {
            ///打开链接
            myConnection.Open();
            ///执行SQL语句
            nResult = myCommand.ExecuteNonQuery();
        }
        catch (SqlException ex)
        {
            ///抛出异常
            throw new Exception(ex.Message, ex);
        }
        finally
        {   ///关闭链接
            myConnection.Close();
        }
        ///返回nResult
        return nResult;
    }

    public int DeleteFolder(int nFolderID)
    {
        ///创建链接
        SqlConnection myConnection = new SqlConnection(
            ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString);

        ///定义SQL语句
        string cmdText = "Delete Folders "
            + " WHERE FolderID='" + nFolderID.ToString() + "'";
        ///创建Command
        SqlCommand myCommand = new SqlCommand(cmdText, myConnection);

        ///定义返回值
        int nResult = -1;

        try
        {
            ///打开链接
            myConnection.Open();
            ///执行SQL语句
            nResult = myCommand.ExecuteNonQuery();
        }
        catch (SqlException ex)
        {
            ///抛出异常
            throw new Exception(ex.Message, ex);
        }
        finally
        {   ///关闭链接
            myConnection.Close();
        }
        ///返回nResult
        return nResult;
    }

    //nFolderID1为发信箱的ID
    public void SetMails(int nFolderID,int nFoderID1)
    {
        string connStr = ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString;
        SqlConnection conn = new SqlConnection(connStr);

        string SqlStr = "update Folders set Total=Total+1,NoReader=NoReader+1 where FolderID="+nFolderID;
        string SqlStr1 = "update Folders set Total=Total+1 where FolderID=" + nFoderID1;
        try
        {
            if (conn.State.ToString() == "Closed")
                conn.Open();

            SqlCommand comm = new SqlCommand(SqlStr, conn);
            SqlCommand comm1 = new SqlCommand(SqlStr1,conn);
            comm.ExecuteNonQuery();
            comm1.ExecuteNonQuery();

        }
        catch (Exception ex)
        {
            throw new Exception(ex.Message, ex);
        }
    }



    public void SetMailDelete(int nFolderID)
    {
        string connStr = ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString;
        SqlConnection conn = new SqlConnection(connStr);
        string SqlStr = "update Folders set Total=Total-1 where FolderID=" + nFolderID;
        string SqlStrT = "update Folders set Total=Total+1 where FolderID=8";
        
      
        try
        {
            if (conn.State.ToString() == "Closed")
                conn.Open();
            SqlCommand comm = new SqlCommand(SqlStr, conn);
            SqlCommand commT = new SqlCommand(SqlStrT, conn);
            comm.ExecuteNonQuery();
            commT.ExecuteNonQuery();

        }
        catch (Exception ex)
        {
            throw new Exception(ex.Message, ex);
        }
    }



    public void SetMailDeleteT(int nFolderID)
    {
        string connStr = ConfigurationManager.ConnectionStrings["DBConnectionStrings"].ConnectionString;
        SqlConnection conn = new SqlConnection(connStr);
        string SqlStr = "update Folders set Total=0 where FolderID=" + nFolderID;
    
        try
        {
            if (conn.State.ToString() == "Closed")
                conn.Open();
            SqlCommand comm = new SqlCommand(SqlStr, conn);
            comm.ExecuteNonQuery();

        }
        catch (Exception ex)
        {
            throw new Exception(ex.Message, ex);
        }
    }

    #endregion
}//5_1_a_s_p_x.c_o_m