SqlHelper-創(chuàng)新互聯(lián)-四川平武建站

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

SqlHelper-創(chuàng)新互聯(lián)

為羅城等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù)，及羅城網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為做網(wǎng)站、成都做網(wǎng)站、羅城網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會得到認(rèn)可，從而選擇與我們長期合作。這樣，我們也可以走得更遠(yuǎn)！>

using System;
using System.Collections.Generic;
using System.Text;
using System.Collections;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
namespace HelloWinForm.DBUtility
{
class SQLHelper
    {
#region 通用方法
   // 數(shù)據(jù)連接池   private SqlConnection con;
///    /// 返回?cái)?shù)據(jù)庫連接字符串
/// 
   ///    public static String GetSqlConnection()
        {
            String conn= ConfigurationManager.AppSettings["connectionString"].ToString();
return conn;
        }
#endregion   #region 執(zhí)行sql字符串
   ///    /// 執(zhí)行不帶參數(shù)的SQL語句
/// 
   ///    ///    public static int ExecuteSql(String Sqlstr)
        {
            String ConnStr= GetSqlConnection();
using (SqlConnection conn = new SqlConnection(ConnStr))
            {
                SqlCommand cmd= new SqlCommand();
                cmd.Connection= conn;
                cmd.CommandText= Sqlstr;
                conn.Open();
                cmd.ExecuteNonQuery();
                conn.Close();
return 1;
            }
        }
///    /// 執(zhí)行帶參數(shù)的SQL語句
/// 
   /// SQL語句   /// 參數(shù)對象數(shù)組   ///    public static int ExecuteSql(String Sqlstr, SqlParameter[] param)
        {
            String ConnStr= GetSqlConnection();
using (SqlConnection conn = new SqlConnection(ConnStr))
            {
                SqlCommand cmd= new SqlCommand();
                cmd.Connection= conn;
                cmd.CommandText= Sqlstr;
                cmd.Parameters.AddRange(param);
                conn.Open();
                cmd.ExecuteNonQuery();
                conn.Close();
return 1;
            }
        }
///    /// 返回DataReader
/// 
   ///    ///    public static SqlDataReader ExecuteReader(String Sqlstr)
        {
            String ConnStr= GetSqlConnection();
            SqlConnection conn= new SqlConnection(ConnStr);//返回DataReader時,是不可以用using()的 try
            {
                SqlCommand cmd= new SqlCommand();
                cmd.Connection= conn;
                cmd.CommandText= Sqlstr;
                conn.Open();
return cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);//關(guān)閉關(guān)聯(lián)的Connection            }
catch //(Exception ex)            {
return null;
            }
        }
///    /// 執(zhí)行SQL語句并返回?cái)?shù)據(jù)表
/// 
   /// SQL語句   ///    public static DataTable ExecuteDt(String Sqlstr)
        {
            String ConnStr= GetSqlConnection();
using (SqlConnection conn = new SqlConnection(ConnStr))
            {
                SqlDataAdapter da= new SqlDataAdapter(Sqlstr, conn);
                DataTable dt= new DataTable();
                conn.Open();
                da.Fill(dt);
                conn.Close();
return dt;
            }
        }
///    /// 執(zhí)行SQL語句并返回DataSet
/// 
   /// SQL語句   ///    public static DataSet ExecuteDs(String Sqlstr)
        {
            String ConnStr= GetSqlConnection();
using (SqlConnection conn = new SqlConnection(ConnStr))
            {
                SqlDataAdapter da= new SqlDataAdapter(Sqlstr, conn);
                DataSet ds= new DataSet();
                conn.Open();
                da.Fill(ds);
                conn.Close();
return ds;
            }
        }
#endregion   #region 操作存儲過程
   ///    /// 運(yùn)行存儲過程(已重載)
/// 
   /// 存儲過程的名字   /// 存儲過程的返回值   public int RunProc(string procName)
        {
            SqlCommand cmd= CreateCommand(procName, null);
            cmd.ExecuteNonQuery();
this.Close();
return (int)cmd.Parameters["ReturnValue"].Value;
        }
///    /// 運(yùn)行存儲過程(已重載)
/// 
   /// 存儲過程的名字   /// 存儲過程的輸入?yún)?shù)列表   /// 存儲過程的返回值   public int RunProc(string procName, SqlParameter[] prams)
        {
            SqlCommand cmd= CreateCommand(procName, prams);
            cmd.ExecuteNonQuery();
this.Close();
return (int)cmd.Parameters[0].Value;
        }
///    /// 運(yùn)行存儲過程(已重載)
/// 
   /// 存儲過程的名字   /// 結(jié)果集   public void RunProc(string procName, out SqlDataReader dataReader)
        {
            SqlCommand cmd= CreateCommand(procName, null);
            dataReader= cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
        }
///    /// 運(yùn)行存儲過程(已重載)
/// 
   /// 存儲過程的名字   /// 存儲過程的輸入?yún)?shù)列表   /// 結(jié)果集   public void RunProc(string procName, SqlParameter[] prams, out SqlDataReader dataReader)
        {
            SqlCommand cmd= CreateCommand(procName, prams);
            dataReader= cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
        }
///    /// 創(chuàng)建Command對象用于訪問存儲過程
/// 
   /// 存儲過程的名字   /// 存儲過程的輸入?yún)?shù)列表   /// Command對象   private SqlCommand CreateCommand(string procName, SqlParameter[] prams)
        {
// 確定連接是打開的            Open();
//command = new SqlCommand( sprocName, new SqlConnection( ConfigManager.DALConnectionString ) );            SqlCommand cmd = new SqlCommand(procName, con);
            cmd.CommandType= CommandType.StoredProcedure;
// 添加存儲過程的輸入?yún)?shù)列表 if (prams != null)
            {
foreach (SqlParameter parameter in prams)
                    cmd.Parameters.Add(parameter);
            }
// 返回Command對象 return cmd;
        }
///    /// 創(chuàng)建輸入?yún)?shù)
/// 
   /// 參數(shù)名   /// 參數(shù)類型   /// 參數(shù)大小   /// 參數(shù)值   /// 新參數(shù)對象   public SqlParameter MakeInParam(string ParamName, SqlDbType DbType, int Size, object Value)
        {
return MakeParam(ParamName, DbType, Size, ParameterDirection.Input, Value);
        }
///    /// 創(chuàng)建輸出參數(shù)
/// 
   /// 參數(shù)名   /// 參數(shù)類型   /// 參數(shù)大小   /// 新參數(shù)對象   public SqlParameter MakeOutParam(string ParamName, SqlDbType DbType, int Size)
        {
return MakeParam(ParamName, DbType, Size, ParameterDirection.Output, null);
        }
///    /// 創(chuàng)建存儲過程參數(shù)
/// 
   /// 參數(shù)名   /// 參數(shù)類型   /// 參數(shù)大小   /// 參數(shù)的方向(輸入/輸出)   /// 參數(shù)值   /// 新參數(shù)對象   public SqlParameter MakeParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value)
        {
            SqlParameter param;
if (Size > 0)
            {
                param= new SqlParameter(ParamName, DbType, Size);
            }
else
            {
                param= new SqlParameter(ParamName, DbType);
            }
            param.Direction= Direction;
if (!(Direction == ParameterDirection.Output && Value == null))
            {
                param.Value= Value;
            }
return param;
        }
#endregion   #region 數(shù)據(jù)庫連接和關(guān)閉
   ///    /// 打開連接池
///    private void Open()
        {
// 打開連接池 if (con == null)
            {
//這里不僅需要using System.Configuration;還要在引用目錄里添加                con = new SqlConnection(GetSqlConnection());
                con.Open();
            }
        }
///    /// 關(guān)閉連接池
///    public void Close()
        {
if (con != null)
                con.Close();
        }
///    /// 釋放連接池
///    public void Dispose()
        {
// 確定連接已關(guān)閉 if (con != null)
            {
                con.Dispose();
                con= null;
            }
        }
#endregion
    }
}

using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.Data;
namespace MyBookShop.DAL
{
public static class DBHelper
    {

private static SqlConnection connection;
public static SqlConnection Connection
        {
get 
            {
string connectionString = "Data Source=localhost;Initial Catalog=myRole; uid=sa;Password=";
if (connection == null)
                {
                    connection= new SqlConnection(connectionString);
                    connection.Open();
                }
else if (connection.State == System.Data.ConnectionState.Closed)
                {
                    connection.Open();
                }
else if (connection.State == System.Data.ConnectionState.Broken)
                {
                    connection.Close();
                    connection.Open();
                }
return connection;
            }
        }

public static int ExecuteCommand(string safeSql)
        {
            SqlCommand cmd= new SqlCommand(safeSql, Connection);
int result = cmd.ExecuteNonQuery();
return result;
        }

public static int ExecuteCommand(string sql, params SqlParameter[] values)
        {
            SqlCommand cmd= new SqlCommand(sql, Connection);
            cmd.Parameters.AddRange(values);
return cmd.ExecuteNonQuery();
        }

public static int GetScalar(string safeSql)
        {
            SqlCommand cmd= new SqlCommand(safeSql, Connection);
int result = Convert.ToInt32(cmd.ExecuteScalar());
return result;
        }

public static int GetScalar(params SqlParameter[] values)
        {
            SqlCommand cmd= new SqlCommand();
            cmd.Connection= Connection;
            cmd.CommandText= "Pro_InsertOrder";
            cmd.CommandType= CommandType.StoredProcedure;
            cmd.Parameters.AddRange(values);
int result = Convert.ToInt32(cmd.ExecuteScalar());
return result;
        }

public static int GetScalar(string sql, params SqlParameter[] values)
        {
            SqlCommand cmd= new SqlCommand(sql, Connection);
            cmd.Parameters.AddRange(values);
int result = Convert.ToInt32(cmd.ExecuteScalar());
return result;
        }

public static SqlDataReader GetReader(string safeSql)
        {
            SqlCommand cmd= new SqlCommand(safeSql, Connection);
            SqlDataReader reader= cmd.ExecuteReader();
return reader;
        }

public static SqlDataReader GetReader(string sql, params SqlParameter[] values)
        {
            SqlCommand cmd= new SqlCommand(sql, Connection);
            cmd.Parameters.AddRange(values);
            SqlDataReader reader= cmd.ExecuteReader();
return reader;
        }

public static DataTable GetDataSet(string safeSql)
        {
            DataSet ds= new DataSet();
            SqlCommand cmd= new SqlCommand(safeSql, Connection);
            SqlDataAdapter da= new SqlDataAdapter(cmd);
            da.Fill(ds);
return ds.Tables[0];
        }

public static DataTable GetDataSet(string sql, params SqlParameter[] values)
        {
            DataSet ds= new DataSet();
            SqlCommand cmd= new SqlCommand(sql, Connection);
            cmd.Parameters.AddRange(values);
            SqlDataAdapter da= new SqlDataAdapter(cmd);
            da.Fill(ds);
return ds.Tables[0];
        }
    }
}

分享題目：SqlHelper-創(chuàng)新互聯(lián)
網(wǎng)站網(wǎng)址：http://www.ef60e0e.cn/article/pgcci.html

99热在线精品一区二区三区_国产伦精品一区二区三区女破破_亚洲一区二区三区无码_精品国产欧美日韩另类一区

新聞中心

其他資訊