cyf
113 lines
4.3 KiB
C#
113 lines
4.3 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Data.SqlClient;
|
|
using System.Data;
|
|
|
|
namespace Lskj.Update
|
|
{
|
|
/// <summary>
|
|
/// SQLServer连接操作类.
|
|
/// </summary>
|
|
public class SQLUtil
|
|
{
|
|
public static string mConnStr;
|
|
|
|
public static string GetSqlConnectionString()
|
|
{
|
|
return mConnStr;
|
|
}
|
|
/// <summary>
|
|
/// <para>说明：适合增删改操作，返回影响条数</para>
|
|
/// <para>创建人：龚宇超</para>
|
|
/// <para>创建日期：2019-08-30 </para>
|
|
/// <para>修改人：</para>
|
|
/// <para>修改日期：</para>
|
|
/// <para>修改备注：</para>
|
|
/// <para>版本：1.0</para>
|
|
/// </summary>
|
|
/// <param name="sql">The SQL.</param>
|
|
/// <param name="parameters">The parameters.</param>
|
|
/// <returns>System.Int32.</returns>
|
|
public static int ExecuteNonQuery(string sql, params SqlParameter[] parameters)
|
|
{
|
|
using (SqlConnection conn = new SqlConnection(GetSqlConnectionString()))
|
|
{
|
|
using (SqlCommand comm = conn.CreateCommand())
|
|
{
|
|
conn.Open();
|
|
comm.CommandText = sql;
|
|
comm.Parameters.AddRange(parameters);
|
|
return comm.ExecuteNonQuery();
|
|
}
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// <para>说明：查询操作，返回查询结果中的第一行第一列的值</para>
|
|
/// <para>创建人：龚宇超</para>
|
|
/// <para>创建日期：2019-08-30 </para>
|
|
/// <para>修改人：</para>
|
|
/// <para>修改日期：</para>
|
|
/// <para>修改备注：</para>
|
|
/// <para>版本：1.0</para>
|
|
/// </summary>
|
|
/// <param name="sql">The SQL.</param>
|
|
/// <param name="parameters">The parameters.</param>
|
|
/// <returns>System.Object.</returns>
|
|
public static object ExecuteScalar(string sql, params SqlParameter[] parameters)
|
|
{
|
|
using (SqlConnection conn = new SqlConnection(GetSqlConnectionString()))
|
|
{
|
|
using (SqlCommand comm = conn.CreateCommand())
|
|
{
|
|
conn.Open();
|
|
comm.CommandText = sql;
|
|
comm.Parameters.AddRange(parameters);
|
|
return comm.ExecuteScalar();
|
|
}
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// <para>说明：Adapter调整，查询操作，返回DataTable</para>
|
|
/// <para>创建人：龚宇超</para>
|
|
/// <para>创建日期：2019-08-30 </para>
|
|
/// <para>修改人：</para>
|
|
/// <para>修改日期：</para>
|
|
/// <para>修改备注：</para>
|
|
/// <para>版本：1.0</para>
|
|
/// </summary>
|
|
/// <param name="sql">The SQL.</param>
|
|
/// <param name="parameters">The parameters.</param>
|
|
/// <returns>DataTable.</returns>
|
|
public static DataTable ExecuteDataTable(string sql, params SqlParameter[] parameters)
|
|
{
|
|
try
|
|
{
|
|
using (SqlDataAdapter adapter = new SqlDataAdapter(sql, GetSqlConnectionString()))
|
|
{
|
|
DataTable dt = new DataTable();
|
|
adapter.SelectCommand.Parameters.AddRange(parameters);
|
|
adapter.Fill(dt);
|
|
return dt;
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
return new DataTable();
|
|
}
|
|
public static SqlDataReader ExecuteReader(string sqlText, params SqlParameter[] parameters)
|
|
{
|
|
//SqlDataReader要求，它读取数据的时候有，它独占它的SqlConnection对象，而且SqlConnection必须是Open状态
|
|
SqlConnection conn = new SqlConnection(GetSqlConnectionString());//不要释放连接，因为后面还需要连接打开状态
|
|
SqlCommand cmd = conn.CreateCommand();
|
|
conn.Open();
|
|
cmd.CommandText = sqlText;
|
|
cmd.Parameters.AddRange(parameters);
|
|
//CommandBehavior.CloseConnection当SqlDataReader释放的时候，顺便把SqlConnection对象也释放掉
|
|
return cmd.ExecuteReader(CommandBehavior.CloseConnection);
|
|
}
|
|
}
|
|
}
|