数据库连接的多种方式(三)

public static string ConnectionString
{
get
{
return CFunc.ConnectionString;
//return System.Configuration.ConfigurationManager.ConnectionStrings["DataBase"].ConnectionString;
}
}

//wen
public static int ExecuteSqlCommand(SqlCommand sqlCommand) {
using (SqlConnection conn = new SqlConnection(CData.ConnectionString)) {
sqlCommand.Connection = conn;
conn.Open();
int result = sqlCommand.ExecuteNonQuery();
conn.Close();
return result;
}
}

public static object ExecuteScalar(SqlCommand sqlCommand) {
using (SqlConnection conn = new SqlConnection(CData.ConnectionString)) {
sqlCommand.Connection = conn;
conn.Open();
object obj = sqlCommand.ExecuteScalar();
conn.Close();
return obj;
}
}

public static int ExecuteSql(string sql) {
using (SqlCommand cmd = GetSqlCommand(sql)) {
cmd.Connection.Open();
int i = cmd.ExecuteNonQuery();
cmd.Connection.Close();
return i;
}
}

///// <summary>
///// 执行带参数SQL语句
///// </summary>
///// <param name="sql"></param>
///// <param name="cmdParms"></param>
///// <returns></returns>
//public static int ExecuteNonQuery(string sql, params SqlParameter[] cmdParms) {
//    using (SqlConnection connection = new SqlConnection(ConnectionString)) {
//        using (SqlCommand cmd = new SqlCommand(sql, connection)) {
//            cmd.Parameters.AddRange(cmdParms);
//            return cmd.ExecuteNonQuery();
//        }
//    }
//}
//wen

public static SqlCommand GetSqlCommand(string Sql)
{
System.Data.SqlClient.SqlConnection Conn = new System.Data.SqlClient.SqlConnection(CData.ConnectionString);
SqlCommand Cmd = new SqlCommand(Sql, Conn);
return Cmd;
}

public static SqlDataReader GetSqlDataReader(string Sql)
{
SqlCommand Cmd = GetSqlCommand(Sql);
SqlDataReader DataReader = null;
try
{
Cmd.Connection.Open();
DataReader = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
}
catch (Exception e)
{
Cmd.Connection.Close();
CFunc.ResponseException(e.Message);
}
return DataReader;
}

public static SqlDataReader GetSqlDataReader(string sql, params SqlParameter[] sqlParameter) {
SqlCommand cmd = GetSqlCommand(sql);
cmd.Parameters.AddRange(sqlParameter);
SqlDataReader dataReader = null;
try {
cmd.Connection.Open();
dataReader = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
}
catch (Exception e) {
cmd.Connection.Close();
throw e;
}
return dataReader;
}

public static System.Data.DataSet GetDataSet(string Sql)
{

SqlDataAdapter Ada = new SqlDataAdapter();
Ada.SelectCommand = GetSqlCommand(Sql);
System.Data.DataSet ds = new System.Data.DataSet();
try
{
Ada.SelectCommand.Connection.Open();
Ada.Fill(ds);
Ada.SelectCommand.Connection.Close();
}
catch (Exception e)
{
Ada.SelectCommand.Connection.Close();
CFunc.ResponseException(e.Message);
}
return ds;
}

public static System.Data.DataSet GetDataSet(SqlCommand sqlCommand) {
using (SqlConnection conn = new SqlConnection(CData.ConnectionString)) {
sqlCommand.Connection = conn;
SqlDataAdapter da = new SqlDataAdapter(sqlCommand);
conn.Open();
DataSet ds = new DataSet();
da.Fill(ds);
conn.Close();
return ds;
}
}

public static System.Data.DataTable GetDataTable(string Sql)
{
System.Data.DataSet ds = GetDataSet(Sql);
System.Data.DataTable Dt = ds.Tables[0];
ds.Dispose();
return Dt;
}

public static object ExecuteScalar(string Sql)
{
SqlCommand Cmd = GetSqlCommand(Sql);
object Obj = null;
try
{
Cmd.Connection.Open();
Obj = Cmd.ExecuteScalar();
}
catch (Exception e)
{
Cmd.Connection.Close();
throw e;
}
Cmd.Connection.Close();
return Obj;
}

public static int ExecuteNonQuery(string Sql)
{
SqlCommand Cmd = GetSqlCommand(Sql);
int i = -1;
try
{
Cmd.Connection.Open();
i = Cmd.ExecuteNonQuery();
Cmd.Connection.Close();
}
catch (Exception e)
{
Cmd.Connection.Close();
CFunc.ResponseException(e.Message + " > ");
}

return i;
}
public static int ExecuteNonQuery(string sql, SqlParameter[] sqlParameters)
{
SqlCommand cmd = GetSqlCommand(sql);
//foreach (SqlParameter SP in Parameters)
//{
//    Cmd.Parameters.Add(SP);
//}
cmd.Parameters.AddRange(sqlParameters);
int i = -1;
try
{
cmd.Connection.Open();
i = cmd.ExecuteNonQuery();
cmd.Connection.Close();
}
catch (Exception e)
{
cmd.Connection.Close();
//CFunc.ResponseException(e.Message + " > " + sql);
throw e;
}

return i;
}

public static string[] GetRecordOne(string StrSql, int ColumnNum)
{
string[] Record = new string[ColumnNum];
System.Data.SqlClient.SqlDataReader Dr = GetSqlDataReader(StrSql);

if (Dr.Read())
{
for (int i = 0; i < ColumnNum; i++)
{
Record[i] = Dr[i].ToString();
}
}
else
{
//CFunc.ResponseException(StrSql);
Record = null;
}
Dr.Close();
return Record;
}