zoukankan      html  css  js  c++  java
  • 根据自己平时的经验写的针对SQLSERVER操作的通用类库

    根据自己平时的经验写的针对SQLSERVER操作的通用类库

      1using System;
      2using System.Data;
      3using System.Data.SqlClient;
      4using System.Web;
      5
      6namespace Whgw_lc
      7{
      8 /// <summary>
      9 /// Data 的摘要说明。
     10 /// </summary>
     11 /// <summary>
     12 /// 数据库相关操作类
     13 /// 作者:DarkAngel
     14 /// 时间:2004-9-24
     15 /// </summary>

     16 public class Data
     17 {
     18  /// <summary>
     19  ///连接数据库字符串 
     20  /// </summary>

     21  protected static string con="data source=10.68.19.203;initial catalog=Whgw;persist security info=False;user id=sa;password=sc2000;workstation id=DARKANGEL;packet size=4096";
     22  /// <summary>
     23  /// 数据库连接对象
     24  /// </summary>

     25  protected System.Data .SqlClient.SqlConnection DataConnection;
     26  /// <summary>
     27  /// SqlDataAdapter对象
     28  /// </summary>

     29  protected System.Data.SqlClient.SqlDataAdapter DataAdapter;
     30  /// <summary>
     31  /// SqlCommand对象
     32  /// </summary>

     33  protected System.Data.SqlClient.SqlCommand DataCommand;
     34  /// <summary>
     35  /// SqlCommandBuilder对象
     36  /// </summary>

     37  protected System.Data.SqlClient.SqlCommandBuilder DataComBuilder;
     38  /// <summary>
     39  /// DataSet对象
     40  /// </summary>

     41  protected System.Data.DataSet DataSet;
     42  /// <summary>
     43  /// DataRow对象
     44  /// </summary>

     45  protected System.Data.DataRow DataRow;
     46  /// <summary>
     47  /// SqlDataReader对象
     48  /// </summary>

     49  protected System.Data.SqlClient.SqlDataReader DataReader;
     50  //protected System.Web.UI.Page mypage;
     51  /// <summary>
     52  ///构造函数
     53  /// </summary>

     54  
     55  public Data()
     56  {
     57   //
     58   // TODO: 连接数据库参数
     59   //
     60   //con=
     61   DataConnection=DataConn(); 
     62   
     63  }

     64  /// <summary>
     65  /// 数据库连接参数属性
     66  /// </summary>

     67  public string Con
     68  {
     69   
     70   get{return con;}
     71   set{con= value;}
     72  }

     73  /// <summary>
     74  /// 建立数据库连接
     75  /// </summary>
     76  /// <returns>返回数据库连接对象</returns>

     77  public SqlConnection DataConn()
     78  {
     79   SqlConnection DataConnection=new SqlConnection(Con);
     80   return DataConnection;
     81  }

     82  /// <summary>
     83  ///  查询结果,返回
     84  /// </summary>
     85  /// <param name="mysql">查询语句</param>
     86  /// <returns>返回datareader</returns>

     87  public SqlDataReader DataQuery(string Sql)
     88  {
     89   
     90   DataConnection=DataConn();
     91   DataConnection.Open();
     92   DataReader=null;
     93   DataCommand=new SqlCommand(Sql,DataConnection);
     94   DataReader=DataCommand.ExecuteReader();
     95   return DataReader;
     96  }

     97  /// <summary>
     98  /// 查询结果,返回DataSet
     99  /// </summary>
    100  /// <param name="mysql">查询语句</param>
    101  /// <param name="tabName">表名</param>
    102  /// <returns>DataSet</returns>

    103  public virtual DataSet DataSetQuery(string Sql,string TableName)
    104  {
    105   DataConnection=DataConn();
    106   DataConnection.Open();
    107   DataAdapter=new SqlDataAdapter(Sql,DataConnection);
    108   DataSet=new DataSet();
    109   DataAdapter.Fill(DataSet,TableName);
    110   return DataSet;
    111  }

    112  public DataSet DataSetQuery(DataSet myds,string TableName,string Sql)
    113  {
    114   DataConnection=DataConn();
    115   DataConnection.Open();
    116   DataAdapter=new SqlDataAdapter(Sql,DataConnection);
    117   
    118   DataAdapter.Fill(myds,TableName);
    119   return DataSet;
    120
    121  }

    122  /// <summary>
    123  /// 查询结果,返回DataSet,带起始和结束
    124  /// </summary>
    125  /// <param name="mysql">查询语句</param>
    126  /// <param name="tabName">表名</param>
    127  /// <param name="starIndex">起始行</param>
    128  /// <param name="count">终止行</param>
    129  /// <returns>返回DataSet</returns>

    130  public DataSet DataSetQuery(string Sql,string TableName,int StarIndex,int Count)
    131  {
    132   DataConnection=DataConn();
    133   DataConnection.Open();
    134   DataAdapter=new SqlDataAdapter(Sql,DataConnection);
    135   DataSet=new DataSet();
    136   DataAdapter.Fill(DataSet,StarIndex,Count,TableName);
    137   return DataSet;
    138  }

    139  /// <summary>
    140  /// 修改数据库内容
    141  /// </summary>
    142  /// <param name="mysql">查询语句</param>
    143  /// <returns>如果执行成功返回真,否者返回假</returns>

    144  public bool EditData(string Sql)
    145  {
    146   DataConnection=DataConn();
    147   DataConnection.Open();
    148   DataCommand=new SqlCommand(Sql,DataConnection);
    149   try
    150   {
    151    DataCommand.ExecuteNonQuery();
    152    return true;
    153   }

    154   catch(Exception ex)
    155   {  
    156    System.Console.Write(ex.Message.ToString());
    157    return false;
    158   }

    159   DataConnection.Close();
    160  }

    161  /// <summary>
    162  /// 修改DataSet内容,并更新数据库
    163  /// </summary>
    164  /// <param name="DataSet">DataSet对象</param>
    165  /// <param name="myda">SqlDataAdapter容器</param>
    166  /// <param name="tbName">表名</param>
    167  /// <returns>返回DataSet</returns>

    168  public DataSet EditData(DataSet DataSet,SqlDataAdapter myda,string TableName)
    169  {
    170    
    171   
    172   DataComBuilder=new SqlCommandBuilder(myda);
    173   myda.UpdateCommand=DataComBuilder.GetUpdateCommand();
    174   myda.DeleteCommand=DataComBuilder.GetDeleteCommand();
    175   myda.InsertCommand=DataComBuilder.GetInsertCommand();
    176   myda.Update(DataSet,TableName);
    177   DataSet.AcceptChanges();
    178   return DataSet;
    179  }

    180  /// <summary>
    181  /// 无参数存储过程的执行
    182  /// </summary>
    183  /// <param name="proName">存储过程名称</param>
    184  /// <returns>是否执行成功</returns>

    185  public bool DataProcedure(string ProcedureName)
    186  {
    187   DataConnection=DataConn();
    188   DataConnection.Open();
    189   DataCommand=new SqlCommand();
    190   DataCommand.CommandText=ProcedureName;
    191   DataCommand.Connection=DataConnection;
    192   DataCommand.CommandType=System.Data.CommandType.StoredProcedure;
    193   try
    194   {
    195    DataCommand.ExecuteNonQuery();
    196    return true;
    197   }

    198   catch(Exception ex)
    199   {  
    200    System.Console.Write(ex.Message.ToString());
    201    return false;
    202   }

    203  }

    204  /// <summary>
    205  ///  关闭数据库连接
    206  /// </summary>

    207  public void CloseConnection()
    208  {
    209   DataConnection.Close();
    210  }

    211 
    212 }

    213}

    214
    215
  • 相关阅读:
    Google Optimize 安装使用教程
    PostgreSQL drop database 显示会话没有关闭 [已解决]
    c#之线程同步--轻量级同步 Interlocked
    CentOS7 'Username' is not in the sudoers file. This incident will be reported
    Mac 如何删除应用、软件
    Oracle的存储过程基本写法
    我的一个PLSQL【我】 循环嵌套、游标使用、变量定义、查询插入表、批量提交事务、字符串截取、动态sql拼接执行
    Oracle定义常量和变量
    ORACLE中%TYPE和%ROWTYPE的使用
    pls_integer类型
  • 原文地址:https://www.cnblogs.com/DarkAngel/p/175514.html
Copyright © 2011-2022 走看看