通用权限管理系统组件 (GPM - General Permissions Manager) 中灵活经典的.NET2.0数据库访问组件,附源码

简介:

  情人节的晚上思绪万千,想到了曾经的N次恋爱,想到现在生活,想到曾经的奋斗,想到曾经在身边的女人,人生不易终于失眠了,上一篇我们介绍了 通用权限管理系统组件 (GPM - General Permissions Manager) 中超级经典的.NET2.0静态数据库访问组件 两者的区别就是一个是 static 的方法,另外一个是通过接口的方式实现的,接着我们介绍更加灵活的,动态数据库5种实用方法,与上一篇的数据库访问组件结合实用会更加强大一些,真正功能强大的是没任何封装的ADO.NET,其实自己封装的往往都是有些娱乐精神的人干出来的事情。

  当然这些数据库访问组件都是可以单独使用的,可以与通用权限管理系统组件无任何关联。通用权限的很多实现理念就是无关性,通用权限与数据库访问组件是无关的,数据库库访问组件就可以单独用,甚至没任何无用的代码,配置在里面。

  我们直接看代码如下:

// -----------------------------------------------------------------
//  All Rights Reserved , Copyright (C) 2012 , Hairihan TECH, Ltd. 
// -----------------------------------------------------------------

using System;
using System.Data;
using System.Collections.Generic;

using DotNet.Utilities;
using DotNet.Business;

/// <summary>
///  DbTools2
///  静态数据库访问的方法程序
///
///  修改纪录
///
///         2012-02-15 版本:1.0 JiRiGaLa 整理例子程序功能。
///
///  版本:1.0
///
/// <author>
/// <name> JiRiGaLa </name>
/// <date> 2012-02-15 </date>
/// </author>
/// </summary>
public partial class DbTools2 : BasePage
{
protected void Page_Load( object sender, EventArgs e)
   {
//  动态方法调用数据库的方法
this.DynamicMethod();

//  动态打开数据库的方法
string dbConnection =  " Data Source=localhost;Initial Catalog=UserCenterV36;User Id = sa ; Password = Password@1234; ";
//  using (IDbHelper dbHelper = DbHelperFactory.GetHelper(CurrentDbType.Oracle))
//  using (IDbHelper dbHelper = DbHelperFactory.GetHelper(CurrentDbType.MySql))
//  using (IDbHelper dbHelper = DbHelperFactory.GetHelper(CurrentDbType.DB2))
//  using (IDbHelper dbHelper = DbHelperFactory.GetHelper(CurrentDbType.Access))
//  using (IDbHelper dbHelper = DbHelperFactory.GetHelper(CurrentDbType.SQLite))
using (IDbHelper dbHelper = DbHelperFactory.GetHelper(CurrentDbType.SqlServer))
       {
           dbHelper.Open(dbConnection);
       }
   }

private void DynamicMethod()
   {
this.Fill();
this.ExecuteNonQuery();
this.ExecuteScalar();
this.ExecuteReader();
   }


/// <summary>
///  Fill
///  动态方法调用数据库的方法,能有效控制数据库的开关次数
/// </summary>
private void Fill()
   {
string dbConnection =  " Data Source=localhost;Initial Catalog=UserCenterV36;User Id = sa ; Password = Password@1234; ";
//  DotNet.Utilities.IDbHelper dbHelper = new DotNet.Utilities.DB2Helper(dbConnection);
//  DotNet.Utilities.IDbHelper dbHelper = new DotNet.Utilities.MySqlHelper(dbConnection);
//  DotNet.Utilities.IDbHelper dbHelper = new DotNet.Utilities.OleDbHelper(dbConnection);
//  DotNet.Utilities.IDbHelper dbHelper = new DotNet.Utilities.OracleHelper(dbConnection);
//  DotNet.Utilities.IDbHelper dbHelper = new DotNet.Utilities.SqLiteHelper(dbConnection);
       DotNet.Utilities.IDbHelper dbHelper =  new DotNet.Utilities.SqlHelper(dbConnection);
       dbHelper.Open();

//  1:直接执行
string commandText =  @" SELECT * 
                                FROM BASE_USER 
                               WHERE DELETIONSTATECODE = 0
";
       DataTable dataTable = dbHelper.Fill(commandText);

//  2:防注入的安全的参数化运行方式执行查询
       commandText =  @"  SELECT * 
                         FROM BASE_USER 
                        WHERE CODE = 
" + dbHelper.GetParameter( " Code ")
                              +  "  AND DELETIONSTATECODE =  " + dbHelper.GetParameter( " DeletionStateCode ");
//  这里是生成安全参数的方法
       List<IDbDataParameter> dbParameters =  new List<IDbDataParameter>();
       dbParameters.Add(dbHelper.MakeParameter( " Code "" jirigala "));
       dbParameters.Add(dbHelper.MakeParameter( " DeletionStateCode "0));
       dataTable = dbHelper.Fill(commandText, dbParameters.ToArray());

//  3:执行存储过程,假设也是需要传递这2个参数,类似功能的一个存储过程
//     我们不建议用存储过程,因为会对系统移植,多数据库设计等上会遇到很多麻烦
       commandText =  " GET_USER ";
       dataTable = dbHelper.Fill(commandText, dbParameters.ToArray(), CommandType.StoredProcedure);
       dbHelper.Close();
   }


/// <summary>
///  ExecuteNonQuery
///  静态方法调用数据库的方法,调用事物的方式
/// </summary>
/// <returns> 影响行数 </returns>
private int ExecuteNonQuery()
   {
int returnValue =  0;

string dbConnection =  " Data Source=localhost;Initial Catalog=UserCenterV36;User Id = sa ; Password = Password@1234; ";
       DotNet.Utilities.IDbHelper dbHelper =  new DotNet.Utilities.SqlHelper(dbConnection);
try
       {
           dbHelper.Open();
           dbHelper.BeginTransaction();

//  1:直接执行
string commandText =  @" UPDATE BASE_USER
                               SET DELETIONSTATECODE = 0
";
           returnValue = dbHelper.ExecuteNonQuery(commandText);

//  2:防注入的安全的参数化运行方式执行查询
           commandText =  @"  UPDATE BASE_USER 
                       SET DELETIONSTATECODE = 0
                       WHERE CODE = 
" + DotNet.Utilities.DbHelper.GetParameter( " Code ")
                                   +  "  AND DELETIONSTATECODE =  " + DotNet.Utilities.DbHelper.GetParameter( " DeletionStateCode ");
//  这里是生成安全参数的方法
           List<IDbDataParameter> dbParameters =  new List<IDbDataParameter>();
           dbParameters.Add(dbHelper.MakeParameter( " Code "" jirigala "));
           dbParameters.Add(dbHelper.MakeParameter( " DeletionStateCode "0));
           returnValue = dbHelper.ExecuteNonQuery(commandText, dbParameters.ToArray());

//  3:执行存储过程,假设也是需要传递这2个参数,类似功能的一个存储过程
//     我们不建议用存储过程,因为会对系统移植,多数据库设计等上会遇到很多麻烦
           commandText =  " UPDATE_USER ";
           returnValue = dbHelper.ExecuteNonQuery(commandText, dbParameters.ToArray(), CommandType.StoredProcedure);

           dbHelper.CommitTransaction();
       }
catch (Exception ex)
       {
           dbHelper.RollbackTransaction();
           BaseExceptionManager.LogException(dbHelper,  this.UserInfo, ex);
throw ex;
       }
finally
       {
           dbHelper.Close();
       }
return returnValue;
   }


/// <summary>
///  ExecuteScalar
///  动态方法调用数据库的方法, 支持Using的用法
/// </summary>
/// <returns> 结果 </returns>
private object ExecuteScalar()
   {
object returnValue =  null;

string dbConnection =  " Data Source=localhost;Initial Catalog=UserCenterV36;User Id = sa ; Password = Password@1234; ";
using (DotNet.Utilities.IDbHelper dbHelper =  new DotNet.Utilities.SqlHelper(dbConnection))
       {
//  1:直接执行
string commandText =  @" SELECT CODE 
                                FROM BASE_USER 
                               WHERE DELETIONSTATECODE = 0
";
           returnValue = dbHelper.ExecuteScalar(commandText);

//  2:防注入的安全的参数化运行方式执行查询
           commandText =  @"  SELECT CODE 
                          FROM BASE_USER 
                         WHERE  CODE = 
" + dbHelper.GetParameter( " Code ")
                                  +  "  AND DELETIONSTATECODE =  " + dbHelper.GetParameter( " DeletionStateCode ");
//  这里是生成安全参数的方法
           List<IDbDataParameter> dbParameters =  new List<IDbDataParameter>();
           dbParameters.Add(dbHelper.MakeParameter( " Code "" jirigala "));
           dbParameters.Add(dbHelper.MakeParameter( " DeletionStateCode "0));
           returnValue = dbHelper.ExecuteScalar(commandText, dbParameters.ToArray());

//  3:执行存储过程,假设也是需要传递这2个参数,类似功能的一个存储过程
//     我们不建议用存储过程,因为会对系统移植,多数据库设计等上会遇到很多麻烦
           commandText =  " GET_USER ";
           returnValue = dbHelper.ExecuteScalar(commandText, dbParameters.ToArray(), CommandType.StoredProcedure);
       }

return returnValue;
   }


/// <summary>
///  ExecuteReader
///  动态方法调用数据库的方法,每次执行程序会自动打开关闭数据库的例子,自动会多次打开关闭
/// </summary>
private void ExecuteReader()
   {
string dbConnection =  " Data Source=localhost;Initial Catalog=UserCenterV36;User Id = sa ; Password = Password@1234; ";
       DotNet.Utilities.IDbHelper dbHelper =  new DotNet.Utilities.SqlHelper(dbConnection);

//  1:直接执行
string commandText =  @" SELECT * 
                                FROM BASE_USER
                               WHERE DELETIONSTATECODE = 0
";
       dbHelper.ExecuteReader(commandText);

//  2:防注入的安全的参数化运行方式执行查询
       commandText =  @"  SELECT * 
                          FROM BASE_USER
                         WHERE CODE = 
" + dbHelper.GetParameter( " Code ")
                              +  "  AND DELETIONSTATECODE =  " + dbHelper.GetParameter( " DeletionStateCode ");
//  这里是生成安全参数的方法
       List<IDbDataParameter> dbParameters =  new List<IDbDataParameter>();
       dbParameters.Add(dbHelper.MakeParameter( " Code "" jirigala "));
       dbParameters.Add(dbHelper.MakeParameter( " DeletionStateCode "0));
       dbHelper.ExecuteReader(commandText, dbParameters.ToArray());

//  3:执行存储过程,假设也是需要传递这2个参数,类似功能的一个存储过程
//     我们不建议用存储过程,因为会对系统移植,多数据库设计等上会遇到很多麻烦
       commandText =  " GET_USER ";
       dbHelper.ExecuteReader(commandText, dbParameters.ToArray(), CommandType.StoredProcedure);
   }
}


  例子程序下载地址如下:

/Files/jirigala/CRM.rar

  .NET 2.0 数据库访问层源码在这里下载:

/Files/jirigala/DotNet.Utilities.rar





本文转自 jirigala 51CTO博客,原文链接:http://blog.51cto.com/2347979/1196327,如需转载请自行联系原作者
相关文章
|
5月前
|
消息中间件 缓存 监控
优化微服务架构中的数据库访问:策略与最佳实践
在微服务架构中,数据库访问的效率直接影响到系统的性能和可扩展性。本文探讨了优化微服务架构中数据库访问的策略与最佳实践,包括数据分片、缓存策略、异步处理和服务间通信优化。通过具体的技术方案和实例分析,提供了一系列实用的建议,以帮助开发团队提升微服务系统的响应速度和稳定性。
|
2月前
|
SQL Oracle 数据库
使用访问指导(SQL Access Advisor)优化数据库业务负载
本文介绍了Oracle的SQL访问指导(SQL Access Advisor)的应用场景及其使用方法。访问指导通过分析给定的工作负载,提供索引、物化视图和分区等方面的优化建议,帮助DBA提升数据库性能。具体步骤包括创建访问指导任务、创建工作负载、连接工作负载至访问指导、设置任务参数、运行访问指导、查看和应用优化建议。访问指导不仅针对单条SQL语句,还能综合考虑多条SQL语句的优化效果,为DBA提供全面的决策支持。
95 11
|
3月前
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
85 3
|
3月前
|
SQL Java 数据库连接
打破瓶颈:利用Java连接池技术提升数据库访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,避免了频繁的连接建立和断开,显著提升了数据库访问效率。常见的连接池库包括HikariCP、C3P0和DBCP,它们提供了丰富的配置选项和强大的功能,帮助优化应用性能。
121 2
|
4月前
.NET 4.0下实现.NET4.5的Task类相似功能组件
【10月更文挑战第29天】在.NET 4.0 环境下,可以使用 `BackgroundWorker` 类来实现类似于 .NET 4.5 中 `Task` 类的功能。`BackgroundWorker` 允许在后台执行耗时操作,同时不会阻塞用户界面线程,并支持进度报告和取消操作。尽管它有一些局限性,如复杂的事件处理模型和不灵活的任务管理方式,但在某些情况下仍能有效替代 `Task` 类。
|
5月前
|
消息中间件 缓存 监控
优化微服务架构中的数据库访问:策略与实践
随着微服务架构的普及,如何高效管理和优化数据库访问成为了关键挑战。本文探讨了在微服务环境中优化数据库访问的策略,包括数据库分片、缓存机制、异步处理等技术手段。通过深入分析实际案例和最佳实践,本文旨在为开发者提供实际可行的解决方案,以提升系统性能和可扩展性。
|
5月前
|
SQL NoSQL Java
彻底革新你的数据库操作体验!Micronaut数据访问技巧让你瞬间爱上代码编写!
【9月更文挑战第10天】Java开发者们一直在寻找简化应用程序与数据库交互的方法。Micronaut作为一个现代框架,提供了多种工具和特性来提升数据访问效率。本文介绍如何使用Micronaut简化数据库操作,并提供具体示例代码。Micronaut支持JPA/Hibernate、SQL及NoSQL(如MongoDB),简化配置并无缝集成。通过定义带有`@Repository`注解的接口,可以实现Spring Data风格的命名查询。
106 6
|
5月前
|
SQL 存储 关系型数据库
C#一分钟浅谈:使用 ADO.NET 进行数据库访问
【9月更文挑战第3天】在.NET开发中,与数据库交互至关重要。ADO.NET是Microsoft提供的用于访问关系型数据库的类库,包含连接数据库、执行SQL命令等功能。本文从基础入手,介绍如何使用ADO.NET进行数据库访问,并提供示例代码,同时讨论常见问题及其解决方案,如连接字符串错误、SQL注入风险和资源泄露等,帮助开发者更好地利用ADO.NET提升应用的安全性和稳定性。
454 6
|
5月前
|
SQL 关系型数据库 分布式数据库
PolarDB Proxy配置与优化:提升数据库访问效率
【9月更文挑战第6天】PolarDB是阿里云推出的高性能分布式关系型数据库,PolarDB Proxy作为其关键组件,位于客户端与PolarDB集群间,负责SQL请求的解析与转发,并支持连接池管理、SQL过滤及路由规则等功能。本文详细介绍了PolarDB Proxy的配置方法,包括连接池、负载均衡和SQL过滤设置,并探讨了监控调优、缓存及网络优化策略,以帮助提升数据库访问效率。
99 1
|
6月前
|
开发者 UED Java
Play Framework惊天秘密:如何让异常处理优雅得像芭蕾舞?
【8月更文挑战第31天】在Web应用开发中,异常处理至关重要,直接影响应用稳定性和用户体验。Play Framework作为轻量级Java Web框架,提供了基于Scala偏函数的灵活异常处理机制。通过实现`HttpErrorHandler`接口可定义全局异常逻辑,而在控制器中使用try-catch块则能捕获特定异常。定义自定义异常类也有助于表示特定错误情况。最佳实践包括保持处理一致性、提供有用错误信息、记录日志及分类处理异常。掌握这些技巧,能使Play应用更健壮可靠。
80 1

热门文章

最新文章