public int ReturnExcuteScalar(string strSQL, SqlParameter[] param)
{
using (SqlConnection conn = new SqlConnection(Dbstr.connstr))
{
using (SqlCommand cmd = new SqlCommand())
{
if (conn.State.Equals(ConnectionState.Closed))
{
conn.Open();
}
try
{
cmd.CommandType = CommandType.Text ;
cmd.Connection = conn;
cmd.CommandText = strSQL; foreach (SqlParameter parameter in param)
{
if (parameter != null)
{
cmd.Parameters.Add(parameter);
}
}
int count = (int)cmd.ExecuteScalar();
return count;
}
catch (Exception e)
{
throw e;
}
finally
{
cmd.Dispose();
conn.Close();
}
}
}
}
以上代码是否写的有缺陷,帮忙参考一下、或是不合理的地方
{
using (SqlConnection conn = new SqlConnection(Dbstr.connstr))
{
using (SqlCommand cmd = new SqlCommand())
{
if (conn.State.Equals(ConnectionState.Closed))
{
conn.Open();
}
try
{
cmd.CommandType = CommandType.Text ;
cmd.Connection = conn;
cmd.CommandText = strSQL; foreach (SqlParameter parameter in param)
{
if (parameter != null)
{
cmd.Parameters.Add(parameter);
}
}
int count = (int)cmd.ExecuteScalar();
return count;
}
catch (Exception e)
{
throw e;
}
finally
{
cmd.Dispose();
conn.Close();
}
}
}
}
以上代码是否写的有缺陷,帮忙参考一下、或是不合理的地方
解决方案 »
- 关于上传控件NeatUpload的一些问题
- 急,急,急vs 2003中requestMap怎么接收checkboxlist 的值??
- DataSet.Merge(ds1)之后,如何将更新写入数据库?
- myset.DoModal ()==IDOK
- 创建一个类多个Form调用
- 请问在c#使用#region & #endregion复制后,粘贴到目标行时,每次都展开了,如何让它默认折叠
- 祝大家圣诞快乐~~~!!
- 提供USB狗操作,数据加密类库,丰田美国公司的车行管理系统源码,回帖有分
- 如何判断文件是否创建成功
- Delphi7 调用C#写的com组件(其中调用了webservice)问题
- UBB图片处理问题
- 如何将DataGridView的数据绑定到DataReader中
SqlCommand 没必要吧?
1.完全可以不用using,因为你自己使用的try-catch-finally,可以很好的垃圾回收2.异常有可以能发生于你程序中的下列代码
if (conn.State.Equals(ConnectionState.Closed))
{
conn.Open();//发生异常,退出了using而未释放对象
}3.使用using的目的在于是程序简练
public int ReturnExcuteScalar(string strSQL, SqlParameter[] param)
{
int i_result = 0;
using (SqlConnection conn = new SqlConnection(Dbstr.connstr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandType = CommandType.Text ;
cmd.Connection = conn;
cmd.CommandText = strSQL; foreach (SqlParameter parameter in param)
{
if (parameter != null)
{
cmd.Parameters.Add(parameter);
}
}
int count = (int)cmd.ExecuteScalar();
i_result = count;
//return count; 检测不到
} return i_result;
}
}
{
cmd.Dispose();
conn.Close();
}
你既然在finally里面关闭了连接释放了资源,那外面还要加using干啥?
{
cmd.Dispose();
conn.Close();
}
发现这段代码没有用
{
int i = ReturnExcuteScalar(obj, objs);
}
catch (Exception ex)
{
ex.Message;
}
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
}这段代码是李开平老师写的。哎自学真费劲啊。。搞得一塌糊涂
当然是using(),()中的资源。
/// 执行SQL语句,返回影响的记录数
/// </summary>
/// <param name="SQLString">SQL语句</param>
/// <returns>影响的记录数</returns>
public static int ExecuteSql(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
} public static int ExecuteSqlByTime(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
} public static int ExecuteSqlTran(List<String> SQLStringList)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = connection;
SqlTransaction tx = connection.BeginTransaction();
cmd.Transaction = tx;
try
{
int count = 0;
for (int n = 0; n < SQLStringList.Count; n++)
{
string strsql = SQLStringList[n];
if (strsql.Trim().Length > 1)
{
cmd.CommandText = strsql;
count += cmd.ExecuteNonQuery();
}
}
tx.Commit();
return count;
}
catch
{
tx.Rollback();
return 0;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 执行带一个存储过程参数的的SQL语句。
/// </summary>
/// <param name="SQLString">SQL语句</param>
/// <param name="content">参数内容,比如一个字段是格式复杂的文章,有特殊符号,可以通过这个方式添加</param>
/// <returns>影响的记录数</returns>
public static int ExecuteSql(string SQLString, string content)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(SQLString, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@content", SqlDbType.NText);
myParameter.Value = content;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}/// <summary>
/// 执行一条计算查询结果语句,返回查询结果(object)。
/// </summary>
/// <param name="SQLString">计算查询结果语句</param>
/// <returns>查询结果(object)</returns>
public static object GetSingle(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
}
public static object GetSingle(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
}
{
conn.Open();
}
看到这里,就不需要再看了。