zoukankan      html  css  js  c++  java
  • ADO.NET通用数据库访问类

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;

    using System.Data;
    using System.Data.SqlClient;

    namespace Test
    {
        public class DBHelper
        {
            public static string ConString = "Data Source=.;Initial Catalog=bankdb;User id=sa;Password=123;";

            //执行增删改的方法
            public static int RunNoQuery(string cmdText, CommandType cmdType, params SqlParameter[] pars)
            {
                SqlConnection con = new SqlConnection(ConString);
                con.Open();
                SqlCommand cmd = new SqlCommand(cmdText, con);
                cmd.CommandType = cmdType;
                if (pars != null && pars.Length > 0)
                {
                    foreach (SqlParameter p in pars)
                    {
                        cmd.Parameters.Add(p);
                    }
                }
                int rows = cmd.ExecuteNonQuery();
                con.Close();
                return rows;
            }

            //执行查询(DataSet)的方法
            public static DataSet RunSelect(string cmdText, CommandType cmdType, params SqlParameter[] pars)
            {
                SqlConnection con = new SqlConnection(ConString);
              
                SqlDataAdapter da = new SqlDataAdapter(cmdText, con);
                da.SelectCommand.CommandType = cmdType;
                if (pars != null && pars.Length > 0)
                {
                    foreach (SqlParameter p in pars)
                    {
                        da.SelectCommand.Parameters.Add(p);
                    }
                }
                DataSet ds = new DataSet();
                da.Fill(ds);

                return ds;
            }

            //执行查询得到一个值
            public static object RunOneValue(string cmdText, CommandType cmdType, params SqlParameter[] pars)
            {
                SqlConnection con = new SqlConnection(ConString);
                con.Open();
                SqlCommand cmd = new SqlCommand(cmdText, con);
                cmd.CommandType = cmdType;
                if (pars != null && pars.Length > 0)
                {
                    foreach (SqlParameter p in pars)
                    {
                        cmd.Parameters.Add(p);
                    }
                }
                object obj = cmd.ExecuteScalar();
                con.Close();
                return obj;
            }
        }
    }
  • 相关阅读:
    Hadoop 回收站
    Sparkstreaming reduceByKeyAndWindow(_+_, _-_, Duration, Duration) 的源码/原理解析
    spark streaming updateStateByKey 用法
    spark streaming 直连 kafka 分区
    sparkStreaming 练习
    json demo
    spark与flume整合
    spark sql 入门
    【面试】c++单例模式
    Python高级笔记(十一)装饰器【面试】
  • 原文地址:https://www.cnblogs.com/turingchang/p/5287135.html
Copyright © 2011-2022 走看看