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

//-----------------------------------------------------------------
// 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>
publicpartialclass DbTools2 : BasePage
{
protectedvoid 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);
       }
   }

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


///<summary>
/// Fill
/// 动态方法调用数据库的方法，能有效控制数据库的开关次数
///</summary>
privatevoid 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>
privateint 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>
privateobject 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>
privatevoid 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);
   }
}