using System;
using System.Data;
using System.Configuration;
using System.Data.SqlClient;
///
/// DbAccess 的摘要说明
///
public class DbAccess
{
private static SqlConnection conn;
private SqlDataAdapter da;
private DataSet ds;
private SqlCommand cmd;
public DbAccess()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
///
/// 获取数据库连接
///
/// 获取数据库连接
internal static SqlConnection GetConn()
{
try
{
//从webConfig中读取数据库链接字符串
string cstr = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
conn = new SqlConnection(cstr);
if (conn.State != ConnectionState.Open)
{
conn.Open();
}
return conn;
}
catch (Exception e)
{
}
return null;
}
///
/// 关闭数据库链接
///
internal static void CloseConn()
{
if (conn.State != ConnectionState.Closed)
{
conn.Close();
}
}
///
/// 执行Sql语句,包括添加,删除,和修改语句
///
/// sql语句
/// 数据库影响的行数
public bool ExecuteSql(string sql)
{
try
{
conn = GetConn();
if (conn.State != ConnectionState.Open)
{
conn.Open();
}
cmd = new SqlCommand(sql, conn);
int flag = cmd.ExecuteNonQuery();
return flag > 0;
}
catch (Exception e)
{
}
finally
{
conn.Close();
}
return false;
}
/// <summary>
/// 根据sql语句返回DataSet类型数据集
/// </summary>
/// <param name="sql">Sql查询语句</param>
/// <returns>DataSet数据集</returns>
public DataSet GetDataSet(string sql)
{
try
{
conn = GetConn();
da = new SqlDataAdapter(sql, conn);
DataSet dst = new DataSet();
da.Fill(dst);
return dst;
}
catch { }
finally
{
conn.Close();
}
return null;
}