zoukankan      html  css  js  c++  java
  • 个人学习代码保存:例2.小项目的sql简单的数据库操作类

    using System;
    using System.Data;
    using System.Configuration;
    using System.Web;
    using System.Web.Security;
    using System.Web.UI;
    using System.Web.UI.WebControls;
    using System.Web.UI.WebControls.WebParts;
    using System.Web.UI.HtmlControls;
    using System.Data.SqlClient;

    /// <summary>
    /// DataBase 的摘要说明
    /// </summary>

    public class DataBase
    {
        
    private static DataBase _instance;
        
    public DataBase()
        
    {
            
    //
            
    // TODO: 在此处添加构造函数逻辑
            
    //
        }

        
    /// <summary>
        
    /// 获得一个DataBase实例
        
    /// </summary>
        
    /// <returns></returns>

        public static DataBase getInstance()
        
    {
            
    if (_instance == null)
            
    {
                _instance 
    = new DataBase();
            }

            
    return _instance;
        }

        
    /// <summary>
        
    /// 返回SqlConnection对象实例
        
    /// </summary>
        
    /// <returns></returns>

        public static SqlConnection ReturnCon()
        
    {
            
    string connstr=ConfigurationManager.AppSettings["ConnectionString"].ToString();
            SqlConnection con 
    = new SqlConnection(connstr);
            
    if (con.State.Equals(ConnectionState.Closed))
            
    {
                con.Open();
            }

            
    return con;
        }

        
    /// <summary>
        
    /// 返回SqlCommand对象实例
        
    /// </summary>
        
    /// <param name="procName"></param>
        
    /// <returns></returns>

        public static SqlCommand CreateCmd(string procName)
        
    {
            SqlConnection con 
    = ReturnCon();
            SqlCommand cmd 
    = new SqlCommand(procName,con);
            cmd.CommandType 
    = CommandType.StoredProcedure;
            
    return cmd;
        }

        
    public static SqlCommand CreateCmd(string procName, SqlParameter[] prams)
        
    {
            SqlConnection con 
    = ReturnCon();
            SqlCommand cmd 
    = new SqlCommand(procName,con);
            cmd.CommandType 
    = CommandType.StoredProcedure;
            
    foreach (SqlParameter parameter in prams)
            
    {
                cmd.Parameters.Add(parameter);
            }

            
    return cmd;
        }

        
    public static SqlCommand CreateCmd(string procName, SqlConnection con)
        
    {
            SqlConnection sqlcon 
    = con;
            
    if (sqlcon.State.Equals(ConnectionState.Closed))
            
    {
                sqlcon.Open();
            }

            SqlCommand cmd 
    = new SqlCommand(procName,sqlcon);
            cmd.CommandType 
    = CommandType.StoredProcedure;
            
    return cmd;
        }

        
    public static SqlCommand CreateCmd(string procName, SqlParameter[] prams, SqlConnection con)
        
    {
            SqlConnection sqlcon 
    = con;
            
    if (sqlcon.State.Equals(ConnectionState.Closed))
            
    {
                sqlcon.Open();
            }

            SqlCommand cmd 
    = new SqlCommand(procName,sqlcon);
            cmd.CommandType 
    = CommandType.StoredProcedure;
            
    foreach (SqlParameter parameter in prams)
            
    {
                cmd.Parameters.Add(parameter);
            }

            
    return cmd;
        }

        
    /// <summary>
        
    /// 返回SqlDataReader对象实例
        
    /// </summary>
        
    /// <param name="procName"></param>
        
    /// <returns></returns>

        public static SqlDataReader RunProcGetReader(string procName)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName);
            SqlDataReader sdr 
    = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            
    return sdr;
        }

        
    public static SqlDataReader RunProGetReader(string procName, SqlParameter[] prams)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName, prams);
            SqlDataReader sdr 
    = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            
    return sdr;
        }

        
    public static SqlDataReader RunProGetReader(string procName, SqlConnection con)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName, con);
            SqlDataReader sdr 
    = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            
    return sdr;
        }

        
    public static SqlDataReader RunProGetReader(string procName, SqlParameter[] prams, SqlConnection con)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName, prams, con);
            SqlDataReader sdr 
    = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            
    return sdr;
        }

        
    /// <summary>
        
    /// 返回DataTable对象实例
        
    /// </summary>
        
    /// <param name="procName"></param>
        
    /// <param name="prams"></param>
        
    /// <param name="con"></param>
        
    /// <returns></returns>

        public static DataTable RunProTable(string procName, SqlParameter[] prams, SqlConnection con)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName, prams, con);
            SqlDataAdapter sda 
    = new SqlDataAdapter(cmd);
            DataSet ds 
    = new DataSet();
            sda.Fill(ds);
            DataTable dt
    =ds.Tables[0];
            con.Close();
            
    return dt;
        }

        
    /// <summary>
        
    /// 返回执行结果受影响的行数
        
    /// </summary>
        
    /// <param name="procName"></param>
        
    /// <returns></returns>

        public static int RunProExecute(string procName)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName);
            
    int intResult = cmd.ExecuteNonQuery();
            
    return intResult;
        }

        
    /// <summary>
        
    /// 返回首行首列
        
    /// </summary>
        
    /// <param name="procName"></param>
        
    /// <returns></returns>

        public static int RunProScalar(string procName)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName);
            
    int intResult = Convert.ToInt32(cmd.ExecuteScalar());
            
    return intResult;
        }

        
    public static int RunProScalar(string procName, SqlParameter[] prams)
        
    {
            SqlCommand cmd 
    = CreateCmd(procName, prams);
            
    int intResult = Convert.ToInt32(cmd.ExecuteScalar());
            
    return intResult;
        }

    }

  • 相关阅读:
    Linux线程同步方法
    Linux进程间通信:信号
    孤儿进程僵尸进程及其回收
    Linux守护进程
    Linux系统编程常见函数 (进程/线程)
    Linux系统编程常用函数 (文件/目录)
    C++实现贪吃蛇小游戏
    C++实现简易Vector类
    C++实现简易版字符串类
    《图解HTTP》读书笔记
  • 原文地址:https://www.cnblogs.com/wbcms/p/1034540.html
Copyright © 2011-2022 走看看