zoukankan      html  css  js  c++  java
  • 数据库连接

    using System;
    using System.Collections.Generic;
    using System.Data.SqlClient;
    using System.Data;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    
    namespace Web.Services
    {
        class DBHelper
        {
            /// <summary>
            /// 执行增删改查语句
            /// </summary>
            /// <param name="sql"></param>
            /// <returns></returns>
            public static bool Update(string sql)
            {
                var con = new SqlConnection("server=.;database=Practice;uid=sa;pwd=sa");
                con.Open();
                var cmd = con.CreateCommand();
                cmd.CommandText = sql;
                var result = cmd.ExecuteNonQuery();
                con.Close();
                return result > 0;
            }
            /// <summary>
            /// 返回结果表中的第一行的第一个单元格数据
            /// </summary>
            /// <param name="sql"></param>
            /// <returns></returns>
            public static object SelectForScalar(string sql)
            {
                var con = new SqlConnection("server=.;database=Practice;uid=sa;pwd=sa");
                con.Open();
                var cmd = con.CreateCommand();
                cmd.CommandText = sql;
                var result = cmd.ExecuteScalar();
                con.Close();
                return result;
            }
            /// <summary>
            /// 返回所有结果
            /// </summary>
            /// <param name="sql"></param>
            /// <returns></returns>
            public static SqlDataReader SelectForReader(string sql)
            {
                var con = new SqlConnection("server=.;database=Practice;uid=sa;pwd=sa");
                con.Open();
                var cmd = con.CreateCommand();
                cmd.CommandText = sql;
                return cmd.ExecuteReader(CommandBehavior.CloseConnection);
            }
        } 
    }
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Data;
    using System.Data.SqlClient;
    using System.Configuration;
    
    namespace Web.Services
    {
        public class DBHelperNew
        {
            private static SqlConnection connection;
    
            //public static SqlConnection Connection
            //{
            //    get
            //    {
            //        //类似单例模式
            //        if (connection == null) connection = new SqlConnection
            //             ("server=.;database=Practice;uid=sa;pwd=sa");
            //        return connection;
            //    }
            //}
    
            public static SqlConnection Connection
            {
                get
                {
                    if (connection == null) connection = new SqlConnection(
                           ConfigurationManager.ConnectionStrings["con"].ConnectionString
                           );
                    if (connection.State == ConnectionState.Broken)
                    {
                        connection.Close();
                    }
                    connection.Open();
                    return connection;
                }
            }
    
            public static SqlCommand Command
            {
                get { return Connection.CreateCommand(); }
            }
    
            public static bool Update(string sql)
            {
                var cmd = Command;
                cmd.CommandText = sql;
                try
                {
                    var result = cmd.ExecuteNonQuery();
                    cmd.Connection.Close();
                    return result > 0;
                }
                catch (Exception ex)
                {
                    cmd.Connection.Close();
                    throw;
                }
            }
    
            public static object SelectForScalar(string sql)
            {
                var cmd = Command;
                cmd.CommandText = sql;
                try
                {
                    var result = cmd.ExecuteScalar();
                    cmd.Connection.Close();
                    return result;
                }
                catch (Exception e)
                {
                    cmd.Connection.Close();
                    throw;
                }
            }
    
            public static SqlDataReader SelectForReader(string sql)
            {
                var cmd = Command;
                cmd.CommandText = sql;
                try
                {
                    return cmd.ExecuteReader(CommandBehavior.CloseConnection);
                }
                catch (Exception e)
                {
                    cmd.Connection.Close();
                    throw;
                }
            }
    
        }
    }
    View Code
  • 相关阅读:
    MySQL Replication主从复制
    使用Amoeba 实现MySQL DB 读写分离
    Amoeba For MySQL入门:实现数据库水平切分
    11条理由告诉你,为什么你的网站不卖座
    很有用的观察者设计模式
    Apache + Tomcat集群配置详解 (1)
    Nginx+tomcat配置负载均衡
    JSON-RPC轻量级远程调用协议介绍及使用
    nginx的upstream目前支持5种方式的分配
    rpc远程过程协议调用
  • 原文地址:https://www.cnblogs.com/TRMan/p/11270309.html
Copyright © 2011-2022 走看看