sqlserver操作的类

 

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.OleDb;
using System.Data.sqlClient;
using System.Configuration;

namespace database
{
  public class DataBase
  {

  /// <summary>
  /// 保护变量，数据库连接。
  /// </summary>
  protected sqlConnection Connection;

  /// <summary>
  /// 保护变量，数据库连接串。
  /// </summary>
  protected string ConnectionString;

  /// <summary>
  /// 构造函数。
  /// </summary>
  /// <param name="DataBaseConnectionString">数据库连接串</param>
  public DataBase()
  {
  ConnectionString = ConfigurationManager.AppSettings["ConnectString"];
  }

  /// <summary>
  /// 析构函数，关闭数据库
  /// </summary>
  ~DataBase()
  {
  try
  {
  if (Connection != null)
  Connection.Close();
  }
  catch { }
  }

  /// <summary>
  /// 保护方法，打开数据库连接。
  /// </summary>
  protected void open()
  {
  if (Connection == null)
  {
  Connection = new sqlConnection(ConnectionString);
  }
  if (Connection.State.Equals(ConnectionState.Closed))
  {
  Connection.open();
  }
  }

  /// <summary>
  /// 公有方法，关闭数据库连接。
  /// </summary>
  public void Close()
  {
  if (Connection != null)
  Connection.Close();
  }

  /// <summary>
  /// 公有方法，获取数据，返回一个DataSet。
  /// </summary>
  /// <param name="sqlString">sql语句</param>
  /// <returns>DataSet</returns>
  public DataSet GetDataSet(string sqlString)
  {
  open();
  sqlDataAdapter adapter = new sqlDataAdapter(sqlString,Connection);
  DataSet dataset = new DataSet();
  adapter.Fill(dataset);
  Close();
  return dataset;
  }
  /// <summary>
  /// 公有方法，获取数据，返回一个DataReader。
  /// </summary>
  /// <param name="sqlString">sql语句</param>
  /// <returns>DataSet</returns>
  public sqlDataReader GetDataReader(string sqlString)
  {
  open();
  sqlCommand cmm = new sqlCommand(sqlString,Connection);
  sqlDataReader datareader = cmm.ExecuteReader();
  return datareader;
  }
  /// <summary>
  /// 公有方法，执行数据库操作。
  /// </summary>
  public void databaseExcutive(string sqlString)
  {
  open();
  sqlCommand Mycomm = new sqlCommand(sqlString,Connection);
  Mycomm.ExecuteNonQuery();
  Close();
  }
  ///<summary>
  ///公有方法,数据库查询带子参数查询
  ///</summary>
  public DataSet GetDataSetsql(string tableName,string filter)
  {
  open();
  string sqlstr = "select * from " + tableName + " " + filter;
  sqlDataAdapter adapter = new sqlDataAdapter(sqlstr,Connection);
  DataSet dataset = new DataSet();
  adapter.Fill(dataset);
  Close();
  return dataset;
  }
  /// 自定义数据查询
  /// </summary>
  /// <param name="displayfilter">查询字段</param>
  /// <param name="filter">查询筛选条件</param>
  /// <returns>DataSet类型</returns>
  public DataSet GetDataSetKeysql(string table,string field,string filter)
  {
  open();
  string sqlstr = "select " + field + " from " + table + " " + filter;
  sqlDataAdapter adapter = new sqlDataAdapter(sqlstr,Connection);
  DataSet dataset = new DataSet();
  adapter.Fill(dataset);
  Close();
  return dataset;
  }
  /// <summary>
  /// 数据插入
  /// </summary>
  /// <param name="filedname">字段名称</param>
  /// <param name="editfildename">值</param>
  /// <returns>Bool类型</returns>
  public bool dataAdd(string tablename,string fieldname,string editfieldname) //数据插入
  {
  open();
  string sqlstr = "insert into " + tablename + " (" + fieldname + ") values(" + editfieldname + ")";
  databaseExcutive(sqlstr);
  bool state;
  state = true;
  return state;
  }


  /// <summary>
  /// 数据删除
  /// </summary>
  /// <param name="filter">删除条件</param>
  /// <returns>Bool类型</returns>
  public bool dataDelete(string tablename,string filter) //数据删除
  {
  open();
  string sqlstr = "delete from " + tablename + filter;
  databaseExcutive(sqlstr);
  bool state;
  state = true;
  return state;
  } /// <summary>
  /// 数据更新
  /// </summary>
  /// <param name="filter">删除条件</param>
  /// <returns>Bool类型</returns>
  public bool dataupdate(string tablename,string filter) //数据删除
  {
  open();
  string sqlstr = "UPDATE " + tablename + " set " + field + " where " + filter;
  databaseExcutive(sqlstr);
  bool state;
  state = true;
  return state;
  }
  ///access
  ///
  public DataSet GetAccessSet(string ocon,string sqlString)
  {
  OleDbConnection odc = new OleDbConnection(ocon);
  OleDbDataAdapter odapter = new OleDbDataAdapter(sqlString,odc);
    
  DataSet dataset = new DataSet();
  odapter.Fill(dataset);
  Close();
  return dataset;
  }
  }
}