zoukankan      html  css  js  c++  java
  • ASP.NET三层架构中数据层数据访问类部分代码

    代码如下:

      1 using System.Collections.Generic;
      2 using System.Linq;
      3 using System.Web;
      4 using System.Data;
      5 using System.Data.SqlClient;
      6 
      7 namespace TestWeb.DLL
      8 {
      9     public class DataAccess
     10     {
     11         private string connectionString = "";
     12 
     13         public string ConnectionString
     14         {
     15             get
     16             {
     17                 return connectionString;
     18             }
     19             set
     20             {
     21                 connectionString = value;
     22             }
     23         }
     24 
     25         protected string BuildSqlStr()
     26         {
     27             return ConfiguretionSettings.AppSettings["slja"].ToString();
     28         }
     29 
     30         protected SqlConnection BuildSqlConnection()
     31         {
     32             if (connectionString == "")
     33             {
     34                 connectionString = BuildSqlStr();
     35             }
     36             SqlConnection conn = new SqlConnection(connectionString);
     37             conn.Open();
     38             return conn;
     39         }
     40 
     41         protected Sqlconnection BuildSqlConnection(connectionString)
     42         {
     43             SqlConnection conn = new SqlConnection(connectionString);
     44             conn.Open();
     45             return conn;
     46         }
     47    
     48         protected SqlCommand BuildSqlCommand()
     49         {
     50             SqlCommand Comobj = new SqlCommand();
     51             Comobj.Connection = BuildSqlConnection();
     52             return Comobj;
     53         }
     54         protected SqlCommand BuildSqlCommand(string cmdText)
     55         {
     56             return new SqlCommand(cmdText, BuildSqlConnection());
     57         }
     58 
     59         protected DataSet BuildSqlDataSet(string cmdText)
     60         {
     61             SqlCommand ObjectCommand = BuildSqlCommand(cmdText);
     62             SqlDataAdapter ObjectAdapter = new SqlDataAdapter(ObjectCommand);
     63             DataSet Ds = new DataSet();
     64             ObjectAdapter.Fill(Ds);
     65             ObjectCommand.Connection.Close();
     66             ObjectCommand.Connection.Dispose();
     67             ObjectCommand.Dispose();
     68             return Ds;
     69         }
     70 
     71         protected DataReader BuildSqlDataReader(string cmdText)
     72         {
     73             SqlCommand ObjectCommand = BuildSqlCommand(cmdText);
     74             SqlDataReader ObjectDataReader = ObjectCommand.ExecuteReader();
     75             ObjectCommand.Connection.Close();
     76             ObjectCommand.Connection.Dispose();
     77             ObjectCommand.Dispose();
     78             return ObjectDataReader;
     79         }
     80 
     81         protected int BuildSqlExecuteNonQuery(string cmdText)
     82         {
     83             SqlCommand ObjectCommand = BuildSqlCommand(cmdText);
     84             int cellout = ObjectCommand.ExecuteNonQuery();
     85             ObjectCommand.Connection.Close();
     86             ObjectCommand.Connection.Dispose();
     87             ObjectCommand.Dispose();
     88             return cellout;
     89         }
     90 
     91         protected string BuildSqlExecuteScalar(string cmdText)
     92         {
     93             SqlCommand ObjectCommand = BuildSqlCommand(cmdText);
     94             string returnStr = string.Empty;
     95             if (ObjectCommand.ExecuteScalar() != null)
     96             {
     97                 returnStr = ObjectCommand.ExecuteScalar().Tostring();
     98             }
     99             ObjectCommand.Connection.Close();
    100             ObjectCommand.Connection.Dispose();
    101             ObjectCommand.Dispose();
    102             return returnStr;
    103         }
    104 
    105         //sisi
    106         //four and four----------------------------------------------------------------------------------
    107 
    108         protected int RunSqlParametersExecuteNonQuery(string Sqlstr, SqlParameter[] parameters)
    109         {
    110             SqlCommand ObjectCommand = BuildSqlCommand();
    111             ObjectCommand.CommandType = CommandType.Text;
    112             ObjectCommand.CommandText = Sqlstr;
    113             int count = 0;
    114             foreach (SqlParameter parameter in parameters)
    115             {
    116                 ObjectCommand.Parameters.Add(parameter);
    117             }
    118             count = ObjectCommand.ExecuteNonQuery();
    119             ObjectCommand.Connection.Close();
    120             ObjectCommand.Connection.Dispose();
    121             ObjectCommand.Dispose();
    122             return count;
    123         }
    124 
    125         protected int RunSqlParametersExecuteNonQuery(string Sqlstr, SqlParameter parameters)
    126         {
    127             SqlCommand ObjectCommand = BuildSqlCommand();
    128             ObjectCommand.CommandType = CommandType.Text;
    129             ObjectCommand.CommandText = Sqlstr;
    130             int count = 0;
    131             ObjectCommand.Parameters.Add(parameters);
    132             count = ObjectCommand.ExecuteNonQuery();
    133             ObjectCommand.Connection.Close();
    134             ObjectCommand.Connection.Dispose();
    135             ObjectCommand.Dispose();
    136             return count;
    137         }
    138 
    139         protected int RunSqlParametersExecuteNonQuery(DbCommand sqlCommand, CommandType commtype, string Sqlstr)
    140         {
    141             sqlCommand.Connection = this.BuildSqlConnection();
    142             sqlCommand.CommandType = commtype;
    143             sqlCommand.ComandText = Sqlstr;
    144             int count = sqlCommand.ExecuteNonQuery();
    145             sqlCommand.Connection.Close();
    146             sqlCommand.Connection.Dispose();
    147             sqlCommand.Dispose();
    148             return count;
    149         }
    150 
    151         protected int RunSqlParametersExecuteNonQuery(DbCommand sqlCommand)
    152         {
    153             sqlCommand.Connection = this.BuildSqlConnection();
    154             int count = sqlCommand.ExecuteNonQuery();
    155             sqlCommand.Connection.Close();
    156             sqlCommand.Connection.Dispose();
    157             sqlCommand.Dispose();
    158             return count;
    159         }
    160 
    161         //----------------------------------------------------------------------------------------------------
    162 
    163         protected string RunSqlParametersExecuteScalar(string Sqlstr, SqlParameter[] parameters)
    164         {
    165             SqlCommand ObjectCommand = BuildSqlCommand();
    166             ObjectCommand.CommandType = CommandType.Text;
    167             ObjectCommand.CommandText = Sqlstr;
    168             string returnStr = string.Empty;
    169             foreach (SqlParameter parameter in parameters)
    170             {
    171                 ObjectCommand.Parameters.Add(parameter);
    172             }
    173             returnStr = ObjectCommand.ExecuteScalar();
    174             ObjectCommand.Connection.Close();
    175             ObjectCommand.Connection.Dispose();
    176             ObjectCommand.Dispose();
    177             return returnStr;
    178         }
    179 
    180         protected string RunSqlParametersExecuteScalar(string Sqlstr, SqlParameter parameters)
    181         {
    182             SqlCommand ObjectCommand = BuildSqlCommand();
    183             ObjectCommand.CommandType = CommandType.Text;
    184             ObjectCommand.CommandText = Sqlstr;
    185             string returnStr = string.Empty;
    186             ObjectCommand.Parameters.Add(parameters);
    187             returnStr = ObjectCommand.ExecuteScalar();
    188             ObjectCommand.Connection.Close();
    189             ObjectCommand.Connection.Dispose();
    190             ObjectCommand.Dispose();
    191             return returnStr;
    192         }
    193 
    194         protected string RunSqlParametersExecuteScalar(DbCommand sqlCommand, CommandType commtype, string Sqlstr)
    195         {
    196             sqlCommand.Connection = this.BuildSqlConnection();
    197             sqlCommand.CommandType = commtype;
    198             sqlCommand.ComandText = Sqlstr;
    199             string returnStr = sqlCommand.ExecuteScalar();
    200             sqlCommand.Connection.Close();
    201             sqlCommand.Connection.Dispose();
    202             sqlCommand.Dispose();
    203             return returnStr;
    204         }
    205 
    206         protected string RunSqlParametersExecuteScalar(DbCommand sqlCommand)
    207         {
    208             sqlCommand.Connection = this.BuildSqlConnection();
    209             string returnStr = sqlCommand.ExecuteScalar();
    210             sqlCommand.Connection.Close();
    211             sqlCommand.Connection.Dispose();
    212             sqlCommand.Dispose();
    213             return returnStr;
    214         }
    215 
    216         //---------------------------------------------------------------------------------------------------
    217 
    218         protected DataSet RunSqlParametersReturnDataSet(string Sqlstr, SqlParameter[] parameters)
    219         {
    220             SqlCommand ObjectCommand = BuildSqlCommand();
    221             ObjectCommand.CommandType = CommandType.Text;
    222             ObjectCommand.CommandText = Sqlstr;
    223             foreach (SqlParameter parameter in parameters)
    224             {
    225                 ObjectCommand.Parameters.Add(parameter);
    226             }
    227             SqlDataAdapter ObjectAdapter = new SqlDataAdapter(ObjectCommand);
    228             DataSet Ds = new DataSet();
    229             ObjectAdapter.Fill(Ds,"DataList");
    230             ObjectCommand.Connection.Close();
    231             ObjectCommand.Connection.Dispose();
    232             ObjectCommand.Dispose();
    233             return Ds;
    234         }
    235 
    236         protected DataSet RunSqlParametersReturnDataSet(string Sqlstr, SqlParameter parameters)
    237         {
    238             SqlCommand ObjectCommand = BuildSqlCommand();
    239             ObjectCommand.CommandType = CommandType.Text;
    240             ObjectCommand.CommandText = Sqlstr;
    241             foreach (SqlParameter parameter in parameters)
    242             ObjectCommand.Parameters.Add(parameter);
    243             SqlDataAdapter ObjectAdapter = new SqlDataAdapter(ObjectCommand);
    244             DataSet Ds = new DataSet();
    245             ObjectAdapter.Fill(Ds,"DataList");
    246             ObjectCommand.Connection.Close();
    247             ObjectCommand.Connection.Dispose();
    248             ObjectCommand.Dispose();
    249             return Ds;
    250         }
    251 
    252         protected DataSet RunSqlParametersReturnDataSet(DbCommand sqlCommand, CommandType commtype, string Sqlstr)
    253         {
    254             sqlCommand.Connection = this.BuildSqlConnection();
    255             sqlCommand.CommandType = commtype;
    256             sqlCommand.ComandText = Sqlstr;
    257             SqlDataAdapter ObjectAdapter = new SqlDataAdapter(sqlCommand);
    258             DataSet Ds = new DataSet();
    259             ObjectAdapter.Fill(Ds,"DataList");
    260             sqlCommand.Connection.Close();
    261             sqlCommand.Connection.Dispose();
    262             sqlCommand.Dispose();
    263             return Ds;
    264         }
    265 
    266         protected DataSet RunSqlParametersReturnDataSet(DbCommand sqlCommand)
    267         {
    268             sqlCommand.Connection = this.BuildSqlConnection();
    269             SqlDataAdapter ObjectAdapter = new SqlDataAdapter(sqlCommand);
    270             DataSet Ds = new DataSet();
    271             ObjectAdapter.Fill(Ds,"DataList");
    272             sqlCommand.Connection.Close();
    273             sqlCommand.Connection.Dispose();
    274             sqlCommand.Dispose();
    275             return Ds;
    276         }
    277 
    278         //-------------------------------------------------------------------------------------------
    279         
    280         protected SqlDataReader RunSqlParametersRuturnDataReader(string Sqlstr, SqlParameter[] parameters)
    281         {
    282             SqlCommand ObjectCommand = BuildSqlCommand();
    283             ObjectCommand.CommandType = CommandType.Text;
    284             ObjectCommand.CommandText = Sqlstr;
    285             foreach (SqlParameter parameter in parameters)
    286             {
    287                 ObjectCommand.Parameters.Add(parameter);
    288             }
    289             SqlDataReader sdr = ObjectCommand.ExecuteReader();
    290             ObjectCommand.Connection.Close();
    291             ObjectCommand.Connection.Dispose();
    292             ObjectCommand.Dispose();
    293             return sdr;
    294         }
    295 
    296         protected SqlDataReader RunSqlParametersRuturnDataReader(string Sqlstr, SqlParameter parameters)
    297         {
    298             SqlCommand ObjectCommand = BuildSqlCommand();
    299             ObjectCommand.CommandType = CommandType.Text;
    300             ObjectCommand.CommandText = Sqlstr;
    301             foreach (SqlParameter parameter in parameters)
    302             ObjectCommand.Parameters.Add(parameter);
    303             SqlDataReader sdr = ObjectCommand.ExecuteReader();
    304             ObjectCommand.Connection.Close();
    305             ObjectCommand.Connection.Dispose();
    306             ObjectCommand.Dispose();
    307             return sdr;
    308         }
    309 
    310         protected SqlDataReader RunSqlParametersRuturnDataReader(DbCommand sqlCommand, CommandType commtype, string Sqlstr)
    311         {
    312             sqlCommand.Connection = this.BuildSqlConnection();
    313             sqlCommand.CommandType = commtype;
    314             sqlCommand.ComandText = Sqlstr;
    315             SqlDataReader sdr = ObjectCommand.ExecuteReader();
    316             sqlCommand.Connection.Close();
    317             sqlCommand.Connection.Dispose();
    318             sqlCommand.Dispose();
    319             return sdr;
    320         }
    321 
    322         protected SqlDataReader RunSqlParametersRuturnDataReader(DbCommand sqlCommand)
    323         {
    324             sqlCommand.Connection = this.BuildSqlConnection();
    325             SqlDataReader sdr = ObjectCommand.ExecuteReader();
    326             sqlCommand.Connection.Close();
    327             sqlCommand.Connection.Dispose();
    328             sqlCommand.Dispose();
    329             return sdr;
    330         }
    331     }
    332 }
  • 相关阅读:
    CLR基础
    Windows7下使用Shell32.dll出现没有实现接口的错误的解决办法
    Python学习
    Python学习
    开发常识之Linux用户及其权限管理
    (转)简单明晰的Jupyter Notebook总结与指南
    Oracle系列数据库版本区别
    应用场景区别-MongoDB与MySQL的选择比较
    我的博客(个人空间)地址更新说明
    (转)Spark与Map-Reduce区别对比
  • 原文地址:https://www.cnblogs.com/azumia/p/2495039.html
Copyright © 2011-2022 走看看