楼主你好： 下面代码 应该是你要的： using System;using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
namespace WindowsApplication6{
public static class DBManager
{
private static string connectionstring = "Data source=(local)\\sqlexpress;initial catalog=pubs;integrated security=true;pooling=false;";
/// <summary>
/// 单条执行SQL
/// </summary>
/// <param name="sql">你的update或者delete或者insert语句</param>
/// <returns></returns>
public static int ExecuteSingleSql(string sql)
{
using (SqlConnection cnn = new SqlConnection(connectionstring))
{
try
{
SqlCommand cmd = new SqlCommand(sql, cnn);
cnn.Open();
return cmd.ExecuteNonQuery();
}
catch (Exception ex)
{
throw ex;
}
}
}
/// <summary>
/// 多条执行
/// </summary>
/// <param name="list"></param>
public static void ExecuteSqlTran(ArrayList list)
{
using (SqlConnection cnn = new SqlConnection(connectionstring))
{
cnn.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = cnn;
SqlTransaction tr = cnn.BeginTransaction(); cmd.Transaction = tr;
try
{
for (int n = 0; n < list.Count; n++)
{
string sql = list[n].ToString();
if (sql.Trim().Length > 0)
{
cmd.CommandText = sql;
cmd.ExecuteNonQuery();
}
}
tr.Commit();
}
catch (Exception ex)
{
tr.Rollback();
throw new Exception(ex.Message);
}
}
}
public static void ExecuteSqlTran2(ArrayList list) {
using (SqlConnection cnn = new SqlConnection(connectionstring))
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = cnn;
SqlTransaction tr = cnn.BeginTransaction(); cmd.Transaction = tr;
try {
for (int i = 0; i < list.Count; i++)
{
string sql = list[i].ToString();
if (sql.Trim().Length > 1)
{
cmd.CommandText = sql;
cmd.ExecuteNonQuery();
}
} tr.Commit();
} catch (Exception ex)
{
tr.Rollback();
throw new Exception(ex.Message);
}
}
}
/// <summary> /// 执行sql的反应行数
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public static int HasData(string sql)
{
using (SqlConnection cnn = new SqlConnection(connectionstring))
{
using (SqlCommand cmd = new SqlCommand(sql, cnn)) {
try {
cnn.Open();
return (Int32)cmd.ExecuteScalar();
}
catch (Exception ex)
{
throw ex; }
}
}
}
/// <summary> /// 查询
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public static DataSet GetDataSet(string sql)
{
using (SqlConnection cnn = new SqlConnection(connectionstring))
{
try {
DataSet ds = new DataSet();
SqlDataAdapter da = new SqlDataAdapter(sql, cnn);
cnn.Open();
da.Fill(ds);
return ds;
}
catch (Exception ex)
{
throw ex;
}
}
}
}}
希望对你有帮主，望采纳，谢谢