.net 数据库连接方法
2008-12-05 17:23
387 查看
C#:
XML:
<connectionStrings>
<add name="TangCompanyConn" connectionString="Data Source=localhost;Initial Catalog=TangCompany;User ID=sa;Password=yongshiok" providerName="System.Data.SqlClient"/>
</connectionStrings>
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;
//该源码首发自www.51aspx.com(51aspx.com)
/// <summary>
/// SqlHelper 的摘要说明
/// </summary>
public class SqlHelper
{
private static readonly string strConn = ConfigurationManager.ConnectionStrings["TangCompanyConn"].ConnectionString;
private static readonly string strName = ConfigurationManager.AppSettings["userName"].ToString();
private static readonly string strPass = ConfigurationManager.AppSettings["userPass"].ToString();
public SqlHelper()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
public static SqlDataReader ExcuteRead(string nText, CommandType nType, SqlParameter[] paras) {
SqlConnection conn = new SqlConnection(strConn);
SqlCommand cmd = new SqlCommand();
try
{
PrepareCommand(conn, cmd, null, nType, nText, paras);
SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return dr;
}
catch(SqlException ex){
throw new Exception(ex.Message, ex);
}
}
public static int ExcuteNonQurey(string nText, CommandType nType, SqlParameter[] paras) {
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(strConn)) {
PrepareCommand(conn, cmd, null, nType, nText, paras);
int rows = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return rows;
}
}
public static object ExcuteSclare(string nText, CommandType nType, SqlParameter[] paras) {
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(strConn)) {
PrepareCommand(conn, cmd, null, nType, nText, paras);
object obj = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return obj;
}
}
public static DataSet ExcuteReadApdater(string nText, CommandType nType, SqlParameter[] paras) {
SqlConnection con = new SqlConnection(strConn);
SqlCommand cmd = new SqlCommand();
DataSet ds = new DataSet();
try
{
PrepareCommand(con, cmd, null, nType, nText, paras);
SqlDataAdapter sqlAdapter = new SqlDataAdapter(cmd);
sqlAdapter.Fill(ds);
cmd.Parameters.Clear();
return ds;
}
catch (SqlException ex) {
throw new Exception(ex.Message, ex);
}
}
public static void PrepareCommand(SqlConnection con, SqlCommand cmd, SqlTransaction trans, CommandType nType, string nText, SqlParameter[] paras) {
if (con.State != ConnectionState.Open)
con.Open();
cmd.Connection = con;
cmd.CommandText = nText;
if (trans != null) {
cmd.Transaction = trans;
}
cmd.CommandType = nType;
if (paras != null) {
foreach (SqlParameter para in paras) {
cmd.Parameters.Add(para);
}
}
}
}
XML:
<connectionStrings>
<add name="TangCompanyConn" connectionString="Data Source=localhost;Initial Catalog=TangCompany;User ID=sa;Password=yongshiok" providerName="System.Data.SqlClient"/>
</connectionStrings>
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;
//该源码首发自www.51aspx.com(51aspx.com)
/// <summary>
/// SqlHelper 的摘要说明
/// </summary>
public class SqlHelper
{
private static readonly string strConn = ConfigurationManager.ConnectionStrings["TangCompanyConn"].ConnectionString;
private static readonly string strName = ConfigurationManager.AppSettings["userName"].ToString();
private static readonly string strPass = ConfigurationManager.AppSettings["userPass"].ToString();
public SqlHelper()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
public static SqlDataReader ExcuteRead(string nText, CommandType nType, SqlParameter[] paras) {
SqlConnection conn = new SqlConnection(strConn);
SqlCommand cmd = new SqlCommand();
try
{
PrepareCommand(conn, cmd, null, nType, nText, paras);
SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return dr;
}
catch(SqlException ex){
throw new Exception(ex.Message, ex);
}
}
public static int ExcuteNonQurey(string nText, CommandType nType, SqlParameter[] paras) {
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(strConn)) {
PrepareCommand(conn, cmd, null, nType, nText, paras);
int rows = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return rows;
}
}
public static object ExcuteSclare(string nText, CommandType nType, SqlParameter[] paras) {
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(strConn)) {
PrepareCommand(conn, cmd, null, nType, nText, paras);
object obj = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return obj;
}
}
public static DataSet ExcuteReadApdater(string nText, CommandType nType, SqlParameter[] paras) {
SqlConnection con = new SqlConnection(strConn);
SqlCommand cmd = new SqlCommand();
DataSet ds = new DataSet();
try
{
PrepareCommand(con, cmd, null, nType, nText, paras);
SqlDataAdapter sqlAdapter = new SqlDataAdapter(cmd);
sqlAdapter.Fill(ds);
cmd.Parameters.Clear();
return ds;
}
catch (SqlException ex) {
throw new Exception(ex.Message, ex);
}
}
public static void PrepareCommand(SqlConnection con, SqlCommand cmd, SqlTransaction trans, CommandType nType, string nText, SqlParameter[] paras) {
if (con.State != ConnectionState.Open)
con.Open();
cmd.Connection = con;
cmd.CommandText = nText;
if (trans != null) {
cmd.Transaction = trans;
}
cmd.CommandType = nType;
if (paras != null) {
foreach (SqlParameter para in paras) {
cmd.Parameters.Add(para);
}
}
}
}
相关文章推荐
- .NET连接数据库字符串密码丢失的解决方法(persist security info=true;)
- .net 数据库连接方法
- .NET连接数据库的几种方法
- .NET 连接数据库方法
- .NET连接数据库字符串密码丢失的解决方法(persist security info=true;)
- .net连接数据库方法
- .net连接数据库mysql常用方法
- .net程序无法连接oracle9.2.0.1数据库解决方法
- .net 数据库连接方法
- .net中连接数据库的几种方法(vb.net)
- jsp中上传大文件(200M已测试),存到数据库,易发生连接超时的ie找不到网页的错误,其解决方法。略写代码,参考(.net修改代码应该可以,改天修改)
- .NET----ASP.NET配置(web.config)无法连接到SQL Server 数据库的解决方法
- C++连接数据库的方法
- .NET(C#)连接各类数据库-集锦
- DBCP数据库连接失效的解决方法(Io 异常:Connection reset)
- java连接数据库的方法
- sql server2000+vs2005连接数据库时出错,解决方法
- .net连接MYSQL数据库的方法及示例!
- 数据库连接方法
- JDBC连接各种数据库的方法