aconn.cs

搜索网上电子邮件,加入url就可搜索,用c#编写

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.OleDb;
/// <summary>
/// Summary description for AConn
/// </summary>
public class AConn
{
    private static string _strconn = @"Provider=Microsoft.Jet.OLEDB.4.0;Data Source="+HttpContext.Current.Server.MapPath("~/")+@"\App_Data\MailAuto.mdb";
    OleDbConnection _conn = new OleDbConnection(_strconn);
	public AConn()
	{
		//
		// TODO: Add constructor logic here
		//
	}
    /// <summary>
    /// 获取结果集
    /// </summary>
    /// <param name="sql"></param>
    /// <returns></returns>
    public DataSet GetDataSet(string sql)
    {
        _conn.Open();

       //  OleDbCommand comm = new OleDbCommand("select * from Record",_conn);
        DataSet ds=new DataSet();
        try
        {
            OleDbDataAdapter adapter = new OleDbDataAdapter(sql, _conn);
            adapter.Fill(ds);
        }
        catch (Exception ex)
        {
            handleError(ex.Message+sql);
        }
        _conn.Close();
        return ds;
    }
    /// <summary>
    /// 获取影响的条数
    /// </summary>
    /// <param name="sql"></param>
    /// <returns></returns>
    public int GetCount(string sql)
    {
        int n =-1;
        _conn.Open();
        try
        {
            OleDbCommand comm = new OleDbCommand(sql, _conn);
            n = comm.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            handleError(ex.Message+sql);
        }
        _conn.Close();
        return n;
    }
    /// <summary>
    /// 获取第一个记录
    /// </summary>
    /// <param name="sql"></param>
    /// <returns></returns>
    public object GetScalar(string sql)
    {
        object n="";
        _conn.Open();
        try
        {
            OleDbCommand comm = new OleDbCommand(sql, _conn);
            n = comm.ExecuteScalar();
        }
        catch (Exception ex)
        {
            handleError(ex.Message+sql);
        }
        _conn.Close();
        return n;
    }
    /// <summary>
    /// 错误处理
    /// </summary>
    /// <param name="msg"></param>
    private void handleError(string msg)
    {
        HttpContext.Current.Response.Write(msg);
    }
}