C# SqlHelper (一)
2015-08-14 21:32
323 查看
class SqlHelper
{
/// <summary>
/// 插入数据
/// </summary>
/// <param name="sql"></param>
/// <param name="paramaters"></param>
/// <returns></returns>
public static int ExecuteNonQuery(string sql,params SqlParameter[] paramaters)
{
using (SqlConnection conn=new SqlConnection())
{
conn.ConnectionString = "server=.;database=T_Test;Trusted_Connection=SSPI";
conn.Open();
using (SqlCommand cmd=conn.CreateCommand())
{
cmd.CommandText = sql;
foreach (SqlParameter parameter in paramaters)
{
cmd.Parameters.Add(parameter);
}
return cmd.ExecuteNonQuery();
}
}
}
/// <summary>
/// 查询数据,并返回结果的第一行第一列
/// </summary>
/// <param name="sql"></param>
/// <param name="paramaters"></param>
/// <returns></returns>
public static object ExecuteScalar(string sql, params SqlParameter[] paramaters)
{
using (SqlConnection conn = new SqlConnection())
{
conn.ConnectionString = "server=.;database=T_Test;Trusted_Connection=SSPI";
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sql;
foreach (SqlParameter parameter in paramaters)
{
cmd.Parameters.Add(parameter);
}
//返回查询结果的第一行第一列。
return cmd.ExecuteScalar();
}
}
}
/// <summary>
/// 查询数据,返回查询结果的一个数据集
/// </summary>
/// <param name="sql"></param>
/// <param name="paramaters"></param>
/// <returns></returns>
public static DataTable ExecuteDataTable(string sql, params SqlParameter[] paramaters)
{
using (SqlConnection conn = new SqlConnection())
{
conn.ConnectionString = "server=.;database=T_Test;Trusted_Connection=SSPI";
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sql;
foreach (SqlParameter parameter in paramaters)
{
cmd.Parameters.Add(parameter);
}
//新建一个DataSet类对象
DataSet dataset = new DataSet();
//新建一个SqlDataAdapter类对象,创建数据适配器对象
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
//将得到的结果填充到dataset中。具体是如何操作的由SqlDataAdapter类完成,无需多关心.
adapter.Fill(dataset);
//dataset可以有多个表,这里我们只用到了一个表,所以返回一个表。
return dataset.Tables[0];
}
}
}
}
{
/// <summary>
/// 插入数据
/// </summary>
/// <param name="sql"></param>
/// <param name="paramaters"></param>
/// <returns></returns>
public static int ExecuteNonQuery(string sql,params SqlParameter[] paramaters)
{
using (SqlConnection conn=new SqlConnection())
{
conn.ConnectionString = "server=.;database=T_Test;Trusted_Connection=SSPI";
conn.Open();
using (SqlCommand cmd=conn.CreateCommand())
{
cmd.CommandText = sql;
foreach (SqlParameter parameter in paramaters)
{
cmd.Parameters.Add(parameter);
}
return cmd.ExecuteNonQuery();
}
}
}
/// <summary>
/// 查询数据,并返回结果的第一行第一列
/// </summary>
/// <param name="sql"></param>
/// <param name="paramaters"></param>
/// <returns></returns>
public static object ExecuteScalar(string sql, params SqlParameter[] paramaters)
{
using (SqlConnection conn = new SqlConnection())
{
conn.ConnectionString = "server=.;database=T_Test;Trusted_Connection=SSPI";
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sql;
foreach (SqlParameter parameter in paramaters)
{
cmd.Parameters.Add(parameter);
}
//返回查询结果的第一行第一列。
return cmd.ExecuteScalar();
}
}
}
/// <summary>
/// 查询数据,返回查询结果的一个数据集
/// </summary>
/// <param name="sql"></param>
/// <param name="paramaters"></param>
/// <returns></returns>
public static DataTable ExecuteDataTable(string sql, params SqlParameter[] paramaters)
{
using (SqlConnection conn = new SqlConnection())
{
conn.ConnectionString = "server=.;database=T_Test;Trusted_Connection=SSPI";
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sql;
foreach (SqlParameter parameter in paramaters)
{
cmd.Parameters.Add(parameter);
}
//新建一个DataSet类对象
DataSet dataset = new DataSet();
//新建一个SqlDataAdapter类对象,创建数据适配器对象
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
//将得到的结果填充到dataset中。具体是如何操作的由SqlDataAdapter类完成,无需多关心.
adapter.Fill(dataset);
//dataset可以有多个表,这里我们只用到了一个表,所以返回一个表。
return dataset.Tables[0];
}
}
}
}
相关文章推荐
- HBase 数据库检索性能优化策略
- SQLServer With As 用法
- MongoDB 查询上
- mysql如何把在屏幕上输出的结果输出到一个文件上?
- Oracle11g下载地址--多平台下的32位和64位
- redis 学习笔记(二)
- 简单REST 客户端使用 SQL,Hadoop,Drill
- Oracle 学习之RAC(九) 集群负载均衡及故障转移
- redis安装使用教程
- Redis监控方案
- oracle TNS-03505: 无法解析名称错误
- Oracle开发中的正则表达式
- mysql登录和连接 权限
- RHEL6.5上Oracle ACFS与Linux samba一起使用时遇到的bug
- 常用Oracle数据表操作命令
- PLSQL操作Oracle创建用户和表
- mysql 数据导入导出命令
- ERROR 2002 (HY000): Can't connect to local MySQL server through socket '/tmp/mysql.sock'
- Hibernate将sql查询结果中字符转为char类型的原因
- oracle中Connect By用法介绍