点击这里给我发消息 点击这里给我发消息

Asp.net(c#)数据库操作类

添加时间:2013-12-6
    相关阅读: 数据库 Mysql
[csharp]  
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; 
namespace Mysqlserver 

    /// <summary> 
    /// SqlServerDataBase 的摘要说明 
    /// </summary> 
    public class SqlServerDataBase 
    { 
        private string strError = null; 
        private int intCount = 0; 
        public SqlServerDataBase() 
        { 
            // 
            // TODO: 在此处添加构造函数逻辑 
            // 
        } 
        /// <summary> 
        /// 公开方法DBConn,返回数据库连接 
        /// </summary> 
        /// <returns></returns> 
        public SqlConnection DBconn() 
        { 
            string strConn = "Server=(local);Database=GlobalMeetings;Uid=sa;pwd="; 
            try 
            { 
                return new SqlConnection(strConn); 
            } 
            catch (Exception) 
            { 
                return null; 
            } 
        } 
        /// <summary> 
        /// 公开属性ErrorMessage,返回错误信息 
        /// </summary> 
        public string ErrorMessage 
        { 
            get 
            { 
                return strError; 
            } 
        } 
 
        /// <summary> 
        /// 根据查询语句从数据库检索数据 
        /// </summary> 
        /// <param name="strSelect">查询语句</param> 
        /// <param name="SqlConn">数据库连接</param> 
        /// <returns>有数据则返回DataSet对象,否则返回null</returns> 
        public DataSet Select(string SelectString, SqlConnection sqlConn) 
        { 
            strError = ""; 
            SqlConnection conn; 
            if (sqlConn == null) 
            { 
                conn = DBconn(); 
            } 
            else 
            { 
                conn = sqlConn; 
            } 
            try 
            { 
                //若数据库连接的当前状态是关闭的,则打开连接 
                if (conn.State == ConnectionState.Closed) 
                { 
                    conn.Open(); 
                } 
                SqlDataAdapter mySqlDataAdapter = new SqlDataAdapter(); 
                SqlCommand selectCommand = new SqlCommand(SelectString, conn); 
                selectCommand.CommandType = CommandType.Text; 
                mySqlDataAdapter.SelectCommand = selectCommand; 
                DataSet myDS = new DataSet(); 
                mySqlDataAdapter.Fill(myDS); 
                return myDS; 
            } 
            catch (Exception e) 
            { 
                strError = "数据检索失败:" + e.Message; 
                return null; 
            } 
            finally 
            { 
                if (conn.State != ConnectionState.Closed) 
                { 
                    conn.Close(); 
                } 
            } 
        } 
        /// <summary> 
        /// 更新数据库 
        /// </summary> 
        /// <param name="UpdateString">Update Sql语句</param> 
        /// <param name="SqlConn">数据库连接</param> 
        /// <returns>更新成功返回true</returns> 
        public bool Update(string UpdateString, SqlConnection SqlConn) 
        { 
            return udiDataBase(UpdateString, SqlConn); 
        } 
        /// <summary> 
        /// 从数据库中删除数据 
        /// </summary> 
        /// <param name="DeleteString">Delete Sql语句</param> 
        /// <param name="SqlConn">数据库连接</param> 
        /// <returns>删除成功返回true</returns> 
        public bool Delete(string DeleteString, SqlConnection SqlConn) 
        { 
            return udiDataBase(DeleteString, SqlConn); 
        } 
        /// <summary> 
        /// 把数据插入数据库 
        /// </summary> 
        /// <param name="InsertString">Insert Sql语句</param> 
        /// <param name="SqlConn">数据库连接</param> 
        /// <returns>插入成功返回true</returns> 
        public bool Insert(string InsertString, SqlConnection SqlConn) 
        { 
            return udiDataBase(InsertString, SqlConn); 
        } 
        /// <summary> 
        /// 根据Sql语句更新数据库 
        /// </summary> 
        /// <param name="UDIString">更新语句</param> 
        /// <param name="SqlConn">数据库连接</param> 
        /// <returns>更新成功则返回true</returns> 
        public bool udiDataBase(string UDIString, SqlConnection SqlConn) 
        { 
            strError = ""; 
            SqlConnection conn; 
            if (SqlConn == null) 
            { 
                conn = DBconn(); 
            } 
            else 
            { 
                conn = SqlConn; 
            } 
            try 
            { 
                if (conn.State == ConnectionState.Closed) 
                { 
                    conn.Open(); 
                } 
                SqlCommand cmd = new SqlCommand(UDIString, conn); 
                cmd.CommandType = CommandType.Text; 
                intCount = cmd.ExecuteNonQuery(); 
                return !(intCount < 1); 
            } 
            catch (Exception e) 
            { 
                strError = "更新数据库失败:" + e.Message; 
                return false; 
            } 
            finally 
            { 
                if (conn.State != ConnectionState.Closed) 
                { 
                    conn.Close(); 
                } 
            } 
        } 
    } 
咨询热线:020-85648757 85648755 85648616 0755-27912581 客服:020-85648756 0755-27912581 业务传真:020-32579052
广州市网景网络科技有限公司 Copyright◎2003-2008 Veelink.com. All Rights Reserved.
广州商务地址:广东省广州市黄埔大道中203号(海景园区)海景花园C栋501室
= 深圳商务地址:深圳市宝源路华丰宝源大厦606
研发中心:广东广州市天河软件园海景园区 粤ICP备05103322号 工商注册