C#如何写DBHelper 类(数据库连接和操作)
2013-07-17 11:24
190 查看
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data;
using System.Configuration;
namespace UseAdo
{
public class DBHelper
{
//连接字符串
public static readonly string ConnectionString = ConfigurationManager.ConnectionStrings["SQLConn"].ToString();
//非查询操作
public static int ExecuteNonQuery(string commandText, CommandType commandType, params SqlParameter[] param)
{
int count = 0;
using (SqlConnection con = new SqlConnection(ConnectionString))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
con.Open();
count = cmd.ExecuteNonQuery();
}
return count;
}
//返回一个值得ExecuteScalar方法
public static object ExecuteScalar(string commandText, CommandType commandType, params SqlParameter[] param)
{
object obj = null;
using (SqlConnection con = new SqlConnection(ConnectionString))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
con.Open();
obj = cmd.ExecuteScalar();
}
return obj;
}
//询方法ExecuteReader()
public static SqlDataReader ExecuteReader(string commandText, CommandType commandType, params SqlParameter[] param)
{
SqlDataReader reader = null;
SqlConnection con = new SqlConnection(ConnectionString);
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
try
{
con.Open();
//关闭reader时同时关闭connection
reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
}
catch
{
con.Close();
}
return reader;
}
//Adapter方法
public static DataSet ExecuteDataSet(string commandText, CommandType commandType, params SqlParameter[] param)
{
DataSet ds = new DataSet();
using (SqlConnection con = new SqlConnection(ConnectionString))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
adapter.Fill(ds);
}
return ds;
}
}
}
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data;
using System.Configuration;
namespace UseAdo
{
public class DBHelper
{
//连接字符串
public static readonly string ConnectionString = ConfigurationManager.ConnectionStrings["SQLConn"].ToString();
//非查询操作
public static int ExecuteNonQuery(string commandText, CommandType commandType, params SqlParameter[] param)
{
int count = 0;
using (SqlConnection con = new SqlConnection(ConnectionString))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
con.Open();
count = cmd.ExecuteNonQuery();
}
return count;
}
//返回一个值得ExecuteScalar方法
public static object ExecuteScalar(string commandText, CommandType commandType, params SqlParameter[] param)
{
object obj = null;
using (SqlConnection con = new SqlConnection(ConnectionString))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
con.Open();
obj = cmd.ExecuteScalar();
}
return obj;
}
//询方法ExecuteReader()
public static SqlDataReader ExecuteReader(string commandText, CommandType commandType, params SqlParameter[] param)
{
SqlDataReader reader = null;
SqlConnection con = new SqlConnection(ConnectionString);
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
try
{
con.Open();
//关闭reader时同时关闭connection
reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
}
catch
{
con.Close();
}
return reader;
}
//Adapter方法
public static DataSet ExecuteDataSet(string commandText, CommandType commandType, params SqlParameter[] param)
{
DataSet ds = new DataSet();
using (SqlConnection con = new SqlConnection(ConnectionString))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = commandText;
cmd.CommandType = commandType;
if (param != null)
{
cmd.Parameters.AddRange(param);
}
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
adapter.Fill(ds);
}
return ds;
}
}
}
相关文章推荐
- js 连接数据库如何操作数据库中的数据
- java如何连接数据库并操作
- 如何读取配置文件并连接后台数据库,且对数据库进行操作实例(查询或修改等)
- Spring jdbcTemplate操作完数据库后是否需要手动关闭数据库连接 ,如何关闭
- Thinkphp 连接数据库操作以及如何创建数据
- awk 如何处理两个文件,实现类似数据库表连接的操作
- awk 如何处理两个文件,实现类似数据库表连接的操作
- 教你如何操作VS2010中SQL2008并且实现连接数据库
- 如何在ASP.NET MVC5不用EF框架完成对数据库的连接操作
- js 连接数据库如何操作数据库中的数据
- 如何用一张JSP页面连接数据库,实现查询、修改操作
- HTML提交表单用户选择的头像如何利用<select>标签提交到PHP并连接数据库进行存读操作
- 如何将对数据库两个表的操作处于用一个事物下?同一个连接对象+事物拦截
- js 连接数据库如何操作数据库中的数据
- JDBC如何与各种数据库连接详解
- python实现简单数据库连接及操作
- 如何获得配置文件中,连接数据库的连接字符串
- SQL2012还原数据库操作在本地服务器上操作和用别的电脑远程连接到服务器进行操作的文件路径差异
- TFS2010备份:TFS2010在重装系统后,如何把以前的tfs数据库文件连接到tfs中
- SQL Server 2008 R2如何开启数据库的远程连接