您的位置:首页 > 博客中心 > 数据库 >

四个DBHelper实现

时间:2022-03-14 04:35

0.



建一个通用的处理数据的类

[csharp]
  1. using System;  
  2. using System.Data;  
  3. using System.Data.SqlClient;  
  4. using System.Text;  
  5. namespace Document  
  6. {  
  7.     /**//// <summary>  
  8.     /// Summary description for DataHelper.  
  9.     /// </summary>  
  10.     public class DataHelper  
  11.     {  
  12.         public DataHelper()  
  13.         {  
  14.             //  
  15.             // TODO: Add constructor logic here  
  16.             //  
  17.         }  
  18.         public static string ConnectionString=System.Configuration.ConfigurationSettings.AppSettings["ConnectionString"];  
  19.       
  20.         GetDataSet#region GetDataSet  
  21.         public static DataSet GetDataSet(string sql)  
  22.         {  
  23.             SqlDataAdapter    sda =new SqlDataAdapter(sql,ConnectionString);  
  24.             DataSet ds=new DataSet();  
  25.             sda.Fill(ds);  
  26.             return ds;  
  27.         }  
  28.         #endregion  
  29.   
  30.         ExecCommand#region ExecCommand  
  31.         public static int ExecCommand(SqlCommand sqlcom)  
  32.         {  
  33.             SqlConnection conn=new SqlConnection(ConnectionString);  
  34.             sqlcom.Connection =conn;  
  35.             conn.Open();  
  36.             try  
  37.             {  
  38.                 int rtn=sqlcom.ExecuteNonQuery();  
  39.                 return rtn;  
  40.             }  
  41.             catch(Exception ex)   
  42.             {  
  43.                 throw ex;                  
  44.             }  
  45.             finally  
  46.             {  
  47.                 conn.Close();  
  48.             }  
  49.             return 0;  
  50.   
  51.         }  
  52.         public static int ExecCommand(string sql)  
  53.         {  
  54.             if (sql.EndsWith(",")) sql=sql.Substring(0,sql.Length-1);  
  55.           
  56.             SqlCommand sqlcom=new SqlCommand(sql);  
  57.             return ExecCommand(sqlcom);                  
  58.         }  
  59.         #endregion  
  60.           
  61.         ExecuteScalar#region ExecuteScalar  
  62.         public static object ExecuteScalar(string sql)  
  63.         {  
  64.             SqlConnection conn=new SqlConnection(ConnectionString);  
  65.             SqlCommand sqlcom=new SqlCommand(sql,conn);  
  66.             conn.Open();  
  67.             try  
  68.             {  
  69.                 object rtn=sqlcom.ExecuteScalar ();  
  70.                 return rtn;  
  71.             }  
  72.             catch(Exception ex)   
  73.             {  
  74.                 throw ex;                  
  75.             }  
  76.             finally  
  77.             {  
  78.                 conn.Close();  
  79.             }  
  80.             return null;  
  81.         }  
  82.         #endregion  
  83.   
  84.         ExecSPCommand#region ExecSPCommand  
  85.         public static void ExecSPCommand(string sql,System.Data.IDataParameter[] paramers)  
  86.         {  
  87.             SqlConnection conn=new SqlConnection(ConnectionString);  
  88.             SqlCommand sqlcom=new SqlCommand(sql,conn);  
  89.             sqlcom.CommandType= CommandType.StoredProcedure ;  
  90.   
  91.             foreach(System.Data.IDataParameter paramer in paramers)  
  92.             {  
  93.                 sqlcom.Parameters.Add(paramer);  
  94.             }              
  95.             conn.Open();  
  96.             try  
  97.             {  
  98.                 sqlcom.ExecuteNonQuery();  
  99.             }  
  100.             catch(Exception ex)   
  101.             {  
  102.                 string s=ex.Message ;  
  103.             }  
  104.             finally  
  105.             {  
  106.                 conn.Close();  
  107.             }  
  108.         }  
  109.         #endregion  
  110.   
  111.         ExecSPDataSet#region ExecSPDataSet  
  112.         public static DataSet ExecSPDataSet(string sql,System.Data.IDataParameter[] paramers)  
  113.         {  
  114.             SqlConnection conn=new SqlConnection(ConnectionString);  
  115.             SqlCommand sqlcom=new SqlCommand(sql,conn);  
  116.             sqlcom.CommandType= CommandType.StoredProcedure ;  
  117.   
  118.             foreach(System.Data.IDataParameter paramer in paramers)  
  119.             {  
  120.                 sqlcom.Parameters.Add(paramer);  
  121.             }              
  122.             conn.Open();  
  123.               
  124.             SqlDataAdapter da=new SqlDataAdapter();  
  125.             da.SelectCommand=sqlcom;  
  126.             DataSet ds=new DataSet();  
  127.             da.Fill(ds);  
  128.           
  129.             conn.Close();  
  130.             return ds;  
  131.         }  
  132.  
  133.         #endregion  
  134.   
  135.         DbType#region DbType  
  136.         private static System.Data.DbType GetDbType(Type type)  
  137.         {  
  138.             DbType result = DbType.String;  
  139.             if( type.Equals(typeof(int)) ||  type.IsEnum)  
  140.                 result = DbType.Int32;  
  141.             else if( type.Equals(typeof(long)))  
  142.                 result = DbType.Int32;  
  143.             else if( type.Equals(typeof(double)) || type.Equals( typeof(Double)))  
  144.                 result = DbType.Decimal;  
  145.             else if( type.Equals(typeof(DateTime)))  
  146.                 result = DbType.DateTime;  
  147.             else if( type.Equals(typeof(bool)))  
  148.                 result = DbType.Boolean;  
  149.             else if( type.Equals(typeof(string) ) )  
  150.                 result = DbType.String;  
  151.             else if( type.Equals(typeof(decimal)))  
  152.                 result = DbType.Decimal;  
  153.             else if( type.Equals(typeof(byte[])))  
  154.                 result = DbType.Binary;  
  155.             else if( type.Equals(typeof(Guid)))  
  156.                 result = DbType.Guid;  
  157.           
  158.             return result;  
  159.               
  160.         }  
  161.  
  162.         #endregion  
  163.   
  164.         UpdateTable#region UpdateTable  
  165.         public static void UpdateTable(DataTable dt,string TableName,string KeyName)  
  166.         {  
  167.             foreach(DataRow dr in dt.Rows)  
  168.             {  
  169.                 updateRow(dr,TableName,KeyName);  
  170.             }  
  171.         }  
  172.         #endregion  
  173.   
  174.         InsertTable#region InsertTable  
  175.         //用于主键是数据库表名+ID类型的  
  176.         public static void InsertTable(DataTable dt)  
  177.         {  
  178.             string TableName="["+dt.TableName+"]";  
  179.             string KeyName=dt.TableName+"ID";  
  180.             foreach(DataRow dr in dt.Rows)  
  181.             {  
  182.                 insertRow(dr,TableName,KeyName);  
  183.             }  
  184.         }  
  185.         //用于主键是任意类型的  
  186.         public static void InsertTable(DataTable dt,string KeyName)  
  187.         {  
  188.             string TableName="["+dt.TableName+"]";  
  189.             foreach(DataRow dr in dt.Rows)  
  190.             {  
  191.                 insertRow(dr,TableName,KeyName);  
  192.             }  
  193.         }  
  194.         #endregion  
  195.   
  196.         DeleteTable#region DeleteTable  
  197.         public static void DeleteTable(DataTable dt,string KeyName)  
  198.         {  
  199.             string TableName="["+dt.TableName+"]";  
  200.             foreach(DataRow dr in dt.Rows)  
  201.             {  
  202.                 deleteRow(dr,TableName,KeyName);  
  203.             }  
  204.         }  
  205.         #endregion  
  206.   
  207.         updateRow#region updateRow  
  208.         private static void  updateRow(DataRow dr,string TableName,string KeyName)  
  209.         {  
  210.             if (dr[KeyName]==DBNull.Value )   
  211.             {  
  212.                 throw new Exception(KeyName +"的值不能为空");  
  213.             }  
  214.               
  215.             if (dr.RowState ==DataRowState.Deleted)  
  216.             {  
  217.                 deleteRow(dr,TableName,KeyName);  
  218.    
  219.             }  
  220.             else if (dr.RowState ==DataRowState.Modified )  
  221.             {  
  222.                 midifyRow(dr,TableName,KeyName);  
  223.             }  
  224.             else if (dr.RowState ==DataRowState.Added  )  
  225.             {  
  226.                 insertRow(dr,TableName,KeyName);  
  227.             }  
  228.             else if (dr.RowState ==DataRowState.Unchanged )  
  229.             {  
  230.                 midifyRow(dr,TableName,KeyName);  
  231.             }             
  232.         }  
  233.  
  234.         #endregion  
  235.   
  236.         deleteRow#region deleteRow  
  237.         private static void  deleteRow(DataRow dr,string TableName,string KeyName)  
  238.         {  
  239.             string sql="Delete {0} where {1} =@{1}";  
  240.             DataTable dtb=dr.Table ;  
  241.             sql=string.Format(sql,TableName,KeyName);  
  242.   
  243.             SqlCommand sqlcom=new SqlCommand(sql);  
  244.             System.Data.IDataParameter iparam=new  SqlParameter();  
  245.             iparam.ParameterName    = "@"+ KeyName;  
  246.             iparam.DbType            = GetDbType(dtb.Columns[KeyName].DataType);  
  247.             iparam.Value            = dr[KeyName];  
  248.             sqlcom.Parameters .Add(iparam);  
  249.               
  250.             ExecCommand(sqlcom);  
  251.         }  
  252.         #endregion  
  253.   
  254.         midifyRow#region midifyRow  
  255.         private static void  midifyRow(DataRow dr,string TableName,string KeyName)  
  256.         {  
  257.             string UpdateSql            = "Update {0} set {1} {2}";  
  258.             string setSql="{0}= @{0}";  
  259.             string wherSql=" Where {0}=@{0}";  
  260.             StringBuilder setSb    = new StringBuilder();  
  261.   
  262.             SqlCommand sqlcom=new SqlCommand();  
  263.             DataTable dtb=dr.Table;  
  264.           
  265.             for (int k=0; k<dr.Table.Columns.Count; ++k)  
  266.             {  
  267.                 System.Data.IDataParameter iparam=new  SqlParameter();  
  268.                 iparam.ParameterName    = "@"+ dtb.Columns[k].ColumnName;  
  269.                 iparam.DbType            = GetDbType(dtb.Columns[k].DataType);  
  270.                 iparam.Value            = dr[k];  
  271.                 sqlcom.Parameters .Add(iparam);  
  272.   
  273.                 if (dtb.Columns[k].ColumnName==KeyName)  
  274.                 {  
  275.                     wherSql=string.Format(wherSql,KeyName);  
  276.                 }  
  277.                 else  
  278.                 {  
  279.                     setSb.Append(string.Format(setSql,dtb.Columns[k].ColumnName));      
  280.                     setSb.Append(",");  
  281.                 }  
  282.                   
  283.             }  
  284.               
  285.             string setStr=setSb.ToString();  
  286.             setStr=setStr.Substring(0,setStr.Length -1); //trim ,  
  287.               
  288.             string sql = string.Format(UpdateSql, TableName, setStr,wherSql);  
  289.             sqlcom.CommandText =sql;      
  290.             try  
  291.             {  
  292.                 ExecCommand(sqlcom);  
  293.             }  
  294.             catch(Exception ex)  
  295.             {  
  296.                 throw ex;              
  297.             }  
  298.         }  
  299.         #endregion  
  300.   
  301.         insertRow#region insertRow  
  302.         private static void  insertRow(DataRow dr,string TableName,string KeyName)  
  303.         {  
  304.             string InsertSql = "Insert into {0}({1}) values({2})";  
  305.             SqlCommand sqlcom=new SqlCommand();  
  306.             DataTable dtb=dr.Table ;  
  307.             StringBuilder insertValues    = new StringBuilder();  
  308.             StringBuilder cloumn_list    = new StringBuilder();  
  309.             for (int k=0; k<dr.Table.Columns.Count; ++k)  
  310.             {  
  311.                 //just for genentae,  
  312.                 if (dtb.Columns[k].ColumnName==KeyName) continue;  
  313.                 System.Data.IDataParameter iparam=new  SqlParameter();  
  314.                 iparam.ParameterName    = "@"+ dtb.Columns[k].ColumnName;  
  315.                 iparam.DbType            = GetDbType(dtb.Columns[k].DataType);  
  316.                 iparam.Value            = dr[k];  
  317.                 sqlcom.Parameters .Add(iparam);  
  318.   
  319.                 cloumn_list.Append(dtb.Columns[k].ColumnName);  
  320.                 insertValues.Append("@"+dtb.Columns[k].ColumnName);  
  321.   
  322.                 cloumn_list.Append(",");  
  323.                 insertValues.Append(",");  
  324.             }  
  325.               
  326.             string cols=cloumn_list.ToString();  
  327.             cols=cols.Substring(0,cols.Length -1);  
  328.   
  329.             string values=insertValues.ToString();  
  330.             values=values.Substring(0,values.Length -1);  
  331.               
  332.             string sql = string.Format(InsertSql, TableName,cols ,values);  
  333.             sqlcom.CommandText =sql;      
  334.             try  
  335.             {  
  336.                 ExecCommand(sqlcom);  
  337.             }  
  338.             catch(Exception ex)  
  339.             {  
  340.                 throw ex;  
  341.             }  
  342.         }  
  343.         #endregion  
  344.     }  
  345. }  
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"];
    
        GetDataSet#region GetDataSet
        public static DataSet GetDataSet(string sql)
        {
            SqlDataAdapter    sda =new SqlDataAdapter(sql,ConnectionString);
            DataSet ds=new DataSet();
            sda.Fill(ds);
            return ds;
        }
        #endregion

        ExecCommand#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
        
        ExecuteScalar#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

        ExecSPCommand#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

        ExecSPDataSet#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

        DbType#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

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

        InsertTable#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

        DeleteTable#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

        updateRow#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

        deleteRow#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

        midifyRow#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

        insertRow#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..调用范例

[csharp]
  1. Insert#region Insert  
  2. private void InsertUserInfo()  
  3. {  
  4.     DataTable dt=ds.Tables[0];  
  5.     dt.TableName="UserInfo";  
  6.         string keyname="UserInfoID";  
  7.     DataRow dr=dt.NewRow();  
  8.     dr["LoginName"]=this.txtUserName.Value;  
  9.     dr["Pass"]=this.txtPassword.Value;  
  10.     dr["NickName"]=this.txtNickName.Value;  
  11.     dr["UserType"]=1;  
  12.     dr["IsActive"]=false;  
  13.     dr["RegisterDate"]=System.DateTime.Now;  
  14.     dt.Rows.Add(dr);  
  15.     dt.AcceptChanges();  
  16.     DataHelper.InsertTable(dt,keyname);  
  17. }  
  18. #endregion  
  19.   
  20. Update#region Update  
  21. private void UpdateUserInfo(string UserID)  
  22. {              
  23.     DataSet ds=GetUserOther(UserID);  
  24.     DataTable dt=ds.Tables[0];  
  25.     dt.TableName="UserInfo";  
  26.         string keyname="UserID";  
  27.     DataRow dr=dt.Rows[0];  
  28.     dr["LoginName"]=this.txtUserName.Value;  
  29.     dr["Pass"]=this.txtPassword.Value;  
  30.     dr["NickName"]=this.txtNickName.Value;  
  31.     dr["UserType"]=1;  
  32.     dr["IsActive"]=false;  
  33.     dr["RegisterDate"]=System.DateTime.Now;  
  34.     dt.Rows.Add(dr);  
  35.     dt.AcceptChanges();  
  36.     DataHelper.UpdateTable(dt,dt.TableName,keynanme);  
  37. }  
  38.  
  39. #endregion  
  40.   
  41. Delete  
        Insert#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

        Update#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

        Delete


 

 

 

 

 

1.

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// 

 1 using System;
  2  using System.Collections.Generic;
  3 using System.Data.SqlClient;
  4 using System.Configuration;
  5 using System.Data;
  6
  7 namespace Common
  8 {
  9     public abstractclass DbHelperSQL
10     {
11         //格式化字符串
12         public staticstring inSQL(string formatStr)
13         {
14            string Str= formatStr;
15            if (formatStr!=null&& formatStr!=string.Empty)
16             {
17                 Str= Str.Replace("‘","‘‘");
18             }
19            return Str;
20         }
21
22         //获取连接字符串
23         public staticstring ConnectionString
24         {
25            get
26             {
27                string _connectionstring= ConfigurationManager.ConnectionStrings["ApplicationServices"].ConnectionString;
28                string ConStringEncrypt= ConfigurationManager.AppSettings["ApplicationServices"];
29                if (ConStringEncrypt=="true")
30                 {
31                     _connectionstring= DESEncrypt.Encrypt(_connectionstring);
32                 }
33                return _connectionstring;
34             }
35         }
36
37         #region 执行带参数的SQL语句
38
39         // 执行查询语句,返回SqlDataReader ( 注意:调用该方法后,一定要对SqlDataReader进行Close )
40         public static  SqlDataReader ExecuteReader(string SQLString,params SqlParameter[] cmdParms)
41         {
42             SqlConnection connection=new SqlConnection(ConnectionString);
43             SqlCommand cmd=new SqlCommand();
44            try
45             {
46                 PrepareCommand(cmd,connection,null,SQLString,cmdParms);
47                 SqlDataReader myReader=cmd.ExecuteReader(CommandBehavior.CloseConnection);
48                 cmd.Parameters.Clear();
49                return myReader;
50             }
51            catch(System.Data.SqlClient.SqlException e)
52             {
53                throw e;
54             }
55         }
56
57         // 执行SQL语句,返回影响的记录数
58         public staticint ExecuteSql(string SQLString,params SqlParameter[] cmdParms)
59         {
60            using (SqlConnection connection=new SqlConnection(ConnectionString))
61             {
62                using (SqlCommand cmd=new SqlCommand())
63                 {
64                    try
65                     {
66                         PrepareCommand(cmd,connection,null,SQLString,cmdParms);
67                        int rows=cmd.ExecuteNonQuery();
68                         cmd.Parameters.Clear();
69                        return rows;
70                     }
71                    catch(System.Data.SqlClient.SqlException e)
72                     {
73                        throw e;
74               &nb

热门排行

今日推荐

热门手游