zoukankan      html  css  js  c++  java
  • ADO

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Configuration;
    using System.Data;
    using System.Data.SqlClient;
    
    namespace ConsoleApp2
    {
        public static class SqlHelper
        {
            private static readonly string constr = ConfigurationManager.ConnectionStrings["mysql"].ConnectionString;
    
            public static int ExecuteNonQuery(string sqlStr, CommandType commandType, params SqlParameter[] pms)
            {
                using (SqlConnection con = new SqlConnection(constr))
                {
                    using (SqlCommand cmd = new SqlCommand(sqlStr, con))
                    {
                        cmd.CommandType = commandType;
                        if (pms != null)
                            cmd.Parameters.AddRange(pms);
    
                        con.Open();
                        object a= cmd.ExecuteNonQuery();
                        return 0;
                    }
                }
            }
    
            public static object ExecuteScalar(string sqlStr, CommandType commandType, params SqlParameter[] pms)
            {
                using (SqlConnection con = new SqlConnection(constr))
                {
                    using (SqlCommand cmd = new SqlCommand(sqlStr, con))
                    {
                        cmd.CommandType = commandType;
                        if (pms != null)
                        {
                            cmd.Parameters.Clear();
                            cmd.Parameters.AddRange(pms);
                        }
                        con.Open();
                        return cmd.ExecuteScalar();
                    }
                }
    
            }
    
    
            public static SqlDataReader ExecuteReader(string sqlStr, CommandType commandType, params SqlParameter[] pms)
            {
                SqlConnection con = new SqlConnection(constr);
                using (SqlCommand cmd = new SqlCommand(sqlStr, con))
                {
                    cmd.CommandType = commandType;
                    if (pms != null)
                    {
                        cmd.Parameters.Clear();
                        cmd.Parameters.AddRange(pms);
                    }
                    try
                    {
                        if (con.State == ConnectionState.Closed)
                            con.Open();
                        return cmd.ExecuteReader(CommandBehavior.CloseConnection);
                    }
                    catch (Exception)
                    {
                        if (con.State == ConnectionState.Open)
                        {
                            con.Close();
                            con.Dispose();
                        }
                        throw;
                    }
                }
            }
    
            public static DataTable ExecuteTable(string sqlStr, CommandType commandType, params SqlParameter[] pms)
            {
                DataTable table = new DataTable();
                using (SqlConnection con = new SqlConnection(constr))
                {
                    using (SqlDataAdapter adapt = new SqlDataAdapter(sqlStr, con))
                    {
                        adapt.SelectCommand.CommandType = commandType;
                        if (pms != null)
                        {
                            adapt.SelectCommand.Parameters.Clear();
                            adapt.SelectCommand.Parameters.AddRange(pms);
                        }
                        con.Open();
                        adapt.Fill(table);
                    }
                }
                return table;
            }
    
    
        }
    }
      private static void Insert()
            {
                List<string> list = new List<string>();
    
                List<SqlParameter> pms = new List<SqlParameter>();
                for (int i = 101; i < 1101; i++)
                {
                    string name = "name" + i;
                    string pwd = "pwd" + i;
                    string str = $"('@{name}','@{pwd}')";
                    pms.Add(new SqlParameter($"@{name}",$"@{pwd}"));
                    list.Add(str);
                }
                string sqlStr = $"insert into LoginData values {string.Join(",", list)}";
                int ii = SqlHelper.ExecuteNonQuery(sqlStr, System.Data.CommandType.Text,pms.ToArray());
                Console.WriteLine(ii);
            }
    
            private void Select()
            {
                Console.WriteLine("name:");
                string name = Console.ReadLine();
                Console.WriteLine("密码:");
                string pwd = Console.ReadLine();
    
                string sqlStr = "select count(0) from LoginData where name=@name and password=@pwd";
                List<SqlParameter> pms = new List<SqlParameter>()
                {
                    new SqlParameter("@name",name),
                    new SqlParameter("@pwd",pwd)
                };
                object num = SqlHelper.ExecuteScalar(sqlStr, CommandType.Text, pms.ToArray());
                Console.WriteLine(num);
            }
  • 相关阅读:
    Asp.Net异步页处理
    iframe通过js自动调节高度
    Js 代码
    JavaScript使用面向对象的技术创建高级 Web 应用程序 (转)
    C#泛型深入浅出(转)
    Asp.Net异步页面处理(转)
    ASP.NET分页存储过程自定义用户控件(转)
    .NET Remoting程序开发入门篇(转)
    认识WebService (转)
    Java CompletableFuture 详解
  • 原文地址:https://www.cnblogs.com/wwz-wwz/p/8955297.html
Copyright © 2011-2022 走看看