`

ADO.NET—DataHelper(转)

    博客分类:
  • C#
阅读更多
using System;
using System.Data;
using System.Data.SqlClient;
using System.Text;
namespace Document
{
    /**//// <summary>
    /// Summary description for DataHelper.
    /// </summary>
    public class DataHelper
    {
        public DataHelper()
        {
            //
            // TODO: Add constructor logic here
            //
        }
        public static string ConnectionString=System.Configuration.ConfigurationSettings.AppSettings["ConnectionString"];
    
        #region GetDataSet
        public static DataSet GetDataSet(string sql)
        {
            SqlDataAdapter    sda =new SqlDataAdapter(sql,ConnectionString);
            DataSet ds=new DataSet();
            sda.Fill(ds);
            return ds;
        }
        #endregion

        #region ExecCommand
        public static int ExecCommand(SqlCommand sqlcom)
        {
            SqlConnection conn=new SqlConnection(ConnectionString);
            sqlcom.Connection =conn;
            conn.Open();
            try
            {
                int rtn=sqlcom.ExecuteNonQuery();
                return rtn;
            }
            catch(Exception ex) 
            {
                throw ex;                
            }
            finally
            {
                conn.Close();
            }
            return 0;

        }
        public static int ExecCommand(string sql)
        {
            if (sql.EndsWith(",")) sql=sql.Substring(0,sql.Length-1);
        
            SqlCommand sqlcom=new SqlCommand(sql);
            return ExecCommand(sqlcom);                
        }
        #endregion
        
        #region ExecuteScalar
        public static object ExecuteScalar(string sql)
        {
            SqlConnection conn=new SqlConnection(ConnectionString);
            SqlCommand sqlcom=new SqlCommand(sql,conn);
            conn.Open();
            try
            {
                object rtn=sqlcom.ExecuteScalar ();
                return rtn;
            }
            catch(Exception ex) 
            {
                throw ex;                
            }
            finally
            {
                conn.Close();
            }
            return null;
        }
        #endregion

        #region ExecSPCommand
        public static void ExecSPCommand(string sql,System.Data.IDataParameter[] paramers)
        {
            SqlConnection conn=new SqlConnection(ConnectionString);
            SqlCommand sqlcom=new SqlCommand(sql,conn);
            sqlcom.CommandType= CommandType.StoredProcedure ;

            foreach(System.Data.IDataParameter paramer in paramers)
            {
                sqlcom.Parameters.Add(paramer);
            }            
            conn.Open();
            try
            {
                sqlcom.ExecuteNonQuery();
            }
            catch(Exception ex) 
            {
                string s=ex.Message ;
            }
            finally
            {
                conn.Close();
            }
        }
        #endregion

        #region ExecSPDataSet
        public static DataSet ExecSPDataSet(string sql,System.Data.IDataParameter[] paramers)
        {
            SqlConnection conn=new SqlConnection(ConnectionString);
            SqlCommand sqlcom=new SqlCommand(sql,conn);
            sqlcom.CommandType= CommandType.StoredProcedure ;

            foreach(System.Data.IDataParameter paramer in paramers)
            {
                sqlcom.Parameters.Add(paramer);
            }            
            conn.Open();
            
            SqlDataAdapter da=new SqlDataAdapter();
            da.SelectCommand=sqlcom;
            DataSet ds=new DataSet();
            da.Fill(ds);
        
            conn.Close();
            return ds;
        }

        #endregion

        #region DbType
        private static System.Data.DbType GetDbType(Type type)
        {
            DbType result = DbType.String;
            if( type.Equals(typeof(int)) ||  type.IsEnum)
                result = DbType.Int32;
            else if( type.Equals(typeof(long)))
                result = DbType.Int32;
            else if( type.Equals(typeof(double)) || type.Equals( typeof(Double)))
                result = DbType.Decimal;
            else if( type.Equals(typeof(DateTime)))
                result = DbType.DateTime;
            else if( type.Equals(typeof(bool)))
                result = DbType.Boolean;
            else if( type.Equals(typeof(string) ) )
                result = DbType.String;
            else if( type.Equals(typeof(decimal)))
                result = DbType.Decimal;
            else if( type.Equals(typeof(byte[])))
                result = DbType.Binary;
            else if( type.Equals(typeof(Guid)))
                result = DbType.Guid;
        
            return result;
            
        }

        #endregion

        #region UpdateTable
        public static void UpdateTable(DataTable dt,string TableName,string KeyName)
        {
            foreach(DataRow dr in dt.Rows)
            {
                updateRow(dr,TableName,KeyName);
            }
        }
        #endregion

        #region InsertTable
        //用于主键是数据库表名+ID类型的
        public static void InsertTable(DataTable dt)
        {
            string TableName="["+dt.TableName+"]";
            string KeyName=dt.TableName+"ID";
            foreach(DataRow dr in dt.Rows)
            {
                insertRow(dr,TableName,KeyName);
            }
        }
        //用于主键是任意类型的
        public static void InsertTable(DataTable dt,string KeyName)
        {
            string TableName="["+dt.TableName+"]";
            foreach(DataRow dr in dt.Rows)
            {
                insertRow(dr,TableName,KeyName);
            }
        }
        #endregion

        #region DeleteTable
        public static void DeleteTable(DataTable dt,string KeyName)
        {
            string TableName="["+dt.TableName+"]";
            foreach(DataRow dr in dt.Rows)
            {
                deleteRow(dr,TableName,KeyName);
            }
        }
        #endregion

        #region updateRow
        private static void  updateRow(DataRow dr,string TableName,string KeyName)
        {
            if (dr[KeyName]==DBNull.Value ) 
            {
                throw new Exception(KeyName +"的值不能为空");
            }
            
            if (dr.RowState ==DataRowState.Deleted)
            {
                deleteRow(dr,TableName,KeyName);
 
            }
            else if (dr.RowState ==DataRowState.Modified )
            {
                midifyRow(dr,TableName,KeyName);
            }
            else if (dr.RowState ==DataRowState.Added  )
            {
                insertRow(dr,TableName,KeyName);
            }
            else if (dr.RowState ==DataRowState.Unchanged )
            {
                midifyRow(dr,TableName,KeyName);
            }           
        }

        #endregion

        #region deleteRow
        private static void  deleteRow(DataRow dr,string TableName,string KeyName)
        {
            string sql="Delete {0} where {1} =@{1}";
            DataTable dtb=dr.Table ;
            sql=string.Format(sql,TableName,KeyName);

            SqlCommand sqlcom=new SqlCommand(sql);
            System.Data.IDataParameter iparam=new  SqlParameter();
            iparam.ParameterName    = "@"+ KeyName;
            iparam.DbType            = GetDbType(dtb.Columns[KeyName].DataType);
            iparam.Value            = dr[KeyName];
            sqlcom.Parameters .Add(iparam);
            
            ExecCommand(sqlcom);
        }
        #endregion

        #region midifyRow
        private static void  midifyRow(DataRow dr,string TableName,string KeyName)
        {
            string UpdateSql            = "Update {0} set {1} {2}";
            string setSql="{0}= @{0}";
            string wherSql=" Where {0}=@{0}";
            StringBuilder setSb    = new StringBuilder();

            SqlCommand sqlcom=new SqlCommand();
            DataTable dtb=dr.Table;
        
            for (int k=0; k<dr.Table.Columns.Count; ++k)
            {
                System.Data.IDataParameter iparam=new  SqlParameter();
                iparam.ParameterName    = "@"+ dtb.Columns[k].ColumnName;
                iparam.DbType            = GetDbType(dtb.Columns[k].DataType);
                iparam.Value            = dr[k];
                sqlcom.Parameters .Add(iparam);

                if (dtb.Columns[k].ColumnName==KeyName)
                {
                    wherSql=string.Format(wherSql,KeyName);
                }
                else
                {
                    setSb.Append(string.Format(setSql,dtb.Columns[k].ColumnName));    
                    setSb.Append(",");
                }
                
            }
            
            string setStr=setSb.ToString();
            setStr=setStr.Substring(0,setStr.Length -1); //trim ,
            
            string sql = string.Format(UpdateSql, TableName, setStr,wherSql);
            sqlcom.CommandText =sql;    
            try
            {
                ExecCommand(sqlcom);
            }
            catch(Exception ex)
            {
                throw ex;            
            }
        }
        #endregion

        #region insertRow
        private static void  insertRow(DataRow dr,string TableName,string KeyName)
        {
            string InsertSql = "Insert into {0}({1}) values({2})";
            SqlCommand sqlcom=new SqlCommand();
            DataTable dtb=dr.Table ;
            StringBuilder insertValues    = new StringBuilder();
            StringBuilder cloumn_list    = new StringBuilder();
            for (int k=0; k<dr.Table.Columns.Count; ++k)
            {
                //just for genentae,
                if (dtb.Columns[k].ColumnName==KeyName) continue;
                System.Data.IDataParameter iparam=new  SqlParameter();
                iparam.ParameterName    = "@"+ dtb.Columns[k].ColumnName;
                iparam.DbType            = GetDbType(dtb.Columns[k].DataType);
                iparam.Value            = dr[k];
                sqlcom.Parameters .Add(iparam);

                cloumn_list.Append(dtb.Columns[k].ColumnName);
                insertValues.Append("@"+dtb.Columns[k].ColumnName);

                cloumn_list.Append(",");
                insertValues.Append(",");
            }
            
            string cols=cloumn_list.ToString();
            cols=cols.Substring(0,cols.Length -1);

            string values=insertValues.ToString();
            values=values.Substring(0,values.Length -1);
            
            string sql = string.Format(InsertSql, TableName,cols ,values);
            sqlcom.CommandText =sql;    
            try
            {
                ExecCommand(sqlcom);
            }
            catch(Exception ex)
            {
                throw ex;
            }
        }
        #endregion
    }
2..调用范例
        #region Insert
        private void InsertUserInfo()
        {
            DataTable dt=ds.Tables[0];
            dt.TableName="UserInfo";
                string keyname="UserInfoID";
            DataRow dr=dt.NewRow();
            dr["LoginName"]=this.txtUserName.Value;
            dr["Pass"]=this.txtPassword.Value;
            dr["NickName"]=this.txtNickName.Value;
            dr["UserType"]=1;
            dr["IsActive"]=false;
            dr["RegisterDate"]=System.DateTime.Now;
            dt.Rows.Add(dr);
            dt.AcceptChanges();
            DataHelper.InsertTable(dt,keyname);
        }
        #endregion

        #region Update
        private void UpdateUserInfo(string UserID)
        {            
            DataSet ds=GetUserOther(UserID);
            DataTable dt=ds.Tables[0];
            dt.TableName="UserInfo";
                string keyname="UserID";
            DataRow dr=dt.Rows[0];
            dr["LoginName"]=this.txtUserName.Value;
            dr["Pass"]=this.txtPassword.Value;
            dr["NickName"]=this.txtNickName.Value;
            dr["UserType"]=1;
            dr["IsActive"]=false;
            dr["RegisterDate"]=System.DateTime.Now;
            dt.Rows.Add(dr);
            dt.AcceptChanges();
            DataHelper.UpdateTable(dt,dt.TableName,keynanme);
        }

        #endregion

        #region Delete
        private void DeleteUserInfo(string UserID)
        {            
            DataSet ds=GetUserOther(UserID);
            DataTable dt=ds.Tables[0];
            dt.TableName="UserInfo";            
                string keyname="UserID";
            DataHelper.DeleteTable(dt,keyname);
        }
        #endregion

 

分享到:
评论

相关推荐

    DBHelper 数据库帮助类

    在这个主题中,我们将深入探讨 `DBHelper` 数据库帮助类,以及与之相关的 `DataHelper` 和 `ADO`(即 ADO.NET)技术。 `DBHelper` 是一个自定义的数据库操作类,它封装了对数据库的基本操作,如连接、查询、插入、...

    asp.net EasyPlatNet 学习项目

    它通常使用ADO.NET或ORM(Object-Relational Mapping)工具如Entity Framework来实现。在本项目中,"DAL"目录下的代码可能包含了数据库连接、SQL语句或存储过程的封装。 **6. DB_51aspx** 这个目录可能包含了数据库...

    dataHelper

    本文将深入探讨标题为"dataHelper"的相关知识点,包括如何使用各种数据库连接,如SQL Server、Oracle、Access、Db(可能指的是SQLite或ODBC)以及MySQL。 首先,我们来看`SqlHelper.cs`,这通常是一个通用的SQL ...

    DataHelper

    《DataHelper:数据库操作与防注入的利器》 在IT行业中,数据库操作是不可或缺的一部分,尤其是在开发业务系统时。为了简化这一过程并提高代码的可维护性,开发者常常会创建工具类库,如"DataHelper",以实现对...

    DataHelper.cs 完全

    DataHelper.cs 完全 DataHelper.cs 完全 DataHelper.cs 完全 DataHelper.cs 完全 DataHelper.cs 完全 DataHelper.cs 完全

    C#,一份非常实用的DataHelper类

    C#,一份非常实用的DataHelper类,自己收集了一年多的帮助类。,自己收集了一年多的帮助类。,自己收集了一年多的帮助类。

    C#语言SQL+Access+Oracle通用版数据库操作类源码

    C#的ADO.NET框架为数据库操作提供了基础支持,它包括DataSet、DataTable、DataColumn、DataRow等对象,以及SqlConnection、SqlCommand、SqlDataAdapter等类,这些都可以在`DataHelper.cs` 和 `Tools.cs` 中得到应用...

    C#.NET用来遍历DataSet的代码

    1. **DataSet**:它是ADO.NET中的一个离线数据缓存机制,用于在应用程序内存中创建一个完整的数据表结构的副本。 2. **DataTable**:`DataSet`由一个或多个`DataTable`对象组成,每个`DataTable`表示数据库中的一个...

    js代码-DataHelper

    在JavaScript编程中,`DataHelper`通常是指一个辅助类或者模块,用于处理数据相关的操作。这个压缩包包含了一个名为`main.js`的主要脚本文件和一个`README.txt`的说明文件。在这里,我们将主要探讨`DataHelper`在...

    ETS2.DataHelper

    ETS2.DataHelperETS2.DataHelperETS2.DataHelperETS2.DataHelperETS2.DataHelperETS2.DataHelper

    数据压缩修复助手(DataHelper) v1.0 Build 5621

    数据压缩修复助手(DataHelper) v1.0 Build 5621 是一款专门针对Access数据库设计的应用软件,它集成了多种实用功能,如数据压缩、数据库修复和文件格式转换,旨在帮助用户更有效地管理和维护他们的Access数据库。...

    DataHelper类

    DataHelper类 通用的哦.支持sql server 以及oracle

    C#中DBhelper类文件下载

    首先,DBhelper类通常会依赖ADO.NET组件,如SqlConnection、SqlCommand、SqlDataAdapter等,用于连接SQL Server数据库并执行SQL语句。在DBhelper.cs文件中,我们可以期待看到如下关键组成部分: 1. **数据库连接...

    人力资源管理 源码

    - "Utils"和"DB_51aspx"以及"DataHelper"可能是两个不同的文件夹,Utils可能包含通用的辅助函数库,DB_51aspx可能与数据库操作有关,DataHelper则可能是数据访问层的代码。 - "UI"文件夹很可能包含了系统的用户界面...

    .net连接mysql

    在.NET开发环境中,连接MySQL数据库是一项常见的任务,尤其在C#编程中。为了实现这一功能,我们可以使用`MySql.Data.dll`库,这是一个由Oracle官方提供的.NET数据提供者,专门用于与MySQL数据库进行交互。本篇文章将...

    新闻发布系统源码 新闻发布系统 小型新闻发布系统源码

    - `HeYang.DAL`: 数据访问层,通常包含与数据库交互的类,如ADO.NET的DataSet、DataTable,或者是ORM框架如Entity Framework的实体类。 - `HeYang.DataHelper`: 数据访问助手类,封装了数据库操作的常用方法,如增...

    基于C# 的网络爬虫源程序

    5. **数据库操作**:如Entity Framework或ADO.NET,用于与数据库交互,存储爬取结果。 **项目结构** 从提供的文件名来看,我们可以推测项目包含以下部分: - **WebHelper.sln**:这是Visual Studio解决方案文件,...

    新闻发布系统(asp.net与flex通信) v1.1

    HeYang.DataHelper 数据访问层(连接数据库、执行操作) HeYang.Model 实体类 (数据传输) Web web页面 NewsInfo.sql 数据库脚本 开发环境SQLServer2005+vs2005 前台是拿DIV+CSS(兼容IE5.5,IE6,IE7,IE8,火狐,...

    赫阳新闻发布系统(asp.net与flex通信) v1.1.rar

    HeYang.DataHelper 数据访问层(连接数据库、执行操作) HeYang.Model 实体类 (数据传输) Web web页面 NewsInfo.sql 数据库脚本 开发环境SQLServer2005 vs2005 前台是拿DIV CSS(兼容IE5.5,IE6,IE7,IE8,...

Global site tag (gtag.js) - Google Analytics