dbconnector.cs

简单的Web平台。能够读取Excel文件

using System;
using System.Data;
using System.Data.SqlClient;
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;

/// <summary>
/// DBConnector 的摘要说明
/// </summary>
public class DBConnector
{
	public DBConnector()
    {

    }

    ~DBConnector()
    {
        
    }

    /// <summary>
    /// 连接到数据库
    /// </summary>
    /// <returns>成功返回true,失败返回false</returns>
    public bool Connect()
    {
        try
        {
            //m_sqlConn = new SqlConnection( m_strConn );
            m_sqlConn.Open();
        }
        catch (SqlException ex)
        {
            return false;
        }
        return true;
    }

    public void Close()
    {
        m_sqlConn.Close();
    }

    /// <summary>
    /// 查询
    /// </summary>
    /// <param name="strSQL">SQL语句</param>
    /// <returns>成功返回包含结果的DataSet对象</returns>
    public DataSet Query(string strSQL)
    {
        if ( m_sqlConn.State == ConnectionState.Closed )
            m_sqlConn.Open();

        DataSet dsResult = new DataSet();
        try
        {
            SqlDataAdapter sqlAdp = new SqlDataAdapter(strSQL, m_sqlConn);
            sqlAdp.Fill( dsResult );
        }
        catch(SqlException ex)
        {            
            return null;
        }
        
        return dsResult;
    }

    public int QueryIntValue(string strSQL)
    {
        if (m_sqlConn.State == ConnectionState.Closed)
            m_sqlConn.Open();
        
        try
        {
            SqlCommand sqlComm = new SqlCommand( strSQL, m_sqlConn );
            // int iVal = (Int32)sqlComm.ExecuteScalar();
            return (Int32)sqlComm.ExecuteScalar();
        }
        catch(Exception ex)
        {            
            return Int32.MinValue;
        }     
    }

    public string QueryString(string strSQL)
    {
        if (m_sqlConn.State == ConnectionState.Closed)
            m_sqlConn.Open();
        
        try
        {
            SqlCommand sqlComm = new SqlCommand( strSQL, m_sqlConn );
            // string strVal = sqlComm.ExecuteScalar().ToString();
            return sqlComm.ExecuteScalar().ToString();
        }
        catch(Exception ex)
        {            
            return null;
        }
    }

    public int Execute(string strSQL)
    {
        if (m_sqlConn.State == ConnectionState.Closed)
            m_sqlConn.Open();

        try
        {
            SqlCommand sqlComm = new SqlCommand( strSQL, m_sqlConn );
            // int iRows = sqlComm.ExecuteNonQuery();

            return sqlComm.ExecuteNonQuery();
        }
        catch(SqlException ex)
        {            
            return -1;
        }
    }

    public int Execute(SqlCommand sqlComm)
    {
        if (m_sqlConn.State == ConnectionState.Closed)
            m_sqlConn.Open();

        int iEffectRows;
        try
        {
            sqlComm.Connection = m_sqlConn;
            iEffectRows = sqlComm.ExecuteNonQuery();
        }
        catch(SqlException ex)
        {            
            return -1;
        }
        
        return iEffectRows;
    }

    public string GetConnectString()
    {
        return m_strConn;
    }

    private const string m_strConn = "server=.;uid=sa;pwd=;database=ZCJ";
    private SqlConnection m_sqlConn = new SqlConnection( m_strConn );
}