C#SqlServer操作辅助类(SqlServerHelper.cs)

作者：囌格菈帥厎 | 来源：互联网 | 2023-09-05 10:59

开发小型软件过程中，为了节约开发时间，数据库操作的代码自己都封装了。上篇介绍了SqlCeHelper这个关于操作本地数据库sdf的例子。现在介绍一下在Sqls

开发小型软件过程中，为了节约开发时间，数据库操作的代码自己都封装了。上篇介绍了SqlCeHelper这个关于操作本地数据库sdf的例子。现在介绍一下在Sqlserver中的代码。因为Sqlserver数据库有多种登录方式，所以在构造函数中： #region [构造函数] /// summar

开发小型软件过程中，为了节约开发时间，数据库操作的代码自己都封装了。上篇介绍了SqlCeHelper这个关于操作本地数据库sdf的例子。现在介绍一下在Sqlserver中的代码。

因为Sqlserver数据库有多种登录方式，所以在构造函数中：

#region[构造函数]
///

/// 构造函数，初始化
///
///

正确的数据库连接字符串
///

超时时间
public SqlServerHelper(string ConStr, int TimeOut)
{
ConnectString = ConStr;
connect = new SqlConnection(ConnectString);
CommandTimeOut = TimeOut;
}
///

/// 构造函数，初始化
///
///

正确的数据库连接字符串
public SqlServerHelper(string ConStr)
{
ConnectString = ConStr;
connect = new SqlConnection(ConnectString);
CommandTimeOut = 30;
}
///

/// 构造函数，初始化
///
///

数据库服务器名称或地址
///

访问的数据库
///

用户名
///

密码
///

超时时间
public SqlServerHelper(string DataServer, string DataBase, string UserID, string Pwd,int TimeOut)
{
ConnectString = string.Format("Data Source={0};Initial Catalog={1};User ID={2};pwd={3}", DataServer, DataBase, UserID, Pwd);
connect = new SqlConnection(ConnectString);
CommandTimeOut = TimeOut;
}
///

/// 构造函数，初始化
///
///

数据库服务器名称或地址
///

访问的数据库
///

用户名
///

密码
public SqlServerHelper(string DataServer, string DataBase, string UserID, string Pwd)
{
ConnectString = string.Format("Data Source={0};Initial Catalog={1};User ID={2};pwd={3}", DataServer, DataBase, UserID, Pwd);
connect = new SqlConnection(ConnectString);
CommandTimeOut = 30;
}
///

/// 构造函数，初始化
///
///

访问的数据库
///

是否为本地数据库？若False，则抛出异常
///

超时时间
public SqlServerHelper(string database, bool isLocal,int TimeOut)
{
if (!isLocal)
{throw (new Exception("不在本地而是用了本地数据库访问方式，导致异常，请修改isLocal的值为True。"));
}
connectstring = string.Format("Data Source=127.0.0.1;Initial Catalog={0};Integrated Security=True", database);
connect = new SqlConnection(ConnectString);
CommandTimeOut = TimeOut;
}
///

/// 构造函数，初始化
///
///

访问的数据库
///

这样，可以方便地构造出自己的连接字符串。

同时这里用到几个比较有用的有关数据库服务器及数据库结构的函数。比如查询局域网中所有数据库实例，获取目标实例所有数据库，获取指定数据库的所有表，获取指定表所有行：

C#SqlServer操作辅助类(SqlServerHelper.cs) - 文章图片 View Code

#region 供使用API方式时使用 [DllImport("odbc32.dll")]
private static extern short SQLAllocHandle(short hType, IntPtr inputHandle, out IntPtr outputHandle);
[DllImport("odbc32.dll")]
private static extern short SQLSetEnvAttr(IntPtr henv, int attribute, IntPtr valuePtr, int strLength);
[DllImport("odbc32.dll")]
private static extern short SQLFreeHandle(short hType, IntPtr handle);
[DllImport("odbc32.dll", CharSet = System.Runtime.InteropServices.CharSet.Ansi)]
private static extern short SQLBrowseConnect(IntPtr hconn, System.Text.StringBuilder inString,
short inStringLength, System.Text.StringBuilder outString, short outStringLength,
out short outLengthNeeded);
private const short SQL_HANDLE_ENV = 1;
private const short SQL_HANDLE_DBC = 2;
private const int SQL_ATTR_ODBC_VERSION = 200;
private const int SQL_OV_ODBC3 = 3;
private const short SQL_SUCCESS = 0;
private const short SQL_NEED_DATA = 99;
private const short DEFAULT_RESULT_SIZE = 1024;
private const string SQL_DRIVER_STR = "DRIVER=SQL SERVER";
#endregion
///

/// 获取网内的数据库服务器名称(API方式)
///
/// 服务器名称数组
public static string[] GetServers()
{
string list = string.Empty;
IntPtr henv = IntPtr.Zero;
IntPtr hconn = IntPtr.Zero;
System.Text.StringBuilder inString = new System.Text.StringBuilder(SQL_DRIVER_STR);
System.Text.StringBuilder outString = new System.Text.StringBuilder(DEFAULT_RESULT_SIZE);
short inStringLength = (short)inString.Length;
short lenNeeded = 0;
try {if (SQL_SUCCESS == SQLAllocHandle(SQL_HANDLE_ENV, henv, out henv)){ if (SQL_SUCCESS == SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (IntPtr)SQL_OV_ODBC3, 0)) { if (SQL_SUCCESS == SQLAllocHandle(SQL_HANDLE_DBC, henv, out hconn)) { if (SQL_NEED_DATA == SQLBrowseConnect(hconn, inString, inStringLength, outString, DEFAULT_RESULT_SIZE, out lenNeeded)) { if (DEFAULT_RESULT_SIZE < lenNeeded) { outString.Capacity = lenNeeded; if (SQL_NEED_DATA != SQLBrowseConnect(hconn, inString, inStringLength, outString, lenNeeded, out lenNeeded)) { throw new ApplicationException("Unabled to aquire SQL Servers from ODBC driver."); } } list = outString.ToString(); int start = list.IndexOf("{") + 1; int len = list.IndexOf("}") - start; if ((start > 0) && (len > 0)) { list = list.Substring(start, len); } else { list = string.Empty; } } } }}
}
catch {list = string.Empty;
}
finally {if (hconn != IntPtr.Zero){ SQLFreeHandle(SQL_HANDLE_DBC, hconn);}if (henv != IntPtr.Zero){ SQLFreeHandle(SQL_HANDLE_ENV, hconn);}
}
string[] array = null;
if (list.Length > 0)
{array = list.Split(&＃39;,&＃39;);
}
return array;
}
///

/// 获取网内的数据库服务器名称(qlClientFactory方式)
///
/// 服务器名称数组
public static string[] GetServersBySqlClientFactory()
{
DataTable dataSources = SqlClientFactory.Instance.CreateDataSourceEnumerator().GetDataSources();
DataColumn column2 = dataSources.Columns["ServerName"];
DataColumn column = dataSources.Columns["InstanceName"];
DataRowCollection rows = dataSources.Rows;
string[] array = new string[rows.Count];
for (int i = 0; i )
{string str2 = rows[i][column2] as string;string str = rows[i][column] as string;if (((str == null) || (str.Length == 0)) || ("MSSQLSERVER" == str)){ array[i] = str2;}else{ array[i] = str2 + @"\" + str;}
}
Array.Sort<string>(array);
return array;
}
///

/// 根据不带数据库的连接字符串，遍历查找出所有数据库实例
///
/// 指定服务器的所有数据库
public string[] GetDataBases()
{
List<string> list = new List<string>();
SqlConnection sqlConnection = new SqlConnection(ConnectString);
string[] result;
try {sqlConnection.Open();SqlCommand sqlCommand = new SqlCommand("select name AS 数据库 from master..sysdatabases", sqlConnection);SqlDataReader sqlDataReader = sqlCommand.ExecuteReader();while (sqlDataReader.Read()){ list.Add(sqlDataReader.GetString(0));}sqlDataReader.Close();string[] array = new string[]{ "master", "tempdb", "model", "msdb"};string[] array2 = array;for (int i = 0; i ){ string item = array2[i]; try { list.Remove(item); } catch { }}result = list.ToArray();
}
catch {result = list.ToArray();
}
finally {sqlConnection.Close();
}
return result;
}
///

/// 获取SqlServer指定数据库的所有表
///
/// 表集合,出错则产生异常
public string[] GetTables()
{
string sql = "select object_name (id) from sysobjects where xtype = &＃39;u&＃39; and objectproperty (id,&＃39;IsMSShipped&＃39;) = 0";
DataTable dt = ReturnDataTable(sql);
List<string> Ls = new List<string>();
for (int i = 0; i )
{Ls.Add(dt.Rows[i][0].ToString());
}
return Ls.ToArray();
}
///

/// 获取指定表的所有列
///
///

表名
/// 列集合,出错则产生异常
public string[] GetColumns(string TableName)
{
string sql = string.Format("select name from syscolumns where id=object_id(&＃39;{0}&＃39;)",TableName);
try {List<string> Ls = new List<string>();DataTable dt = ReturnDataTable(sql);for (int i = 0; i ){ Ls.Add(dt.Rows[i][0].ToString());}return Ls.ToArray();
}
catch {throw;
}
}

接下来就是许多比较常用的增删改查的操作了。就不分开写了。

为了查看方便，贴出自己所有代码：

C#SqlServer操作辅助类(SqlServerHelper.cs) - 文章图片 View Code

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Data;
using System.Collections;
using System.Runtime.InteropServices;
namespace MyTool.DataBase
{
///

/// SQL Server 数据库的操作类库。代码原创。
///
public class SqlServerHelper
{
#region[字段]
private string cOnnectstring= "Data Source=127.0.0.1;Initial Catalog=AdventureWorksDW;Integrated Security=True";
SqlConnection connect = null;
SqlCommand command = null;
private int CommandTimeOut = 30;
#endregion
#region[属性]
///

/// 数据库连接字符串
///
public string ConnectString
{
get { return connectstring; }
set { cOnnectstring= value; }
}
#endregion
#region[构造函数]
///

/// 构造函数，初始化
///
///

正确的数据库连接字符串
///

超时时间
public SqlServerHelper(string ConStr, int TimeOut)
{
ConnectString = ConStr;
connect = new SqlConnection(ConnectString);
CommandTimeOut = TimeOut;
}
///

/// 构造函数，初始化
///
///

正确的数据库连接字符串
public SqlServerHelper(string ConStr)
{
ConnectString = ConStr;
connect = new SqlConnection(ConnectString);
CommandTimeOut = 30;
}
///

/// 构造函数，初始化
///
///

数据库服务器名称或地址
///

访问的数据库
///

用户名
///

密码
///

/// 构造函数，初始化
///
///

数据库服务器名称或地址
///

访问的数据库
///

用户名
///

/// 构造函数，初始化
///
///

访问的数据库
///

是否为本地数据库？若False，则抛出异常
///

/// 构造函数，初始化
///
///

访问的数据库
///

是否为本地数据库？若False，则抛出异常
public SqlServerHelper(string database, bool isLocal)
{
if (!isLocal)
{throw (new Exception("不在本地而是用了本地数据库访问方式，导致异常，请修改isLocal的值为True。"));
}
connectstring = string.Format("Data Source=127.0.0.1;Initial Catalog={0};Integrated Security=True", database);
connect = new SqlConnection(ConnectString);
CommandTimeOut = 30;
}
#endregion
#region[私有函数]
private void Open()
{
try {if (connect.State != System.Data.ConnectionState.Open){ connect.Open();}
}
catch (Exception ex)
{throw (new Exception(ex.Message));
}
}
private void Close()
{
try {if (connect.State != System.Data.ConnectionState.Closed){ connect.Close();}
}
catch (Exception ex)
{throw (new Exception(ex.Message));
}
}
#endregion
///

/// 测试是否能够连通
///
/// 布尔值
public bool ConnectTest()
{
try {connect.Open();
}
catch {connect.Close();return false;
}
return true;
}
///

/// 执行无返回的Sql语句，如插入，删除，更新
///
///

SQL语句
/// 受影响的条数
public int ExecuteNonQuery(string sqlstr)
{
try {Open();command = new SqlCommand(sqlstr, connect);int num = command.ExecuteNonQuery();command.Parameters.Clear();Close();return num;
}
catch {throw;
}
}
///

/// 执行查询语句，返回DataSet
///
///

Sql
/// DataSet数据集
public DataSet ReturnDataSet(string sqlstr)
{
DataSet ds = new DataSet();
try {Open();SqlDataAdapter adapter = new SqlDataAdapter(sqlstr, connect);adapter.Fill(ds, "Obj");
}
catch (Exception)
{throw;
}
return ds;
}
///

/// 执行查询语句，返回DataTable
///
///

Sqk
/// DataTable数据表
public DataTable ReturnDataTable(string sqlstr)
{
return ReturnDataSet(sqlstr).Tables[0];
}
///

/// 执行查询语句，返回DataReader
///
///

Sql
/// DataReader
public SqlDataReader ReturnDataReader(string sqlstr)
{
try {Open();command = new SqlCommand(sqlstr, connect);SqlDataReader myReader = command.ExecuteReader();command.Parameters.Clear();Close();return myReader;
}
catch (System.Data.SqlClient.SqlException e)
{throw new Exception(e.Message);
}
}
///

/// 执行事务
///
///

public void ExecuteSqlTran(ArrayList SQLStringList)
{
Open();
command = new SqlCommand();
command.Connection = connect;
SqlTransaction tx = connect.BeginTransaction();
command.Transaction = tx;
try {for (int n = 0; n ){ string strsql = SQLStringList[n].ToString(); if (strsql.Trim().Length > 1) { command.CommandText = strsql; command.ExecuteNonQuery(); }}tx.Commit();
}
catch (Exception)
{tx.Rollback();throw;
}
}
#region 供使用API方式时使用 [DllImport("odbc32.dll")]
private static extern short SQLAllocHandle(short hType, IntPtr inputHandle, out IntPtr outputHandle);
[DllImport("odbc32.dll")]
private static extern short SQLSetEnvAttr(IntPtr henv, int attribute, IntPtr valuePtr, int strLength);
[DllImport("odbc32.dll")]
private static extern short SQLFreeHandle(short hType, IntPtr handle);
[DllImport("odbc32.dll", CharSet = System.Runtime.InteropServices.CharSet.Ansi)]
private static extern short SQLBrowseConnect(IntPtr hconn, System.Text.StringBuilder inString,
short inStringLength, System.Text.StringBuilder outString, short outStringLength,
out short outLengthNeeded);
private const short SQL_HANDLE_ENV = 1;
private const short SQL_HANDLE_DBC = 2;
private const int SQL_ATTR_ODBC_VERSION = 200;
private const int SQL_OV_ODBC3 = 3;
private const short SQL_SUCCESS = 0;
private const short SQL_NEED_DATA = 99;
private const short DEFAULT_RESULT_SIZE = 1024;
private const string SQL_DRIVER_STR = "DRIVER=SQL SERVER";
#endregion
///

/// 获取指定表的所有列
///
///

推荐阅读

header
【MySQL】frm文件解析

官网说明：http:dev.mysql.comdocinternalsenfrm-file-format.htmlfrm是MySQL表结构定义文件，通常frm文件是不会损坏的，但是如果 ... [详细]

蜡笔小新 2024-11-23 10:29:06
header
Windows环境下Oracle数据库迁移实践

本文详细记录了一次在Windows操作系统下将Oracle数据库的控制文件、数据文件及在线日志文件迁移至外部存储的过程，旨在为后续的集群环境部署做好准备。 ... [详细]

蜡笔小新 2024-11-23 19:57:51
md5
MVC模式下的电子取证技术初探

本文探讨了在MVC（模型-视图-控制器）架构下进行电子取证的技术方法，通过实际案例分析，提供了详细的取证步骤和技术要点。 ... [详细]

蜡笔小新 2024-11-23 12:13:06
java
Java程序设计复习题

1、编写一个Java程序在屏幕上输出“你好！”。programmenameHelloworld.javapublicclassHelloworld{publicst ... [详细]

蜡笔小新 2024-11-22 20:05:03
client
binlog2sql，你该知道的数据恢复工具

binlog2sql，你该知道的数据恢复工具 ... [详细]

蜡笔小新 2024-11-22 18:58:43
list
MySQL 常见错误解析与解决

本文详细解析了MySQL中常见的几种错误，并提供了具体的解决方法，帮助开发者快速定位和解决问题。 ... [详细]

蜡笔小新 2024-11-22 14:15:56
join
PHP与MySQL实现高效分页查询

本文探讨了如何在PHP与MySQL环境中实现高效的分页查询，包括基本的分页实现、性能优化技巧以及高级的分页策略。 ... [详细]

蜡笔小新 2024-11-22 05:45:48
python
利用Scrapy构建的数据采集与分析可视化系统

本文探讨了如何使用Scrapy框架构建高效的数据采集系统，以及如何通过异步处理技术提升数据存储的效率。同时，文章还介绍了针对不同网站采用的不同采集策略。 ... [详细]

蜡笔小新 2024-11-23 16:56:38
python
PHP中Smarty模板引擎自定义函数详解

本文详细介绍了如何在PHP的Smarty模板引擎中自定义函数，并通过具体示例演示了这些函数的使用方法和应用场景。适合PHP后端开发者学习。 ... [详细]

蜡笔小新 2024-11-23 15:39:25
python
MySQL InnoDB事务日志详解：Redo Log与Undo Log

本文详细介绍了MySQL InnoDB存储引擎中的Redo Log和Undo Log，探讨了它们的工作原理、存储方式及其在事务处理中的关键作用。 ... [详细]

蜡笔小新 2024-11-23 15:34:23
python
SSE图像算法优化系列三：超高速导向滤波实现过程纪要（欢迎挑战）

自从何凯明提出导向滤波后，因为其算法的简单性和有效性，该算法得到了广泛的应用，以至于新版的matlab都将其作为标准自带的函数之一了&#x ... [详细]

蜡笔小新 2024-11-23 10:46:33
select
数据输入验证与控件绑定方法

本文提供了多种数据输入验证函数及控件绑定方法的实现代码，包括电话号码、数字、传真、邮政编码、电子邮件和网址的验证，以及报表绑定和自动编号等功能。 ... [详细]

蜡笔小新 2024-11-23 07:47:36
select
MySQL窗口函数详解与应用

本文介绍了MySQL窗口函数的基本概念、应用场景及常见函数的使用方法。窗口函数在处理复杂查询时非常有用，例如计算每个用户的订单排名、环比增长率、以及动态聚合等。 ... [详细]

蜡笔小新 2024-11-23 02:53:38
java
Hibernate框架简述

Hibernate全自动全映射ORM框架，旨在消除sql，是一个持久层的ORM框架1）、基础概念DAO(DataAccessorOb ... [详细]

蜡笔小新 2024-11-22 16:36:49
java
CentOS 6.5环境下Redis 3.0.6的安装与配置

本文详细介绍了如何在CentOS 6.5系统上安装和配置Redis 3.0.6，包括必要的环境准备、软件包下载、编译安装及基本功能测试。 ... [详细]

蜡笔小新 2024-11-22 11:42:46

囌格菈帥厎

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章