dataoperate.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;

/// <summary>
/// dataOperate 的摘要说明
/// </summary>
public class dataOperate
{
	public dataOperate()
	{
		//
		// TODO: 在此处添加构造函数逻辑
		//
	}

    /********************************************************************
     * 获取数据集       
     * ******************************************************************/
    public string GetDataSet(string sql, ref DataSet ds, string dsName)
    {
        //获取数据集DataSet
        string sRet = "";
        SqlConnection con = DB.CreateConnection();
        con.Open();
        try
        {
            SqlDataAdapter sda = new SqlDataAdapter();
            sda.SelectCommand = new SqlCommand(sql, con);
            sda.Fill(ds, dsName);
        }
        catch (Exception ex)
        {
            sRet = ex.Message.ToString();
        }
        con.Close();
        return sRet;
    }

    /********************************************************************
     * 执行sql语句      
     * ******************************************************************/
    public string ExecuteNonQuery(string sql)
    {
        string sRet = "";
        int count = 0;
        SqlConnection con = DB.CreateConnection();
        con.Open();
        SqlCommand cmd = new SqlCommand(sql, con);

        try
        {
            count = cmd.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            sRet = ex.Message.ToString();
        }

        con.Close();

        if (sRet == "" && count <= 0)
        {
            sRet = "记录不存在！";
        }
        return sRet;
    }

    /********************************************************************
     * 执行sql语句返回首行首列    
     * ******************************************************************/
    public string ExecuteScalar(string sql, ref string result)
    {
        string sRet = "";
        SqlConnection con = DB.CreateConnection();
        con.Open();
        SqlCommand cmd = new SqlCommand(sql, con);

        try
        {
            result = cmd.ExecuteScalar().ToString();
        }
        catch (Exception ex)
        {
            sRet = ex.Message.ToString();
        }
        
        con.Close();
        return sRet;
    }

    /********************************************************************
     * 获取数据集       
     * ******************************************************************/

    /********************************************************************
     * 获取数据集       
     * ******************************************************************/
}