【C#】SQL数据库助手类1.0(自用)

简介:
复制代码
using System;
using System.Collections.Generic;
using System.Text;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

namespace Erp.DBUtility
{
    public class YSqlHelper
    {
        //Sql连接语句
        private static string connectionString = ConfigurationManager.AppSettings["ConnectionString"];

        /// <summary>执行不带参数的增删改SQL语句或存储过程 ,返回受影响的行数</summary>
        public static int ExecuteNonQuery(string cmdText, CommandType ct)
        {
            int res = 0;//受影响的行数
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                try
                {
                    conn.Open();//打开数据库链接
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = ct;
                        res = cmd.ExecuteNonQuery();//执行Sql语句并受影响的行数
                    }
                }
                catch
                {

                }
                finally
                {
                    if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态
                    {
                        conn.Close();//关闭与数据库的链接
                    }
                }
            }
            return res;
        }

        /// <summary>  执行带参数的增删改SQL语句或存储过程,返回受影响的行数</summary>
        public static int ExecuteNonQuery(string cmdText, SqlParameter[] paras, CommandType ct)
        {
            int res = 0;//受影响的行数
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                try
                {
                    conn.Open();//打开数据库链接
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = ct;
                        cmd.Parameters.AddRange(paras);
                        res = cmd.ExecuteNonQuery();//执行Sql语句并受影响的行数
                    }
                }
                catch
                {

                }
                finally
                {
                    if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态
                    {
                        conn.Close();//关闭与数据库的链接
                    }
                }
            }
            return res;
        }

        /// <summary> 执行不带参数的查询SQL语句或存储过程,返回DataTable对象</summary>
        public static DataTable ExecuteQueryDataTable(string cmdText, CommandType ct)
        {
            DataTable dt = new DataTable();
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                try
                {
                    conn.Open();//打开数据库链接
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = ct;
                        using (SqlDataReader sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
                        {
                            dt.Load(sdr);
                        }
                    }
                }
                catch
                {

                }
                finally
                {
                    if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态
                    {
                        conn.Close();//关闭与数据库的链接
                    }
                }
            }
            return dt;
        }

        /// <summary> 执行带参数的查询SQL语句或存储过程,返回DataTable对象</summary>
        public static DataTable ExecuteQueryDataTable(string cmdText, SqlParameter[] paras, CommandType ct)
        {
            DataTable dt = new DataTable();
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                try
                {
                    conn.Open();//打开数据库链接
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = ct;
                        cmd.Parameters.AddRange(paras);
                        using (SqlDataReader sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
                        {
                            dt.Load(sdr);
                        }
                    }
                }
                catch
                {

                }
                finally
                {
                    if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态
                    {
                        conn.Close();//关闭与数据库的链接
                    }
                }
            }
            return dt;
        }

        /// <summary> 执行不带参数的查询SQL语句或存储过程,返回DataSet对象</summary>
        public static DataSet ExecuteQueryDataSet(string cmdText, CommandType ct)
        {
            DataSet ds = new DataSet();
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                try
                {
                    conn.Open();//打开数据库链接
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = ct;
                        using (SqlDataAdapter da = new SqlDataAdapter(cmd))
                        {
                            da.Fill(ds, "ds");
                        }
                    }
                }
                catch
                {

                }
                finally
                {
                    if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态
                    {
                        conn.Close();//关闭与数据库的链接
                    }
                }
            }
            return ds;
        }

        /// <summary> 执行带参数的查询SQL语句或存储过程,返回DataSet对象</summary>
        public static DataSet ExecuteQueryDataSet(string cmdText, SqlParameter[] paras, CommandType ct)
        {
            DataSet ds = new DataSet();
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                try
                {
                    conn.Open();//打开数据库链接
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = ct;
                        cmd.Parameters.AddRange(paras);
                        using (SqlDataAdapter da = new SqlDataAdapter(cmd))
                        {
                            da.Fill(ds, "ds");
                        }
                    }
                }
                catch
                {

                }
                finally
                {
                    if (conn.State == ConnectionState.Open)//判断连接是否处于打开状态
                    {
                        conn.Close();//关闭与数据库的链接
                    }
                }
            }
            return ds;
        }

        /// <summary>查询数据是否存在</summary>
        public static bool ExecuteDataIsExistByData(string sqlStr, CommandType commandType)
        {
            bool iss = false;
            DataSet ds = ExecuteQueryDataSet(sqlStr, commandType);
            for (int i = 0; i < ds.Tables.Count; i++)
            {
                if (ds.Tables[i].Rows.Count > 0) iss = true;
            }
            return iss;
        }

        /// <summary>查询数据是否存在 </summary>
        public static bool ExecuteDataIsExistByData(string sqlStr, SqlParameter[] paras, CommandType commandType)
        {
            bool iss = false;
            DataSet ds = ExecuteQueryDataSet(sqlStr, paras, commandType);
            for (int i = 0; i < ds.Tables.Count; i++)
            {
                if (ds.Tables[i].Rows.Count > 0) iss = true;
            }
            return iss;
        }
        /// <summary>查询增删改数据操作是否成功 </summary>
        public static bool ExecuteDataIsExistByInt(string sqlStr, CommandType commandType)
        {
            int ds = ExecuteNonQuery(sqlStr, commandType);
            bool iss = ds > 0 ? true : false;
            return iss;
        }
        /// <summary>查询增删改数据操作是否成功 </summary>
        public static bool ExecuteDataIsExistByInt(string sqlStr, SqlParameter[] paras, CommandType commandType)
        {
            int ds = ExecuteNonQuery(sqlStr, paras, commandType);
            bool iss = ds > 0 ? true : false;
            return iss;
        }
    }
}
复制代码




本文转自叶超Luka博客园博客,原文链接:http://www.cnblogs.com/yc-755909659/p/3642945.html,如需转载请自行联系原作者
目录
相关文章
|
11天前
|
SQL 存储 关系型数据库
【SQL技术】不同数据库引擎 SQL 优化方案剖析
不同数据库系统(MySQL、PostgreSQL、Doris、Hive)的SQL优化策略。存储引擎特点、SQL执行流程及常见操作(如条件查询、排序、聚合函数)的优化方法。针对各数据库,索引使用、分区裁剪、谓词下推等技术,并提供了具体的SQL示例。通用的SQL调优技巧,如避免使用`COUNT(DISTINCT)`、减少小文件问题、慎重使用`SELECT *`等。通过合理选择和应用这些优化策略,可以显著提升数据库查询性能和系统稳定性。
66 9
|
29天前
|
SQL Java 数据库连接
【潜意识Java】MyBatis中的动态SQL灵活、高效的数据库查询以及深度总结
本文详细介绍了MyBatis中的动态SQL功能,涵盖其背景、应用场景及实现方式。
96 6
|
2月前
|
SQL Oracle 数据库
使用访问指导(SQL Access Advisor)优化数据库业务负载
本文介绍了Oracle的SQL访问指导(SQL Access Advisor)的应用场景及其使用方法。访问指导通过分析给定的工作负载,提供索引、物化视图和分区等方面的优化建议,帮助DBA提升数据库性能。具体步骤包括创建访问指导任务、创建工作负载、连接工作负载至访问指导、设置任务参数、运行访问指导、查看和应用优化建议。访问指导不仅针对单条SQL语句,还能综合考虑多条SQL语句的优化效果,为DBA提供全面的决策支持。
95 11
|
2月前
|
SQL 关系型数据库 MySQL
MySQL导入.sql文件后数据库乱码问题
本文分析了导入.sql文件后数据库备注出现乱码的原因,包括字符集不匹配、备注内容编码问题及MySQL版本或配置问题,并提供了详细的解决步骤,如检查和统一字符集设置、修改客户端连接方式、检查MySQL配置等,确保导入过程顺利。
|
2月前
|
SQL 监控 安全
SQL Servers审核提高数据库安全性
SQL Server审核是一种追踪和审查SQL Server上所有活动的机制,旨在检测潜在威胁和漏洞,监控服务器设置的更改。审核日志记录安全问题和数据泄露的详细信息,帮助管理员追踪数据库中的特定活动,确保数据安全和合规性。SQL Server审核分为服务器级和数据库级,涵盖登录、配置变更和数据操作等事件。审核工具如EventLog Analyzer提供实时监控和即时告警,帮助快速响应安全事件。
|
SQL .NET C#
SQL点滴15—在SQL Server 2008中调用C#程序
原文:SQL点滴15—在SQL Server 2008中调用C#程序    T-SQL的在执行普通的查询的时候是很高效的,但是在执行循环,判断这样的语句的时候效率就不那么的高了。这时可以借助CLR了,我们可以在SQL Server 2008中扩展C#程序来完成循环等过程式的查询,或者其他SQL不便实现的功能。
920 0
|
SQL .NET C#
SQL点滴15—在SQL Server 2008中调用C#程序
   T-SQL的在执行普通的查询的时候是很高效的,但是在执行循环,判断这样的语句的时候效率就不那么的高了。这时可以借助CLR了,我们可以在SQL Server 2008中扩展C#程序来完成循环等过程式的查询,或者其他SQL不便实现的功能。
981 0
|
5月前
|
关系型数据库 MySQL 网络安全
5-10Can't connect to MySQL server on 'sh-cynosl-grp-fcs50xoa.sql.tencentcdb.com' (110)")
5-10Can't connect to MySQL server on 'sh-cynosl-grp-fcs50xoa.sql.tencentcdb.com' (110)")
|
7月前
|
SQL 存储 监控
SQL Server的并行实施如何优化?
【7月更文挑战第23天】SQL Server的并行实施如何优化?
184 13
|
7月前
|
SQL
解锁 SQL Server 2022的时间序列数据功能
【7月更文挑战第14天】要解锁SQL Server 2022的时间序列数据功能,可使用`generate_series`函数生成整数序列,例如:`SELECT value FROM generate_series(1, 10)。此外,`date_bucket`函数能按指定间隔(如周)对日期时间值分组,这些工具结合窗口函数和其他时间日期函数,能高效处理和分析时间序列数据。更多信息请参考官方文档和技术资料。
110 9