当前位置：网站首页>C＃.NET万能数据库访问封装类(ACCESS、SQLServer、Oracle)
C＃.NET万能数据库访问封装类(ACCESS、SQLServer、Oracle)
2022-06-23 00:41:00 【51CTO】
using System;
using System.Collections;
using System.Collections.Specialized;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Data.OracleClient;
using System.Configuration;
using System.Reflection;
using BloodWeb.Common;
namespace BloodWeb.DAL
{
/**////
<
summary
>
/// All rights reserved
/// 数据访问基础类
/// 用户可以修改满足自己项目的需要。
///
</
summary
>
public class DataBaseLayer
{
//数据库连接字符串(web.config来配置)
//
<
add
key=
"ConnectionString"
value=
"server=127.0.0.1;database=DATABASE;uid=sa;pwd="
/>
private string connectionString;
public string ConntionString
{
get
{
return connectionString ;
}
set
{
connectionString = value;
}
}
public DataBaseLayer(string strConnect,string dataType)
{
this.ConntionString = strConnect;
this.DbType = dataType;
}
public DataBaseLayer()
{
this.connectionString =ConfigurationBase.ConnectionString;// ConfigurationSettings.AppSettings["ConnectionString"] ;
this.dbType =ConfigurationBase.DataType;// ConfigurationSettings.AppSettings["DataType"] ;
//this.connectionString = "data source=192.168.1.43;user id=sa;pwd=sa;database=temphrdb";
//this.dbType = "SqlServer";
}
/**////
<
summary
>
/// 数据库类型
///
</
summary
>
private string dbType;
public string DbType
{
get
{
if ( dbType == string.Empty || dbType == null )
{
return "Access";
}
else
{
return dbType;
}
}
set
{
if ( value != string.Empty
&
& value != null )
{
dbType = value;
}
if (dbType ==string.Empty || dbType == null)
{
dbType = ConfigurationBase.DataType; //ConfigurationSettings.AppSettings["DataType"];
}
if ( dbType == string.Empty || dbType == null )
{
dbType = "Access";
}
}
}
#region 转换参数
private System.Data.IDbDataParameter iDbPara(string ParaName,string DataType)
{
switch(this.DbType)
{
case "SqlServer":
return GetSqlPara(ParaName,DataType);
case "Oracle":
return GetOleDbPara(ParaName,DataType);
case "Access":
return GetOleDbPara(ParaName,DataType);
default :
return GetSqlPara(ParaName,DataType);
}
}
private System.Data.SqlClient.SqlParameter GetSqlPara( string ParaName , string DataType)
{
switch(DataType)
{
case "Decimal":
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.Decimal );
case "Varchar":
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.VarChar );
case "DateTime":
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.DateTime );
case "Iamge":
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.Image );
case "Int":
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.Int );
case "Text":
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.NText );
default :
return new System.Data.SqlClient.SqlParameter ( ParaName, System.Data.SqlDbType.VarChar );
}
}
private System.Data.OracleClient.OracleParameter GetOraclePara( string ParaName , string DataType)
{
switch(DataType)
{
case "Decimal":
return new System.Data.OracleClient.OracleParameter( ParaName, System.Data.OracleClient.OracleType.Double);
case "Varchar":
return new System.Data.OracleClient.OracleParameter ( ParaName, System.Data.OracleClient.OracleType.VarChar );
case "DateTime":
return new System.Data.OracleClient.OracleParameter ( ParaName, System.Data.OracleClient.OracleType.DateTime );
case "Iamge":
return new System.Data.OracleClient.OracleParameter ( ParaName, System.Data.OracleClient.OracleType.BFile );
case "Int":
return new System.Data.OracleClient.OracleParameter ( ParaName, System.Data.OracleClient.OracleType.Int32 );
case "Text":
return new System.Data.OracleClient.OracleParameter ( ParaName, System.Data.OracleClient.OracleType.LongVarChar );
default:
return new System.Data.OracleClient.OracleParameter ( ParaName, System.Data.OracleClient.OracleType.VarChar );
}
}
private System.Data.OleDb.OleDbParameter GetOleDbPara( string ParaName , string DataType)
{
switch(DataType)
{
case "Decimal":
return new System.Data.OleDb.OleDbParameter( ParaName, System.Data.DbType.Decimal);
case "Varchar":
return new System.Data.OleDb.OleDbParameter ( ParaName, System.Data.DbType.String );
case "DateTime":
return new System.Data.OleDb.OleDbParameter ( ParaName, System.Data.DbType.DateTime );
case "Iamge":
return new System.Data.OleDb.OleDbParameter( ParaName, System.Data.DbType.Binary );
case "Int":
return new System.Data.OleDb.OleDbParameter ( ParaName, System.Data.DbType.Int32 );
case "Text":
return new System.Data.OleDb.OleDbParameter ( ParaName, System.Data.DbType.String );
default:
return new System.Data.OleDb.OleDbParameter ( ParaName, System.Data.DbType.String );
}
}
#endregion
#region 创建 Connection 和 Command
private IDbConnection GetConnection()
{
switch(this.DbType)
{
case "SqlServer":
return new System.Data.SqlClient.SqlConnection(this.ConntionString);
case "Oracle":
return new System.Data.OracleClient.OracleConnection(this.ConntionString);
case "Access":
return new System.Data.OleDb.OleDbConnection(this.ConntionString);
default:
return new System.Data.SqlClient.SqlConnection(this.ConntionString);
}
}
private IDbCommand GetCommand(string Sql,IDbConnection iConn)
{
switch(this.DbType)
{
case "SqlServer":
return new System.Data.SqlClient.SqlCommand(Sql,(SqlConnection)iConn);
case "Oracle":
return new System.Data.OracleClient.OracleCommand(Sql,(OracleConnection)iConn);
case "Access":
return new System.Data.OleDb.OleDbCommand(Sql,(OleDbConnection)iConn);
default:
return new System.Data.SqlClient.SqlCommand(Sql,(SqlConnection)iConn);
}
}
private IDbCommand GetCommand()
{
switch(this.DbType)
{
case "SqlServer":
return new System.Data.SqlClient.SqlCommand();
case "Oracle":
return new System.Data.OracleClient.OracleCommand();
case "Access":
return new System.Data.OleDb.OleDbCommand();
default:
return new System.Data.SqlClient.SqlCommand();
}
}
private IDataAdapter GetAdapater(string Sql,IDbConnection iConn)
{
switch(this.DbType)
{
case "SqlServer":
return new System.Data.SqlClient.SqlDataAdapter(Sql,(SqlConnection)iConn);
case "Oracle":
return new System.Data.OracleClient.OracleDataAdapter(Sql,(OracleConnection)iConn);
case "Access":
return new System.Data.OleDb.OleDbDataAdapter(Sql,(OleDbConnection)iConn);
default:
return new System.Data.SqlClient.SqlDataAdapter(Sql,(SqlConnection)iConn);;
}
}
private IDataAdapter GetAdapater()
{
switch(this.DbType)
{
case "SqlServer":
return new System.Data.SqlClient.SqlDataAdapter();
case "Oracle":
return new System.Data.OracleClient.OracleDataAdapter();
case "Access":
return new System.Data.OleDb.OleDbDataAdapter();
default:
return new System.Data.SqlClient.SqlDataAdapter();
}
}
private IDataAdapter GetAdapater(IDbCommand iCmd)
{
switch(this.DbType)
{
case "SqlServer":
return new System.Data.SqlClient.SqlDataAdapter((SqlCommand)iCmd);
case "Oracle":
return new System.Data.OracleClient.OracleDataAdapter((OracleCommand)iCmd);
case "Access":
return new System.Data.OleDb.OleDbDataAdapter((OleDbCommand)iCmd);
default:
return new System.Data.SqlClient.SqlDataAdapter((SqlCommand)iCmd);
}
}
#endregion
#region 执行简单SQL语句
/**////
<
summary
>
/// 执行SQL语句，返回影响的记录数
///
</
summary
>
///
<
param
name=
"SQLString"
>SQL语句
</
param
>
///
<
returns
>影响的记录数
</
returns
>
public int ExecuteSql(string SqlString)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using (System.Data.IDbCommand iCmd = GetCommand(SqlString,iConn))
{
iConn.Open();
try
{
int rows=iCmd.ExecuteNonQuery();
return rows;
}
catch(System.Exception E)
{
throw new Exception(E.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行多条SQL语句，实现数据库事务。
///
</
summary
>
///
<
param
name=
"SQLStringList"
>多条SQL语句
</
param
>
public void ExecuteSqlTran(ArrayList SQLStringList)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
using(System.Data.IDbCommand iCmd = GetCommand())
{
iCmd.Connection=iConn;
using(System.Data.IDbTransaction iDbTran = iConn.BeginTransaction())
{
iCmd.Transaction=iDbTran;
try
{
for(int n=0;n
<
SQLStringList.Count;n++)
{
string
strsql =
SQLStringList[n].ToString();
if
(
strsql.Trim().Length
>1)
{
iCmd.CommandText = strsql;
iCmd.ExecuteNonQuery();
}
}
iDbTran.Commit();
}
catch(System.Exception E)
{
iDbTran.Rollback();
throw new Exception(E.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
}
/**////
<
summary
>
/// 执行带一个存储过程参数的的SQL语句。
///
</
summary
>
///
<
param
name=
"SQLString"
>SQL语句
</
param
>
///
<
param
name=
"content"
>参数内容,比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加
</
param
>
///
<
returns
>影响的记录数
</
returns
>
public int ExecuteSql(string SqlString,string content)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using(System.Data.IDbCommand iCmd = GetCommand(SqlString,iConn))
{
System.Data.IDataParameter myParameter = this.iDbPara( "@content", "Text");
myParameter.Value = content ;
iCmd.Parameters.Add(myParameter);
iConn.Open();
try
{
int rows = iCmd.ExecuteNonQuery();
return rows;
}
catch( System.Exception e )
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 向数据库里插入图像格式的字段(和上面情况类似的另一种实例)
///
</
summary
>
///
<
param
name=
"strSQL"
>SQL语句
</
param
>
///
<
param
name=
"fs"
>图像字节,数据库的字段类型为image的情况
</
param
>
///
<
returns
>影响的记录数
</
returns
>
public int ExecuteSqlInsertImg(string SqlString,byte[] fs)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using(System.Data.IDbCommand iCmd = GetCommand(SqlString,iConn))
{
System.Data.IDataParameter myParameter = this.iDbPara( "@content", "Image");
myParameter.Value = fs ;
iCmd.Parameters.Add(myParameter);
iConn.Open();
try
{
int rows = iCmd.ExecuteNonQuery();
return rows;
}
catch( System.Exception e )
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行一条计算查询结果语句，返回查询结果（object）。
///
</
summary
>
///
<
param
name=
"SQLString"
>计算查询结果语句
</
param
>
///
<
returns
>查询结果（object）
</
returns
>
public object GetSingle(string SqlString)
{
using (System.Data.IDbConnection iConn = GetConnection())
{
using (System.Data.IDbCommand iCmd = GetCommand(SqlString,iConn))
{
iConn.Open();
try
{
object obj = iCmd.ExecuteScalar();
if((Object.Equals(obj,null))||(Object.Equals(obj,System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行查询语句，返回IDataAdapter
///
</
summary
>
///
<
param
name=
"strSQL"
>查询语句
</
param
>
///
<
returns
>IDataAdapter
</
returns
>
public IDataAdapter ExecuteReader(string strSQL)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
try
{
System.Data.IDataAdapter iAdapter = this.GetAdapater(strSQL,iConn);
return iAdapter;
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
/**////
<
summary
>
/// 执行查询语句，返回DataSet
///
</
summary
>
///
<
param
name=
"SQLString"
>查询语句
</
param
>
///
<
returns
>DataSet
</
returns
>
public DataSet Query(string sqlString)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using(System.Data.IDbCommand iCmd = GetCommand(sqlString,iConn))
{
DataSet ds = new DataSet();
iConn.Open();
try
{
System.Data.IDataAdapter iAdapter = this.GetAdapater(sqlString,iConn);
iAdapter.Fill(ds);
return ds;
}
catch(System.Exception ex)
{
throw new Exception(ex.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行查询语句，返回DataSet
///
</
summary
>
///
<
param
name=
"sqlString"
>查询语句
</
param
>
///
<
param
name=
"dataSet"
>要填充的DataSet
</
param
>
///
<
param
name=
"tableName"
>要填充的表名
</
param
>
///
<
returns
>DataSet
</
returns
>
public DataSet Query(string sqlString,DataSet dataSet,string tableName)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using(System.Data.IDbCommand iCmd = GetCommand(sqlString,iConn))
{
iConn.Open();
try
{
System.Data.IDataAdapter iAdapter = this.GetAdapater(sqlString,iConn);
((OleDbDataAdapter)iAdapter).Fill(dataSet,tableName);
return dataSet;
}
catch(System.Exception ex)
{
throw new Exception(ex.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行SQL语句 返回存储过程
///
</
summary
>
///
<
param
name=
"sqlString"
>Sql语句
</
param
>
///
<
param
name=
"dataSet"
>要填充的DataSet
</
param
>
///
<
param
name=
"startIndex"
>开始记录
</
param
>
///
<
param
name=
"pageSize"
>页面记录大小
</
param
>
///
<
param
name=
"tableName"
>表名称
</
param
>
///
<
returns
>DataSet
</
returns
>
public DataSet Query(string sqlString , DataSet dataSet ,int startIndex ,int pageSize, string tableName )
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
try
{
System.Data.IDataAdapter iAdapter = this.GetAdapater(sqlString,iConn);
((OleDbDataAdapter)iAdapter).Fill(dataSet,startIndex,pageSize,tableName);
return dataSet;
}
catch(Exception ex)
{
throw new Exception(ex.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
/**////
<
summary
>
/// 执行查询语句，向XML文件写入数据
///
</
summary
>
///
<
param
name=
"sqlString"
>查询语句
</
param
>
///
<
param
name=
"xmlPath"
>XML文件路径
</
param
>
public void WriteToXml(string sqlString,string xmlPath)
{
Query(sqlString).WriteXml(xmlPath);
}
/**////
<
summary
>
/// 执行查询语句
///
</
summary
>
///
<
param
name=
"SqlString"
>查询语句
</
param
>
///
<
returns
>DataTable
</
returns
>
public DataTable ExecuteQuery(string sqlString)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
//System.Data.IDbCommand iCmd = GetCommand(sqlString,iConn);
DataSet ds = new DataSet();
try
{
System.Data.IDataAdapter iAdapter = this.GetAdapater(sqlString,iConn);
iAdapter.Fill(ds);
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
return ds.Tables[0];
}
}
/**////
<
summary
>
/// 执行查询语句
///
</
summary
>
///
<
param
name=
"SqlString"
>查询语句
</
param
>
///
<
returns
>DataTable
</
returns
>
public DataTable ExecuteQuery(string SqlString,string Proc)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using(System.Data.IDbCommand iCmd = GetCommand(SqlString,iConn))
{
iCmd.CommandType = CommandType.StoredProcedure;
DataSet ds = new DataSet();
try
{
System.Data.IDataAdapter iDataAdapter = this.GetAdapater(SqlString,iConn);
iDataAdapter.Fill(ds);
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
return ds.Tables[0];
}
}
}
/**////
<
summary
>
///
///
</
summary
>
///
<
param
name=
"Sql"
>
</
param
>
///
<
returns
>
</
returns
>
public DataView ExeceuteDataView(string Sql)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
using(System.Data.IDbCommand iCmd = GetCommand(Sql,iConn))
{
DataSet ds = new DataSet();
try
{
System.Data.IDataAdapter iDataAdapter = this.GetAdapater(Sql,iConn);
iDataAdapter.Fill(ds);
return ds.Tables[0].DefaultView;
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
#endregion
#region 执行带参数的SQL语句
/**////
<
summary
>
/// 执行SQL语句，返回影响的记录数
///
</
summary
>
///
<
param
name=
"SQLString"
>SQL语句
</
param
>
///
<
returns
>影响的记录数
</
returns
>
public int ExecuteSql(string SQLString,params IDataParameter[] iParms)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
System.Data.IDbCommand iCmd = GetCommand();
{
try
{
PrepareCommand(out iCmd, iConn, null , SQLString, iParms );
int rows=iCmd.ExecuteNonQuery();
iCmd.Parameters.Clear();
return rows;
}
catch(System.Exception E)
{
throw new Exception( E.Message );
}
finally
{
iCmd.Dispose();
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行多条SQL语句，实现数据库事务。
///
</
summary
>
///
<
param
name=
"SQLStringList"
>SQL语句的哈希表（key为sql语句，value是该语句的SqlParameter[]）
</
param
>
public void ExecuteSqlTran(Hashtable SQLStringList)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
using (IDbTransaction iTrans = iConn.BeginTransaction())
{
System.Data.IDbCommand iCmd = GetCommand();
try
{
//循环
foreach ( DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
IDataParameter[] iParms=( IDataParameter[] ) myDE.Value;
PrepareCommand( out iCmd , iConn , iTrans , cmdText , iParms );
int val = iCmd.ExecuteNonQuery();
iCmd.Parameters.Clear();
}
iTrans.Commit();
}
catch
{
iTrans.Rollback();
throw;
}
finally
{
iCmd.Dispose();
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行一条计算查询结果语句，返回查询结果（object）。
///
</
summary
>
///
<
param
name=
"SQLString"
>计算查询结果语句
</
param
>
///
<
returns
>查询结果（object）
</
returns
>
public object GetSingle(string SQLString,params IDataParameter[] iParms)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
System.Data.IDbCommand iCmd = GetCommand();
{
try
{
PrepareCommand( out iCmd, iConn, null , SQLString, iParms );
object obj = iCmd.ExecuteScalar();
iCmd.Parameters.Clear();
if((Object.Equals(obj,null))||(Object.Equals(obj,System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
iCmd.Dispose();
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行查询语句，返回IDataReader
///
</
summary
>
///
<
param
name=
"strSQL"
>查询语句
</
param
>
///
<
returns
> IDataReader
</
returns
>
public IDataReader ExecuteReader(string SQLString,params IDataParameter[] iParms)
{
System.Data.IDbConnection iConn = this.GetConnection();
{
System.Data.IDbCommand iCmd = GetCommand();
{
try
{
PrepareCommand(out iCmd, iConn , null , SQLString , iParms);
System.Data.IDataReader iReader = iCmd.ExecuteReader();
iCmd.Parameters.Clear();
return iReader;
}
catch(System.Exception e)
{
throw new Exception(e.Message);
}
finally
{
iCmd.Dispose();
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 执行查询语句，返回DataSet
///
</
summary
>
///
<
param
name=
"SQLString"
>查询语句
</
param
>
///
<
returns
>DataSet
</
returns
>
public DataSet Query(string sqlString,params IDataParameter[] iParms)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
IDbCommand iCmd = GetCommand();
{
PrepareCommand(out iCmd , iConn , null , sqlString , iParms );
try
{
IDataAdapter iAdapter = this.GetAdapater(sqlString,iConn);
DataSet ds = new DataSet();
iAdapter.Fill(ds);
iCmd.Parameters.Clear();
return ds;
}
catch(System.Exception ex)
{
throw new Exception(ex.Message);
}
finally
{
iCmd.Dispose();
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
}
}
}
/**////
<
summary
>
/// 初始化Command
///
</
summary
>
///
<
param
name=
"iCmd"
>
</
param
>
///
<
param
name=
"iConn"
>
</
param
>
///
<
param
name=
"iTrans"
>
</
param
>
///
<
param
name=
"cmdText"
>
</
param
>
///
<
param
name=
"iParms"
>
</
param
>
private void PrepareCommand(out IDbCommand iCmd,IDbConnection iConn,System.Data.IDbTransaction iTrans, string cmdText, IDataParameter[] iParms)
{
if (iConn.State != ConnectionState.Open)
iConn.Open();
iCmd = this.GetCommand();
iCmd.Connection = iConn;
iCmd.CommandText = cmdText;
if (iTrans != null)
iCmd.Transaction = iTrans;
iCmd.CommandType = CommandType.Text;//cmdType;
if (iParms != null)
{
foreach (IDataParameter parm in iParms)
iCmd.Parameters.Add(parm);
}
}
#endregion
#region 存储过程操作
/**////
<
summary
>
/// 执行存储过程
///
</
summary
>
///
<
param
name=
"storedProcName"
>存储过程名
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
returns
>SqlDataReader
</
returns
>
public SqlDataReader RunProcedure(string storedProcName, IDataParameter[] parameters )
{
System.Data.IDbConnection iConn = this.GetConnection();
{
iConn.Open();
using(SqlCommand sqlCmd = BuildQueryCommand(iConn,storedProcName, parameters))
{
return sqlCmd.ExecuteReader(CommandBehavior.CloseConnection);
}
}
}
/**////
<
summary
>
/// 执行存储过程
///
</
summary
>
///
<
param
name=
"storedProcName"
>存储过程名
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
param
name=
"tableName"
>DataSet结果中的表名
</
param
>
///
<
returns
>DataSet
</
returns
>
public DataSet RunProcedure(string storedProcName, IDataParameter[] parameters ,string tableName)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
DataSet dataSet = new DataSet();
iConn.Open();
System.Data.IDataAdapter iDA = this.GetAdapater();
iDA = this.GetAdapater( BuildQueryCommand(iConn, storedProcName, parameters ) );
((SqlDataAdapter)iDA).Fill( dataSet,tableName);
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
return dataSet;
}
}
/**////
<
summary
>
/// 执行存储过程
///
</
summary
>
///
<
param
name=
"storedProcName"
>存储过程名
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
param
name=
"tableName"
>DataSet结果中的表名
</
param
>
///
<
param
name=
"startIndex"
>开始记录索引
</
param
>
///
<
param
name=
"pageSize"
>页面记录大小
</
param
>
///
<
returns
>DataSet
</
returns
>
public DataSet RunProcedure(string storedProcName, IDataParameter[] parameters ,int startIndex,int pageSize,string tableName)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
DataSet dataSet = new DataSet();
iConn.Open();
System.Data.IDataAdapter iDA = this.GetAdapater();
iDA = this.GetAdapater( BuildQueryCommand(iConn, storedProcName, parameters ) );
((SqlDataAdapter)iDA).Fill( dataSet,startIndex,pageSize,tableName);
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
return dataSet;
}
}
/**////
<
summary
>
/// 执行存储过程 填充已经存在的DataSet数据集
///
</
summary
>
///
<
param
name=
"storeProcName"
>存储过程名称
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
param
name=
"dataSet"
>要填充的数据集
</
param
>
///
<
param
name=
"tablename"
>要填充的表名
</
param
>
///
<
returns
>
</
returns
>
public DataSet RunProcedure(string storeProcName,IDataParameter[] parameters,DataSet dataSet,string tableName)
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
System.Data.IDataAdapter iDA = this.GetAdapater();
iDA = this.GetAdapater(BuildQueryCommand(iConn,storeProcName,parameters));
((SqlDataAdapter)iDA).Fill(dataSet,tableName);
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
return dataSet;
}
}
/**////
<
summary
>
/// 执行存储过程并返回受影响的行数
///
</
summary
>
///
<
param
name=
"storedProcName"
>
</
param
>
///
<
param
name=
"parameters"
>
</
param
>
///
<
returns
>
</
returns
>
public int RunProcedureNoQuery(string storedProcName, IDataParameter[] parameters )
{
int result = 0;
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
using(SqlCommand scmd = BuildQueryCommand(iConn,storedProcName,parameters))
{
result = scmd.ExecuteNonQuery();
}
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
return result ;
}
public string RunProcedureExecuteScalar(string storeProcName,IDataParameter[] parameters)
{
string result = string.Empty;
using (System.Data.IDbConnection iConn = this.GetConnection())
{
iConn.Open();
using(SqlCommand scmd = BuildQueryCommand(iConn,storeProcName,parameters))
{
object obj = scmd.ExecuteScalar();
if(obj == null)
result = null;
else
result = obj.ToString();
}
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
}
return result;
}
/**////
<
summary
>
/// 构建 SqlCommand 对象(用来返回一个结果集，而不是一个整数值)
///
</
summary
>
///
<
param
name=
"connection"
>数据库连接
</
param
>
///
<
param
name=
"storedProcName"
>存储过程名
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
returns
>SqlCommand
</
returns
>
private SqlCommand BuildQueryCommand(IDbConnection iConn,string storedProcName, IDataParameter[] parameters)
{
IDbCommand iCmd = GetCommand(storedProcName,iConn);
iCmd.CommandType = CommandType.StoredProcedure;
if (parameters == null)
{
return (SqlCommand)iCmd;
}
foreach (IDataParameter parameter in parameters)
{
iCmd.Parameters.Add( parameter );
}
return (SqlCommand)iCmd;
}
/**////
<
summary
>
/// 执行存储过程，返回影响的行数
///
</
summary
>
///
<
param
name=
"storedProcName"
>存储过程名
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
param
name=
"rowsAffected"
>影响的行数
</
param
>
///
<
returns
>
</
returns
>
public int RunProcedure(string storedProcName, IDataParameter[] parameters, out int rowsAffected )
{
using (System.Data.IDbConnection iConn = this.GetConnection())
{
int result;
iConn.Open();
using(SqlCommand sqlCmd = BuildIntCommand(iConn,storedProcName, parameters ))
{
rowsAffected = sqlCmd.ExecuteNonQuery();
result = (int)sqlCmd.Parameters["ReturnValue"].Value;
if(iConn.State != ConnectionState.Closed)
{
iConn.Close();
}
return result;
}
}
}
/**////
<
summary
>
/// 创建 SqlCommand 对象实例(用来返回一个整数值)
///
</
summary
>
///
<
param
name=
"storedProcName"
>存储过程名
</
param
>
///
<
param
name=
"parameters"
>存储过程参数
</
param
>
///
<
returns
>SqlCommand 对象实例
</
returns
>
private SqlCommand BuildIntCommand(IDbConnection iConn,string storedProcName, IDataParameter[] parameters)
{
SqlCommand sqlCmd = BuildQueryCommand(iConn,storedProcName, parameters );
sqlCmd.Parameters.Add( new SqlParameter ( "ReturnValue",
SqlDbType.Int,4,ParameterDirection.ReturnValue,
false,0,0,string.Empty,DataRowVersion.Default,null ));
return sqlCmd;
}
#endregion
}
}
- 1.
- 2.
- 3.
- 4.
- 5.
- 6.
- 7.
- 8.
- 9.
- 10.
- 11.
- 12.
- 13.
- 14.
- 15.
- 16.
- 17.
- 18.
- 19.
- 20.
- 21.
- 22.
- 23.
- 24.
- 25.
- 26.
- 27.
- 28.
- 29.
- 30.
- 31.
- 32.
- 33.
- 34.
- 35.
- 36.
- 37.
- 38.
- 39.
- 40.
- 41.
- 42.
- 43.
- 44.
- 45.
- 46.
- 47.
- 48.
- 49.
- 50.
- 51.
- 52.
- 53.
- 54.
- 55.
- 56.
- 57.
- 58.
- 59.
- 60.
- 61.
- 62.
- 63.
- 64.
- 65.
- 66.
- 67.
- 68.
- 69.
- 70.
- 71.
- 72.
- 73.
- 74.
- 75.
- 76.
- 77.
- 78.
- 79.
- 80.
- 81.
- 82.
- 83.
- 84.
- 85.
- 86.
- 87.
- 88.
- 89.
- 90.
- 91.
- 92.
- 93.
- 94.
- 95.
- 96.
- 97.
- 98.
- 99.
- 100.
- 101.
- 102.
- 103.
- 104.
- 105.
- 106.
- 107.
- 108.
- 109.
- 110.
- 111.
- 112.
- 113.
- 114.
- 115.
- 116.
- 117.
- 118.
- 119.
- 120.
- 121.
- 122.
- 123.
- 124.
- 125.
- 126.
- 127.
- 128.
- 129.
- 130.
- 131.
- 132.
- 133.
- 134.
- 135.
- 136.
- 137.
- 138.
- 139.
- 140.
- 141.
- 142.
- 143.
- 144.
- 145.
- 146.
- 147.
- 148.
- 149.
- 150.
- 151.
- 152.
- 153.
- 154.
- 155.
- 156.
- 157.
- 158.
- 159.
- 160.
- 161.
- 162.
- 163.
- 164.
- 165.
- 166.
- 167.
- 168.
- 169.
- 170.
- 171.
- 172.
- 173.
- 174.
- 175.
- 176.
- 177.
- 178.
- 179.
- 180.
- 181.
- 182.
- 183.
- 184.
- 185.
- 186.
- 187.
- 188.
- 189.
- 190.
- 191.
- 192.
- 193.
- 194.
- 195.
- 196.
- 197.
- 198.
- 199.
- 200.
- 201.
- 202.
- 203.
- 204.
- 205.
- 206.
- 207.
- 208.
- 209.
- 210.
- 211.
- 212.
- 213.
- 214.
- 215.
- 216.
- 217.
- 218.
- 219.
- 220.
- 221.
- 222.
- 223.
- 224.
- 225.
- 226.
- 227.
- 228.
- 229.
- 230.
- 231.
- 232.
- 233.
- 234.
- 235.
- 236.
- 237.
- 238.
- 239.
- 240.
- 241.
- 242.
- 243.
- 244.
- 245.
- 246.
- 247.
- 248.
- 249.
- 250.
- 251.
- 252.
- 253.
- 254.
- 255.
- 256.
- 257.
- 258.
- 259.
- 260.
- 261.
- 262.
- 263.
- 264.
- 265.
- 266.
- 267.
- 268.
- 269.
- 270.
- 271.
- 272.
- 273.
- 274.
- 275.
- 276.
- 277.
- 278.
- 279.
- 280.
- 281.
- 282.
- 283.
- 284.
- 285.
- 286.
- 287.
- 288.
- 289.
- 290.
- 291.
- 292.
- 293.
- 294.
- 295.
- 296.
- 297.
- 298.
- 299.
- 300.
- 301.
- 302.
- 303.
- 304.
- 305.
- 306.
- 307.
- 308.
- 309.
- 310.
- 311.
- 312.
- 313.
- 314.
- 315.
- 316.
- 317.
- 318.
- 319.
- 320.
- 321.
- 322.
- 323.
- 324.
- 325.
- 326.
- 327.
- 328.
- 329.
- 330.
- 331.
- 332.
- 333.
- 334.
- 335.
- 336.
- 337.
- 338.
- 339.
- 340.
- 341.
- 342.
- 343.
- 344.
- 345.
- 346.
- 347.
- 348.
- 349.
- 350.
- 351.
- 352.
- 353.
- 354.
- 355.
- 356.
- 357.
- 358.
- 359.
- 360.
- 361.
- 362.
- 363.
- 364.
- 365.
- 366.
- 367.
- 368.
- 369.
- 370.
- 371.
- 372.
- 373.
- 374.
- 375.
- 376.
- 377.
- 378.
- 379.
- 380.
- 381.
- 382.
- 383.
- 384.
- 385.
- 386.
- 387.
- 388.
- 389.
- 390.
- 391.
- 392.
- 393.
- 394.
- 395.
- 396.
- 397.
- 398.
- 399.
- 400.
- 401.
- 402.
- 403.
- 404.
- 405.
- 406.
- 407.
- 408.
- 409.
- 410.
- 411.
- 412.
- 413.
- 414.
- 415.
- 416.
- 417.
- 418.
- 419.
- 420.
- 421.
- 422.
- 423.
- 424.
- 425.
- 426.
- 427.
- 428.
- 429.
- 430.
- 431.
- 432.
- 433.
- 434.
- 435.
- 436.
- 437.
- 438.
- 439.
- 440.
- 441.
- 442.
- 443.
- 444.
- 445.
- 446.
- 447.
- 448.
- 449.
- 450.
- 451.
- 452.
- 453.
- 454.
- 455.
- 456.
- 457.
- 458.
- 459.
- 460.
- 461.
- 462.
- 463.
- 464.
- 465.
- 466.
- 467.
- 468.
- 469.
- 470.
- 471.
- 472.
- 473.
- 474.
- 475.
- 476.
- 477.
- 478.
- 479.
- 480.
- 481.
- 482.
- 483.
- 484.
- 485.
- 486.
- 487.
- 488.
- 489.
- 490.
- 491.
- 492.
- 493.
- 494.
- 495.
- 496.
- 497.
- 498.
- 499.
- 500.
- 501.
- 502.
- 503.
- 504.
- 505.
- 506.
- 507.
- 508.
- 509.
- 510.
- 511.
- 512.
- 513.
- 514.
- 515.
- 516.
- 517.
- 518.
- 519.
- 520.
- 521.
- 522.
- 523.
- 524.
- 525.
- 526.
- 527.
- 528.
- 529.
- 530.
- 531.
- 532.
- 533.
- 534.
- 535.
- 536.
- 537.
- 538.
- 539.
- 540.
- 541.
- 542.
- 543.
- 544.
- 545.
- 546.
- 547.
- 548.
- 549.
- 550.
- 551.
- 552.
- 553.
- 554.
- 555.
- 556.
- 557.
- 558.
- 559.
- 560.
- 561.
- 562.
- 563.
- 564.
- 565.
- 566.
- 567.
- 568.
- 569.
- 570.
- 571.
- 572.
- 573.
- 574.
- 575.
- 576.
- 577.
- 578.
- 579.
- 580.
- 581.
- 582.
- 583.
- 584.
- 585.
- 586.
- 587.
- 588.
- 589.
- 590.
- 591.
- 592.
- 593.
- 594.
- 595.
- 596.
- 597.
- 598.
- 599.
- 600.
- 601.
- 602.
- 603.
- 604.
- 605.
- 606.
- 607.
- 608.
- 609.
- 610.
- 611.
- 612.
- 613.
- 614.
- 615.
- 616.
- 617.
- 618.
- 619.
- 620.
- 621.
- 622.
- 623.
- 624.
- 625.
- 626.
- 627.
- 628.
- 629.
- 630.
- 631.
- 632.
- 633.
- 634.
- 635.
- 636.
- 637.
- 638.
- 639.
- 640.
- 641.
- 642.
- 643.
- 644.
- 645.
- 646.
- 647.
- 648.
- 649.
- 650.
- 651.
- 652.
- 653.
- 654.
- 655.
- 656.
- 657.
- 658.
- 659.
- 660.
- 661.
- 662.
- 663.
- 664.
- 665.
- 666.
- 667.
- 668.
- 669.
- 670.
- 671.
- 672.
- 673.
- 674.
- 675.
- 676.
- 677.
- 678.
- 679.
- 680.
- 681.
- 682.
- 683.
- 684.
- 685.
- 686.
- 687.
- 688.
- 689.
- 690.
- 691.
- 692.
- 693.
- 694.
- 695.
- 696.
- 697.
- 698.
- 699.
- 700.
- 701.
- 702.
- 703.
- 704.
- 705.
- 706.
- 707.
- 708.
- 709.
- 710.
- 711.
- 712.
- 713.
- 714.
- 715.
- 716.
- 717.
- 718.
- 719.
- 720.
- 721.
- 722.
- 723.
- 724.
- 725.
- 726.
- 727.
- 728.
- 729.
- 730.
- 731.
- 732.
- 733.
- 734.
- 735.
- 736.
- 737.
- 738.
- 739.
- 740.
- 741.
- 742.
- 743.
- 744.
- 745.
- 746.
- 747.
- 748.
- 749.
- 750.
- 751.
- 752.
- 753.
- 754.
- 755.
- 756.
- 757.
- 758.
- 759.
- 760.
- 761.
- 762.
- 763.
- 764.
- 765.
- 766.
- 767.
- 768.
- 769.
- 770.
- 771.
- 772.
- 773.
- 774.
- 775.
- 776.
- 777.
- 778.
- 779.
- 780.
- 781.
- 782.
- 783.
- 784.
- 785.
- 786.
- 787.
- 788.
- 789.
- 790.
- 791.
- 792.
- 793.
- 794.
- 795.
- 796.
- 797.
- 798.
- 799.
- 800.
- 801.
- 802.
- 803.
- 804.
- 805.
- 806.
- 807.
- 808.
- 809.
- 810.
- 811.
- 812.
- 813.
- 814.
- 815.
- 816.
- 817.
- 818.
- 819.
- 820.
- 821.
- 822.
- 823.
- 824.
- 825.
- 826.
- 827.
- 828.
- 829.
- 830.
- 831.
- 832.
- 833.
- 834.
- 835.
- 836.
- 837.
- 838.
- 839.
- 840.
- 841.
- 842.
- 843.
- 844.
- 845.
- 846.
- 847.
- 848.
- 849.
- 850.
- 851.
- 852.
- 853.
- 854.
- 855.
- 856.
- 857.
- 858.
- 859.
- 860.
- 861.
- 862.
- 863.
- 864.
- 865.
- 866.
- 867.
- 868.
- 869.
- 870.
- 871.
- 872.
- 873.
- 874.
- 875.
- 876.
- 877.
- 878.
- 879.
- 880.
- 881.
- 882.
- 883.
- 884.
- 885.
- 886.
- 887.
- 888.
- 889.
- 890.
- 891.
- 892.
- 893.
- 894.
- 895.
- 896.
- 897.
- 898.
- 899.
- 900.
- 901.
- 902.
- 903.
- 904.
- 905.
- 906.
- 907.
- 908.
- 909.
- 910.
- 911.
- 912.
- 913.
- 914.
- 915.
- 916.
- 917.
- 918.
- 919.
- 920.
- 921.
- 922.
- 923.
- 924.
- 925.
- 926.
- 927.
- 928.
- 929.
- 930.
- 931.
- 932.
- 933.
- 934.
- 935.
- 936.
- 937.
- 938.
- 939.
- 940.
- 941.
- 942.
- 943.
- 944.
- 945.
- 946.
- 947.
- 948.
- 949.
- 950.
- 951.
- 952.
- 953.
- 954.
- 955.
- 956.
- 957.
- 958.
- 959.
- 960.
- 961.
- 962.
- 963.
- 964.
- 965.
- 966.
- 967.
- 968.
- 969.
- 970.
- 971.
- 972.
- 973.
- 974.
- 975.
- 976.
- 977.
- 978.
- 979.
- 980.
- 981.
- 982.
- 983.
- 984.
- 985.
- 986.
- 987.
- 988.
- 989.
- 990.
- 991.
- 992.
- 993.
- 994.
- 995.
- 996.
- 997.
- 998.
- 999.
- 1000.
- 1001.
- 1002.
- 1003.
- 1004.
- 1005.
- 1006.
- 1007.
- 1008.
- 1009.
- 1010.
- 1011.
- 1012.
- 1013.
- 1014.
- 1015.
- 1016.
- 1017.
- 1018.
- 1019.
- 1020.
- 1021.
- 1022.
- 1023.
- 1024.
- 1025.
- 1026.
- 1027.
- 1028.
- 1029.
- 1030.
- 1031.
- 1032.
- 1033.
- 1034.
- 1035.
- 1036.
- 1037.
- 1038.
- 1039.
- 1040.
- 1041.
- 1042.
- 1043.
- 1044.
- 1045.
- 1046.
- 1047.
- 1048.
- 1049.
- 1050.
- 1051.
- 1052.
- 1053.
- 1054.
- 1055.
- 1056.
- 1057.
- 1058.
- 1059.
- 1060.
- 1061.
- 1062.
- 1063.
- 1064.
- 1065.
- 1066.
- 1067.
- 1068.
- 1069.
- 1070.
- 1071.
- 1072.
- 1073.
- 1074.
- 1075.
- 1076.
- 1077.
- 1078.
- 1079.
- 1080.
- 1081.
- 1082.
- 1083.
- 1084.
- 1085.
- 1086.
- 1087.
- 1088.
- 1089.
- 1090.
- 1091.
- 1092.
- 1093.
- 1094.
- 1095.
- 1096.
- 1097.
- 1098.
- 1099.
- 1100.
- 1101.
- 1102.
- 1103.
- 1104.
- 1105.
- 1106.
- 1107.
- 1108.
- 1109.
- 1110.
- 1111.
- 1112.
- 1113.
- 1114.
- 1115.
- 1116.
- 1117.
- 1118.
- 1119.
- 1120.
- 1121.
- 1122.
- 1123.
- 1124.
- 1125.
- 1126.
- 1127.
- 1128.
- 1129.
- 1130.
- 1131.
- 1132.
- 1133.
- 1134.
- 1135.
- 1136.
- 1137.
- 1138.
- 1139.
- 1140.
- 1141.
- 1142.
- 1143.
- 1144.
- 1145.
- 1146.
- 1147.
- 1148.
- 1149.
- 1150.
- 1151.
- 1152.
- 1153.
- 1154.
- 1155.
- 1156.
- 1157.
- 1158.
- 1159.
- 1160.
- 1161.
- 1162.
- 1163.
- 1164.
- 1165.
- 1166.
- 1167.
- 1168.
- 1169.
- 1170.
- 1171.
- 1172.
- 1173.
- 1174.
- 1175.
- 1176.
- 1177.
龙腾一族至尊龙骑
边栏推荐
- Tidb monitoring upgrade: a long way to solve panic
- SAP ui5 application development tutorial 102 - detailed explanation of the print function of SAP ui5 applications
- SAP ui5 application development tutorial 103 - how to consume the trial version of the third-party library in SAP ui5 applications
- 如何入门机器学习？
- Extend your kubernetes API using the aggregation API
- 07 project cost management
- 通过天天基金投资基金安全吗？我打算开户买基金
- Template specialization template ＜＞
- Vector 1 (classes and objects)
- 关于测试/开发程序员技术的一些思考，水平很高超的，混不下去了......
猜你喜欢
贵金属现货白银如何呢？
Tidb monitoring upgrade: a long way to solve panic
Yyds dry inventory solution sword finger offer: print the binary tree into multiple lines
JMeter associated login 302 type interface
How to set the power-off auto start of easycvr hardware box
Some thoughts about the technology of test / development programmers are very advanced, and they can't go on
初学者如何快速入门深度学习?
【机器学习-西瓜书】更文挑战【Day1】：1.1 引言
How to get started with machine learning?
EasyCVR使用RTMP推流时不显示界面如何解决？
随机推荐
层次选择器
Dig three feet to solve the data consistency problem between redis and MySQL
[sliding window] leetcode992 Subarrays with K Different Integers
每日刷题记录 (一)
Graphite statsd interface data format description
How to refine permissions to buttons?
Ros2 summer school 2022 transfer-
How to get started with machine learning?
百度交易中台之钱包系统架构浅析
LeetCode刷题——715. Range 模块
Which platform is safer to buy stocks on?
启牛学堂属于证券公司吗？开户安全吗？
Leetcode question brushing - 715 Range module
Typecho imite le modèle de thème du blog Lu songsongsong / modèle de thème du blog d'information technologique
Installing MySQL for Linux
How about China International Futures Co., Ltd.? Is it a regular futures company? Is it safe to open an account online?
a++,++a,!,~
【机器学习-西瓜书】更文挑战【Day1】：1.1 引言
The road of architects starts from "storage selection"
MD5 encryption + salt value tool class