通用数据访问层类代码,Asp.Net代码库,德仔网

代码语言
代码分类
【Asp.Net】通用数据访问层类
作者:掌心雷 / 发布于2014/9/22/ 630

	using System;
	using System.Collections.Generic;
	using System.Linq;
	using System.Text;

	using System.Configuration;
	using System.Data.SqlClient;
	using System.Data;

	namespace DLL
	{
	 public static class DBHelper
	 {
	 //定义连接对象
	 private static SqlConnection connection;

	 public static SqlConnection Connection
	 {
	 get
	 {
	 string connectionString = ConfigurationManager.ConnectionStrings["ConnString"].ConnectionString;
	 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;
	 }
	 }

	 //ExecuteNonQuery方法是用来执行insert、delete、update语句的,返回的是影响的行数
	 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();
	 }

	 //ExecuteScalar()返回sql语句执行后的第一行第一列的值,object类型
	 public static int GetScalar(string safeSql)
	 {
	 SqlCommand cmd = new SqlCommand(safeSql, Connection);
	 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;
	 }

	 //ExecuteReader()返回一个Datareader对象，对象内容是为与命令匹配的所有行，通常用于读取数据
	 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;
	 }

	 //返回一个DataTable
	 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];
	 }
	 }
	}
试试其它关键字
同语言下
可能有用的
掌心雷贡献的其它代码(2)