zoukankan      html  css  js  c++  java
  • ADO.NET数据读取封装

    public class sqlserver
    {
    //private string sqlstr = System.ConfigurationManager.ConnectionStrings["conn03"].ConnectionString;
    private string sqlstr = System.Configuration.ConfigurationManager.AppSettings["conn03"].ToString();

    //返回datatable
    public DataTable ExecuteDataTable(string sql,params SqlParameter[] parameters)
    {
    //第一步创建连接
    using (SqlConnection con = new SqlConnection(sqlstr))
    {
    con.Open();
    //实例工具
    using(SqlCommand cmd = new SqlCommand (sql, con))
    {
    //新增参数
    foreach (SqlParameter item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    DataTable dt = new DataTable();
    //获取数据
    SqlDataAdapter dr = new SqlDataAdapter(cmd);
    //填充到表
    dr.Fill(dt);
    return dt;
    }
    }
    }

    //返回dataset
    public DataSet ExecuteDataSet(string sql,params SqlParameter[] parameters)
    {
    using (SqlConnection con = new SqlConnection(sqlstr))
    {
    con.Open();
    using (SqlCommand cmd = new SqlCommand(sql,con))
    {

    foreach (SqlParameter item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    DataSet ds = new DataSet ();
    SqlDataAdapter dr = new SqlDataAdapter(cmd);
    dr.Fill(ds);
    return ds;
    }

    }
    }


    //执行增删改
    public int ExecuteNonQuery(string sql, params SqlParameter[] parameters)
    {
    using (SqlConnection con = new SqlConnection(sqlstr))
    {
    con.Open();
    using (SqlCommand cmd = new SqlCommand(sql, con))
    {

    foreach (SqlParameter item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    return cmd.ExecuteNonQuery();
    }

    }

    }

    //反回首行首列
    public object ExecuScalar(string sql, params SqlParameter[] parameters)
    {

    using (SqlConnection con = new SqlConnection(sqlstr))
    {
    con.Open();
    using (SqlCommand cmd = new SqlCommand(sql, con))
    {

    foreach (SqlParameter item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    return cmd.ExecuteScalar();
    }

    }
    }


    //利用读取器来读取数据
    public SqlDataReader ExecuteReader(string sql, params SqlParameter[] parameters)
    {
    using (SqlConnection con = new SqlConnection(sqlstr))
    {
    con.Open();
    using (SqlCommand cmd = new SqlCommand(sql, con))
    {

    foreach (SqlParameter item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    return cmd.ExecuteReader();
    }

    }

    }
    }

  • 相关阅读:
    MPF源码分析之资源文件加载
    oracle存储过程代码日志记录
    fix8源码分析之日志模块
    oracle日期转整数
    记录OCI操作一个诡异的问题
    记录一个虚拟机重启网络启动失败问题
    buff占用内存高
    MFC程序编译链接问题汇总一
    回调函数模型设计
    利用call与apply向函数传递参数
  • 原文地址:https://www.cnblogs.com/liwp/p/6371057.html
Copyright © 2011-2022 走看看