using System;
          using System.Collections.Generic;
          using System.Linq;
          using System.Text;
          using System.Data;
          using System.Collections;
          using System.Data.SqlClient;
          using System.Data.Common;
          using System.Configuration;


          namespace Common.Dba
          {
              public  class DbSqlServerData:DbAccess
              {
                   new SqlCommand cmd = null;
                  public DbSqlServerData()
                  {
                      //
                      // TODO: 在此處添加構(gòu)造函數(shù)邏輯
                      //
                      conn = new SqlConnection();
                      conn.ConnectionString = ConnectionString;//Convert.ToString(ConfigurationManager.AppSettings["datasource"]); //Convert.ToString(System.Configuration.ConfigurationSettings.AppSettings["datasource"]);
                      //conn.ConnectionString = "initial catalog=idyan_new;data source=.;user id=bt;password=btbtbtbt;Connect Timeout=5000";
                      cmd = new SqlCommand();
                      cmd.Connection = conn as SqlConnection;
                      cmd.CommandTimeout = 0;

                  }
                  public DbSqlServerData(string constr)
                  {

                      //
                      // TODO: 在此處添加構(gòu)造函數(shù)邏輯
                      //
                      conn = new SqlConnection();
                      //conn.ConnectionString = "initial catalog=pubs;data source=.;user id=sa;password=";
                      //conn.ConnectionString = Convert.ToString(System.Configuration.ConfigurationSettings.AppSettings["datasource"]);
                      conn.ConnectionString = constr;// "initial catalog=idyan_new;data source=.;user id=bt;password=btbtbtbt";
                      cmd = new SqlCommand();
                      cmd.Connection = conn as SqlConnection;
                      cmd.CommandTimeout = 0;

                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)Sql語句
                  /// </summary>
                  /// <param name="Sql"></param>
                  /// <returns></returns>
                  public override DataTable GetTable(string sql)
                  {
                      DataSet ds = new DataSet();

                      try
                      {
                          cmd.CommandText = sql;
                          cmd.CommandType = CommandType.Text;
                          SqlDataAdapter da = new SqlDataAdapter();
                          da.SelectCommand = cmd;
                          da.Fill(ds);
                      }
                      catch (Exception ex)
                      {

                       
                          return null;

                      }
                      return ds.Tables[0] ?? new DataTable();
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <returns></returns>
                  public override DataSet GetDataSet(string sql)
                  {
                      DataSet ds = new DataSet();

                      try
                      {
                          cmd.CommandText = sql;
                          cmd.CommandType = CommandType.Text;
                          SqlDataAdapter da = new SqlDataAdapter();
                          da.SelectCommand = cmd;

                          da.Fill(ds);
                      }
                      catch (Exception ex)
                      {

                        
                          return null;

                      }
                      return ds;
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <returns></returns>
                  public override DataSet GetDataSet(string sql, DbParameter[] pas)
                  {
                      DataSet ds = new DataSet();

                      try
                      {
                          cmd.Parameters.Clear();
                          cmd.CommandText = sql;
                          foreach (SqlParameter pa in pas)
                          {
                              cmd.Parameters.Add(pa);
                          }
                          cmd.CommandType = CommandType.Text;
                          SqlDataAdapter da = new SqlDataAdapter();
                          da.SelectCommand = cmd;

                          da.Fill(ds);
                      }
                      catch (Exception ex)
                      {

                       
                          return null;

                      }
                      return ds;
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句 帶參數(shù) 的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override DataTable GetTable(string sql, params DbParameter[] pas)
                  {
                      DataSet ds = new DataSet();
                      try
                      {
                          cmd.CommandText = sql;
                          cmd.CommandType = CommandType.Text;
                          SqlDataAdapter da = new SqlDataAdapter();
                          da.SelectCommand = cmd;
                          cmd.Parameters.Clear();

                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }


                          da.Fill(ds);
                      }
                      catch (Exception ex)
                      {


                          return null;
                      }
                      return ds.Tables[0] ?? new DataTable();
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句 帶參數(shù) 的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override DataTable GetProcTable(string procname, params DbParameter[] pas)
                  {
                      DataSet ds = new DataSet();
                      try
                      {
                          cmd.CommandType = CommandType.StoredProcedure;
                          cmd.CommandText = procname;
                          //cmd.CommandText = sql;
                          SqlDataAdapter da = new SqlDataAdapter();
                          da.SelectCommand = cmd;
                          cmd.Parameters.Clear();

                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }

           

                          da.Fill(ds);
                      }
                      catch (Exception ex)
                      {


                          return null;
                      }
                      return ds.Tables[0] ?? new DataTable();
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句 帶參數(shù) 的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override DataTable GetProcCursorTable(string procname, params DbParameter[] pas)
                  {
                      DataSet ds = new DataSet();
                      try
                      {
                          cmd.CommandType = CommandType.StoredProcedure;
                          cmd.CommandText = procname;
                          //cmd.CommandText = sql;
                          SqlDataAdapter da = new SqlDataAdapter();
                          da.SelectCommand = cmd;
                          cmd.Parameters.Clear();

                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }

           

                          da.Fill(ds);
                      }
                      catch (Exception ex)
                      {


                          return null;
                      }
                      return ds.Tables[1] ?? new DataTable();
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句 帶參數(shù) 的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override int GetProcState(string procname, params DbParameter[] pas)
                  {
                      int state = 0;
                      try
                      {
                          OpenConn();
                          cmd.CommandType = CommandType.StoredProcedure;
                          cmd.CommandText = procname;
                          cmd.Parameters.Clear();
                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }
                          cmd.ExecuteNonQuery();
                          CloseConn();
                          state = Convert.ToInt32(pas[pas.Length - 1].Value);

                      }
                      catch
                      {
                          return 0;
                      }
                      return state;
                  }
                  /// <summary>
                  /// 獲取數(shù)據(jù)根據(jù)sql語句 帶參數(shù) 的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override int GetProcStateNo(string procname, params DbParameter[] pas)
                  {
                      int state = 0;
                      try
                      {
                          OpenConn();
                          cmd.CommandType = CommandType.StoredProcedure;
                          cmd.CommandText = procname;
                          cmd.Parameters.Clear();
                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }
                          cmd.ExecuteNonQuery();
                          CloseConn();
                          state = 1;

                          // state = Convert.ToInt32(pas[pas.Length - 1].Value);

                      }
                      catch
                      {

                          return 0;
                      }
                      return state;
                  }
                  /// <summary>
                  /// 存儲過程返回值的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override string GetProcStateReturnValue(string procname, params DbParameter[] pas)
                  {
                      string state = "";
                      try
                      {
                          OpenConn();
                          cmd.CommandType = CommandType.StoredProcedure;
                          cmd.CommandText = procname;
                          cmd.Parameters.Clear();
                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }
                          cmd.Parameters.AddWithValue("@Return_Value", "").Direction = ParameterDirection.ReturnValue;
                          cmd.ExecuteNonQuery();
                          state = Convert.ToString(cmd.Parameters["@Return_Value"].Value);
                          state = state == null ? ("") : (state);
                          CloseConn();


                          // state = Convert.ToInt32(pas[pas.Length - 1].Value);

                      }
                      catch
                      {

                          return "";
                      }
                      return state;
                  }
                  /// <summary>
                  /// 根據(jù)sql語句返回跟新狀態(tài)
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <returns></returns>
                  public override bool GetState(string sql)
                  {
                      bool succ = false;
                      try
                      {
                          cmd.CommandType = CommandType.Text;
                          cmd.CommandText = sql;
                          OpenConn();
                          succ = cmd.ExecuteNonQuery() > 0 ? (true) : (false);
                          CloseConn();
                      }
                      catch (Exception ex)
                      {


                          return false;
                      }
                      return succ;

                  }
                  /// <summary>
                  /// 根據(jù)sql語句返回跟新狀態(tài)帶參數(shù)的
                  /// </summary>
                  /// <param name="sql">sql語句</param>
                  /// <param name="pas">參數(shù)的集合</param>
                  /// <returns></returns>
                  public override bool GetState(string sql, params DbParameter[] pas)
                  {
                      bool succ = false;
                      try
                      {
                          cmd.CommandType = CommandType.Text;
                          cmd.CommandText = sql;
                          cmd.Parameters.Clear();

                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }
                          OpenConn();
                          succ = cmd.ExecuteNonQuery() > 0 ? (true) : (false);
                          CloseConn();
                      }
                      catch
                      {

                          // this.ShowError(ex.Message);
                          //using (System.IO.StreamWriter sw = new System.IO.StreamWriter("D:\\error2008.txt"))
                          //{
                          //    sw.Write(ex.Message);
                          //    sw.Flush();
                          //}
                          return false;
                      }
                      return succ;

                  }
                  /// <summary>
                  /// 根據(jù)sql語句返回第一個單元格的數(shù)據(jù)
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <returns></returns>
                  public override string GetOne(string sql)
                  {
                      string res = "";
                      try
                      {
                          cmd.CommandType = CommandType.Text;
                          cmd.CommandText = sql;
                          OpenConn();
                          res = cmd.ExecuteScalar() == null ? ("") : (Convert.ToString(cmd.ExecuteScalar()));
                          CloseConn();
                      }
                      catch (Exception ex)
                      {


                          return null;
                      }
                      return res;
                  }
                  /// <summary>
                  ///  根據(jù)sql語句返回第一個單元格的數(shù)據(jù)帶參數(shù)的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override string GetOne(string sql, params DbParameter[] pas)
                  {
                      string res = "";
                      try
                      {
                          cmd.CommandType = CommandType.Text;
                          cmd.CommandText = sql;
                          cmd.Parameters.Clear();

                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }
                          OpenConn();
                          res = cmd.ExecuteScalar() == null ? ("") : (Convert.ToString(cmd.ExecuteScalar()));
                          CloseConn();
                      }
                      catch (Exception ex)
                      {
                          CloseConn();

                          return null;
                      }
                      return res;
                  }
                  /// <summary>
                  /// 返回數(shù)據(jù)的DataReader
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <returns></returns>
                  public override DbDataReader GetDataReader(string sql)
                  {
                      SqlDataReader dr = null;
                      try
                      {
                          cmd.CommandType = CommandType.Text;
                          conn.Open();
                          cmd.CommandText = sql;
                          dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                      }
                      catch (Exception ex)
                      {


                          return null;
                      }
                      return dr;
                  }
                  /// <summary>
                  /// 返回數(shù)據(jù)的DataReader帶參數(shù)的
                  /// </summary>
                  /// <param name="sql"></param>
                  /// <param name="pas"></param>
                  /// <returns></returns>
                  public override DbDataReader GetDataReader(string sql, params DbParameter[] pas)
                  {
                      SqlDataReader dr = null;
                      try
                      {
                          cmd.CommandType = CommandType.Text;
                          conn.Open();
                          cmd.Parameters.Clear();

                          foreach (SqlParameter temppa in pas)
                          {
                              cmd.Parameters.Add(temppa);
                          }

                          cmd.CommandText = sql;
                          dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                      }
                      catch (Exception ex)
                      {


                          return null;
                      }
                      return dr;
                  }
                  /// <summary>
                  /// 事務(wù)處理函數(shù)
                  /// </summary>
                  /// <param name="al"></param>
                  /// <returns></returns>
                  public override bool GetTranState(ArrayList al)
                  {
                      cmd.CommandType = CommandType.Text;
                      OpenConn();
                      SqlTransaction tran = (conn as SqlConnection).BeginTransaction();
                      cmd.Transaction = tran;
                      try
                      {
                          for (int i = 0; i < al.Count; i++)
                          {
                              cmd.CommandText = Convert.ToString(al[i]);
                              cmd.ExecuteNonQuery();
                          }

                          tran.Commit();
                          CloseConn();
                      }
                      catch
                      {

                          tran.Rollback();
                          CloseConn();
                          return false;
                      }
                      return true;

                  }
                
                  /// <summary>
                  /// 分頁函數(shù)
                  /// </summary>
                  /// <param name="pagesize"></param>
                  /// <param name="columns"></param>
                  /// <param name="tablename"></param>
                  /// <param name="pid"></param>
                  /// <param name="order"></param>
                  /// <param name="current"></param>
                  /// <returns></returns>
                  public override DataTable GetPageData(int current, int pagesize, string columns, string tablename, string pid, string where, string order)
                  {
                      current = current - 1 >= 0 ? (current - 1) : (0);
                      string sql = string.Format("select top {0} {1} from {2} where 1=1 and {3} not in(select top {4}{3} from {2} where 1=1{5}  order by {6}){5} order by {6}", pagesize, columns, tablename, pid, current * pagesize, where, order);
                      return GetTable(sql);
                    
                  }
                  /// <summary>
                  /// 分頁存儲過程的調(diào)用
                  /// </summary>
                  /// <param name="current"></param>
                  /// <param name="pagesize"></param>
                  /// <param name="columns"></param>
                  /// <param name="tablename"></param>
                  /// <param name="pid"></param>
                  /// <param name="where"></param>
                  /// <param name="order"></param>
                  /// <returns></returns>
                  public override DataTable GetProcPageData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string ordertype)
                  {
                      SqlParameter[] pas = { new SqlParameter("@PageIndex", current), new SqlParameter("@PageSize", pagesize), new SqlParameter("@Columns", columns), new SqlParameter("@Tablename", tablename), new SqlParameter("@Where", where), new SqlParameter("@Order", order), new SqlParameter("@OrderType", ordertype), new SqlParameter("@Pid", pid) };
                      return GetProcTable("Pages", pas);
                      //current = current - 1 >= 0 ? (current - 1) : (0);
                      //string sql = string.Format("select top {0} {1} from {2} where 1=1 and {3} not in(select top {4}{3} from {2} where 1=1{5}  order by {6}){5} order by {6}", pagesize, columns, tablename, pid, current * pagesize, where, order);
                      //return GetTable(sql);
                  }
                  /// <summary>
                  /// 分頁存儲過程的調(diào)用
                  /// </summary>
                  /// <param name="current"></param>
                  /// <param name="pagesize"></param>
                  /// <param name="columns"></param>
                  /// <param name="tablename"></param>
                  /// <param name="pid"></param>
                  /// <param name="where"></param>
                  /// <param name="order"></param>
                  /// <returns></returns>
                  public override DataTable GetProcData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string resultCount, string distinct)
                  {
                      SqlParameter[] pas = { new SqlParameter("@TableNames", SqlDbType.NVarChar, 200), new SqlParameter("@PrimaryKey", SqlDbType.NVarChar, 100), new SqlParameter("@Order", SqlDbType.NVarChar, 200), new SqlParameter("@CurrentPage", SqlDbType.Int), new SqlParameter("@PageSize", SqlDbType.Int), new SqlParameter("@Fields", SqlDbType.NVarChar, 800), new SqlParameter("@Filter", SqlDbType.NVarChar, 1000), new SqlParameter("@ResultCount", SqlDbType.NVarChar, 12), new SqlParameter("@distinct", SqlDbType.NVarChar, 12) };
                      pas[0].Value = tablename;
                      pas[1].Value = pid;
                      pas[2].Value = order;
                      pas[3].Value = current;
                      pas[4].Value = pagesize;
                      pas[5].Value = columns;
                      pas[6].Value = where;
                      pas[7].Value = resultCount;
                      pas[8].Value = distinct;
                      return this.GetProcTable("Pages", pas);
                
                  }
                  /// <summary>
                  /// 分頁存儲過程的調(diào)用
                  /// </summary>
                  /// <param name="current"></param>
                  /// <param name="pagesize"></param>
                  /// <param name="columns"></param>
                  /// <param name="tablename"></param>
                  /// <param name="pid"></param>
                  /// <param name="where"></param>
                  /// <param name="order"></param>
                  /// <returns></returns>
                  public override DataTable GetProcAdminData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string resultCount, string distinct)
                  {
                      SqlParameter[] pas = { new SqlParameter("@TableNames", SqlDbType.NVarChar, 200), new SqlParameter("@PrimaryKey", SqlDbType.NVarChar, 100), new SqlParameter("@Order", SqlDbType.NVarChar, 200), new SqlParameter("@CurrentPage", SqlDbType.Int), new SqlParameter("@PageSize", SqlDbType.Int), new SqlParameter("@Fields", SqlDbType.NVarChar, 800), new SqlParameter("@Filter", SqlDbType.NVarChar, 200), new SqlParameter("@ResultCount", SqlDbType.NVarChar, 24), new SqlParameter("@Distinct", SqlDbType.NVarChar, 12) };
                      pas[0].Value = tablename;
                      pas[1].Value = pid;
                      pas[2].Value = order;
                      pas[3].Value = current;
                      pas[4].Value = pagesize;
                      pas[5].Value = columns;
                      pas[6].Value = where;
                      pas[7].Value = resultCount;
                      pas[8].Value = distinct;
                      return this.GetProcTable("Pages", pas);

                  }
                  public override DbParameter[] MakeParameters(params string[] str)
                  {
                      SqlParameter[] pas = new SqlParameter[str.Length/ 2];
                      for (int i = 0; i < str.Length / 2; i++)
                      {
                          pas[i] = new SqlParameter(string.Format("@{0}", str[2 * i]), str[2 * i + 1]);
                      }
                      return pas;
                  }
              }
          }

          posted on 2009-09-02 11:08 sanmao 閱讀(97) 評論(0)  編輯  收藏

          只有注冊用戶登錄后才能發(fā)表評論。


          網(wǎng)站導航:
           

          常用鏈接

          留言簿(5)

          隨筆分類

          隨筆檔案

          搜索

          •  

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 青神县| 多伦县| 涟源市| 九台市| 邯郸县| 峨眉山市| 鲁甸县| 乌兰察布市| 凌云县| 应城市| 九龙县| 二连浩特市| 新宾| 海城市| 恩平市| 黄大仙区| 陵川县| 九龙坡区| 融水| 桃园县| 左云县| 通许县| 梁平县| 定陶县| 淮滨县| 新密市| 绩溪县| 北京市| 彰化县| 古浪县| 凯里市| 涪陵区| 汉川市| 枞阳县| 神木县| 大荔县| 临安市| 阿拉善右旗| 蓝田县| 临颍县| 隆德县|