通用数据访问层--SQLServer版

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.sqlClient;
/// <summary>
/// DBmanager的摘要说明
/// </summary>
public class DBmanager
{
private static readonly string sqlCon = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
protected static sqlConnection Getsqlconnection()//返回sqlConnection对象；
{
sqlConnection sqlcon = new sqlConnection(sqlCon);
return sqlcon;
}
//
// Todo:
/// <summary>
/// 检测记录是否存在
/// </summary>
/// <param name="CheckedField">被检测的字段</param>
/// <param name="CheckedContent">字段的内容</param>
/// <param name="CheckedTable">被检测的字段所在的表</param>
/// <returns>True:存在,False:不存在</returns>
public static bool IsExistRecord(string CheckedField, string CheckedContent, string CheckedTable)
{
string IsExistConditon = "where " + CheckedField + "=" + CheckedContent + "";
string IsExistsql = "select " + CheckedField + " from " + CheckedTable + " " + IsExistConditon + "";
sqlDataReader myReader = Static_getDataReadBysql(IsExistsql);
if (myReader.Read())
{
if (myReader != null) { myReader.Close(); }
return true;//存在
}
else
{
if (myReader != null) { myReader.Close(); }
return false;//不存在
}
}
/// <summary>
/// 根据sql语句返回一个数据集对象
/// </summary>
/// <param name="sqlcmd">要生成数据集对象的sqlCommand</param>
/// <returns>返回值：DataSet</returns>
public static DataSet Static_getDataSet(sqlCommand sqlcmd)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlcmd.Connection = sqlCon;
//适配器
sqlDataAdapter sqlData = new sqlDataAdapter();
sqlData.SelectCommand = sqlcmd;
DataSet ds = new DataSet();
sqlData.Fill(ds);
return ds;
}
/// <summary>
/// 根据sql语句返回一个数据集对象
/// </summary>
/// <param name="sqlstr">要生成数据集对象的string</param>
/// <returns>返回值：DataSet</returns>
public static DataSet Static_getDataSet(string sqlstr)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
sqlCommand cmd = new sqlCommand();
cmd.CommandText = sqlstr;
//sql命令
cmd.Connection = sqlCon;
//适配器
sqlDataAdapter sqlData = new sqlDataAdapter();
sqlData.SelectCommand = cmd;
DataSet ds = new DataSet();
sqlData.Fill(ds);
return ds;
}
/// <summary>
/// 根据sql语句返回一个数据集对象
/// </summary>
/// <param name="sqlstr">要生成数据集对象的string</param>
/// <param name="tbname">指定返回数据集的表名称</param>
/// <returns>返回值：DataSet</returns>
public static DataSet Static_getDataSet(string sqlstr, string tbname)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
sqlCommand cmd = new sqlCommand();
cmd.CommandText = sqlstr;
//sql命令
cmd.Connection = sqlCon;
//适配器
sqlDataAdapter sqlData = new sqlDataAdapter();
sqlData.SelectCommand = cmd;
DataSet ds = new DataSet();
sqlData.Fill(ds, tbname);
return ds;
}
/// <summary>
/// 根据sql语句返回一个数据视图对象
/// </summary>
/// <param name="sqlcmd">要生成数据集对象的sqlCommand</param>
/// <returns>返回值：DataView</returns>
public static DataView Static_getDataView(sqlCommand sqlcmd)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlcmd.Connection = sqlCon;
//适配器
sqlDataAdapter sqlData = new sqlDataAdapter();
sqlData.SelectCommand = sqlcmd;
DataSet ds = new DataSet();
sqlData.Fill(ds);
return ds.Tables[0].defaultview;
}
/// <summary>
/// 根据sqlCommand对象的实例返回sqlDataAdapter对象
/// </summary>
/// <param name="sqlcmd">sqlCommand对象</param>
/// <returns>sqlDataAdapter sqlDataAdapter对象的实例</returns>
public static sqlDataAdapter Static_getDataAdapter(sqlCommand sqlcmd)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlcmd.Connection = sqlCon;
//适配器
sqlDataAdapter sqlData = new sqlDataAdapter();
sqlData.SelectCommand = sqlcmd;
return sqlData;
}
/// <summary>
/// 根据传递过来的参数返回一个数据读对象
/// </summary>
/// <param name="strsql">String sql语句</param>
/// <returns>sqlDataReader sqlDataReader对象的实例</returns>
public static sqlDataReader Static_getDataReadBysql(string strsql)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlCommand sqlCmd = new sqlCommand();
sqlCmd.CommandType = CommandType.Text;
sqlCmd.CommandText = strsql;
sqlCmd.Connection = sqlCon;
//
sqlCon.open();
sqlDataReader sqlRead = sqlCmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
//sqlCon.Close();
return sqlRead;
}
/// <summary>
/// 根据传递过来的参数返回一个数据读对象
/// </summary>
/// <param name="Conn">sqlConnection　数据库连接对象</param>
/// <param name="sql">String sql语句</param>
/// <returns>sqlDataReader sqlDataReader对象的实例</returns>
public static sqlDataReader Static_GetsqlDataReader(sqlConnection Conn, String Str_sql)
{
//连接对象
sqlConnection sqlCon = Conn;
//sql命令
sqlCommand sqlCmd = new sqlCommand();
sqlCmd.CommandType = CommandType.Text;
sqlCmd.CommandText = Str_sql;
sqlCmd.Connection = sqlCon;
//
sqlCon.open();
sqlDataReader sqlRead = sqlCmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
//sqlCon.Close();
return sqlRead;
}
/// <summary>
/// 执行传递过来的sql语句
/// </summary>
/// <param name="strsql">string 要执行的sql语句</param>
public static void Static_excutesql(string strsql)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlCommand sqlCmd = new sqlCommand();
sqlCmd.CommandType = CommandType.Text;
sqlCmd.CommandText = strsql;
sqlCmd.Connection = sqlCon;
sqlCon.open();
sqlCmd.ExecuteNonQuery();
sqlCon.Close();
}
/// <summary>
/// 执行传递过来的sql语句返回受影响的行数
/// </summary>
/// <param name="strsql">string 要执行的sql语句</param>
/// <returns>int 受影响的行数</returns>
public static int Static_excuteNonQuerysqlCount(string strsql)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlCommand sqlCmd = new sqlCommand();
sqlCmd.CommandType = CommandType.Text;
sqlCmd.CommandText = strsql;
sqlCmd.Connection = sqlCon;
sqlCon.open();
int i;
i = sqlCmd.ExecuteNonQuery();
sqlCon.Close();
return i;
}
/// <summary>
/// 执行传递过来的sql语句
/// </summary>
/// <param name="strsql">string 要执行的sql语句</param>
/// <returns>int 受影响的行数</returns>
public static object Static_excutesqlCount(string strsql)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
//sql命令
sqlCommand sqlCmd = new sqlCommand();
sqlCmd.CommandType = CommandType.Text;
sqlCmd.CommandText = strsql;
sqlCmd.Connection = sqlCon;
sqlCon.open();
object obj;
obj = sqlCmd.ExecuteScalar();
sqlCon.Close();
return obj;
}
/// <summary>
/// 执行存储过程返回数据集
/// </summary>
/// <param name="p_strProcName">存储过程名称</param>
/// <param name="cmdParams">存储过程参数</param>
/// <returns>Dataset</returns>
public static DataSet Static_ExcuteQueryDataByProc(string p_strProcName, sqlParameter[] cmdParams)
{
//连接对象
sqlConnection sqlCon = Getsqlconnection();
DataSet dstemp = new DataSet();
sqlDataAdapter sqlAdapter = new sqlDataAdapter();
sqlCommand sqlCmd = new sqlCommand();
sqlCmd.CommandType = CommandType.StoredProcedure;
sqlCmd.CommandText = p_strProcName;
sqlCmd.Connection = sqlCon;
//添加参数
for (int i = 0; i < cmdParams.Length; i++)
sqlCmd.Parameters.Add(cmdParams[i]);
sqlAdapter.SelectCommand = sqlCmd;
sqlAdapter.Fill(dstemp);
return dstemp;
}
//
}

通用数据访问层--SQLServer版

相关推荐