2. 程式人生 > >C#連線oracle例項

C#連線oracle例項

阿新 • • 發佈：2019-01-19

本文所述為C#實現的Oracle資料庫操作類，可執行超多常用的Oracle資料庫操作，包含了基礎資料庫連線、關閉連線、輸出記錄集、執行Sql語句，返回帶分頁功能的dataset 、取表裡欄位的型別和長度等，同時還有哈稀表自動插入資料庫等高階任務。需要特別指出的是：在執行SQL語句，返回 DataReader之前一定要先用.read()開啟,然後才能讀到資料，再用hashTable對資料庫進行insert,update,del操作,注意此時只能用預設的資料庫連線"connstr"。

完整的C# Oracle資料庫類例項程式碼如下：

using System;
using System.Data;
using System.Data.OracleClient;
using System.Collections;
using System.Reflection;
namespace MyOraComm
{
 /// ConnDbForOracle 的摘要說明。
 public class ConnForOracle
 {
  protected OracleConnection Connection;
  private string connectionString;
  public ConnForOracle()
  {
  string connStr;
  connStr = System.Configuration.ConfigurationSettings.AppSettings["connStr"].ToString();
  connectionString = connStr;
  Connection = new OracleConnection(connectionString);
  }
 
  #region 帶引數的建構函式 
  /// 帶引數的建構函式
  /// 資料庫聯接字串
  public ConnForOracle(string ConnString)
  {
  string connStr;
  connStr = System.Configuration.ConfigurationSettings.AppSettings[ConnString].ToString();
  Connection = new OracleConnection(connStr);
  }
  #endregion

  #region 開啟資料庫 
  /// 開啟資料庫
  public void OpenConn()
  {
  if(this.Connection.State!=ConnectionState.Open)
   this.Connection.Open();
  }
  #endregion
  #region 關閉資料庫聯接 
  /// 關閉資料庫聯接
  public void CloseConn()
  {
  if(Connection.State==ConnectionState.Open)
   Connection.Close();
  }
  #endregion

  #region 執行SQL語句，返回資料到DataSet中
  /// 執行SQL語句，返回資料到DataSet中
  /// sql語句
  /// 自定義返回的DataSet表名
  /// 返回DataSet
  public DataSet ReturnDataSet(string sql,string DataSetName)
  {
  DataSet dataSet=new DataSet();
  OpenConn();
  OracleDataAdapter OraDA=new OracleDataAdapter(sql,Connection);
  OraDA.Fill(dataSet,DataSetName);
  //  CloseConn();
  return dataSet;
  }
  #endregion

  #region 執行Sql語句,返回帶分頁功能的dataset 
  /// 執行Sql語句,返回帶分頁功能的dataset
  /// Sql語句
  /// 每頁顯示記錄數
  /// <當前頁/param>
  /// 返回dataset表名
  /// 返回DataSet
  public DataSet ReturnDataSet(string sql,int PageSize,int CurrPageIndex,string DataSetName)
  {
  DataSet dataSet=new DataSet();
  OpenConn();
  OracleDataAdapter OraDA=new OracleDataAdapter(sql,Connection);
  OraDA.Fill(dataSet,PageSize * (CurrPageIndex - 1), PageSize,DataSetName);
  //  CloseConn();
  return dataSet;
  }
  #endregion

  #region 執行SQL語句，返回 DataReader,用之前一定要先.read()開啟,然後才能讀到資料
  /// 執行SQL語句，返回 DataReader,用之前一定要先.read()開啟,然後才能讀到資料 
  /// sql語句
  /// 返回一個OracleDataReader
  public OracleDataReader ReturnDataReader(String sql)
  {
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  return command.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
  }
  #endregion

  #region 執行SQL語句，返回記錄總數數
  /// 執行SQL語句，返回記錄總數數
  /// sql語句
  /// 返回記錄總條數
  public int GetRecordCount(string sql)
  {
  int recordCount = 0;
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  OracleDataReader dataReader = command.ExecuteReader();
  while(dataReader.Read())
  {
   recordCount++;
  }
  dataReader.Close();
  //CloseConn();
  return recordCount;
  }
  #endregion

  #region 取當前序列,條件為seq.nextval或seq.currval
  /// 
  /// 取當前序列
  public decimal GetSeq(string seqstr)
  {
  decimal seqnum = 0;
  string sql="select "+seqstr+" from dual";
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  OracleDataReader dataReader = command.ExecuteReader();
  if(dataReader.Read())
  {
   seqnum=decimal.Parse(dataReader[0].ToString());
  }
  dataReader.Close();
  //  CloseConn();
  return seqnum;
  }
  #endregion
  #region 執行SQL語句,返回所影響的行數
  /// 執行SQL語句,返回所影響的行數
  public int ExecuteSQL(string sql)
  {
  int Cmd=0;
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  try
  {
   Cmd =command.ExecuteNonQuery(); 
  }
  catch
  {
  }
  finally
  {
   //CloseConn();
  }
  return Cmd;
  }
  #endregion
 
  //＝＝用hashTable對資料庫進行insert,update,del操作,注意此時只能用預設的資料庫連線"connstr"
  #region 根據表名及哈稀表自動插入資料庫 用法：Insert("test",ht)
  public int Insert(string TableName,Hashtable ht)
  {
  OracleParameter[] Parms=new OracleParameter[ht.Count];
  IDictionaryEnumerator et = ht.GetEnumerator();
  DataTable dt=GetTabType(TableName);
  System.Data.OracleClient.OracleType otype;
  int size=0;
  int i=0;
  while ( et.MoveNext() ) // 作雜湊表迴圈
  {
   GetoType(et.Key.ToString().ToUpper(),dt,out otype,out size);
   System.Data.OracleClient.OracleParameter op=MakeParam(":"+et.Key.ToString(),otype,size,et.Value.ToString());
   Parms[i]=op; // 新增SqlParameter物件
   i=i+1;
  }
  string str_Sql=GetInsertSqlbyHt(TableName,ht); // 獲得插入sql語句
  int val=ExecuteNonQuery(str_Sql,Parms);
  return val;
  }
  #endregion
 
  #region 根據相關條件對資料庫進行更新操作 用法：Update("test","Id=:Id",ht); 
  public int Update(string TableName,string ht_Where, Hashtable ht)
  {
  OracleParameter[] Parms=new OracleParameter[ht.Count];
  IDictionaryEnumerator et = ht.GetEnumerator();
  DataTable dt=GetTabType(TableName);
  System.Data.OracleClient.OracleType otype;
  int size=0;
  int i=0;
  // 作雜湊表迴圈
  while ( et.MoveNext() )
  {
   GetoType(et.Key.ToString().ToUpper(),dt,out otype,out size);
   System.Data.OracleClient.OracleParameter op=MakeParam(":"+et.Key.ToString(),otype,size,et.Value.ToString());
   Parms[i]=op; // 新增SqlParameter物件
   i=i+1;
  }
  string str_Sql=GetUpdateSqlbyHt(TableName,ht_Where,ht); // 獲得插入sql語句
  int val=ExecuteNonQuery(str_Sql,Parms);
  return val;
  }
  #endregion
 
  #region del操作,注意此處條件個數與hash裡引數個數應該一致 用法：Del("test","Id=:Id",ht)
  public int Del(string TableName,string ht_Where,Hashtable ht)
  {
  OracleParameter[] Parms=new OracleParameter[ht.Count];
  IDictionaryEnumerator et = ht.GetEnumerator();
  DataTable dt=GetTabType(TableName);
  System.Data.OracleClient.OracleType otype;
  int i=0;
  int size=0;
  // 作雜湊表迴圈
  while ( et.MoveNext() )
  {
   GetoType(et.Key.ToString().ToUpper(),dt,out otype,out size);
   System.Data.OracleClient.OracleParameter op=MakeParam(":"+et.Key.ToString(),et.Value.ToString());
   Parms[i]=op; // 新增SqlParameter物件
   i=i+1;
  }
  string str_Sql=GetDelSqlbyHt(TableName,ht_Where,ht); // 獲得刪除sql語句
  int val=ExecuteNonQuery(str_Sql,Parms);
  return val;
  }
  #endregion 

  //　＝＝＝＝＝＝＝＝上面三個操作的內部呼叫函式＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

  #region 根據哈稀表及表名自動生成相應insert語句(引數型別的)
  /// 根據哈稀表及表名自動生成相應insert語句 
  /// 要插入的表名
  /// 哈稀表
  /// 返回sql語句
  public static string GetInsertSqlbyHt(string TableName,Hashtable ht)
  {
  string str_Sql="";
  int i=0;
  int ht_Count=ht.Count; // 雜湊表個數
  IDictionaryEnumerator myEnumerator = ht.GetEnumerator();
  string before="";
  string behide="";
  while ( myEnumerator.MoveNext() )
  {
   if (i==0)
   {
   before="("+myEnumerator.Key;
   }
   else if (i+1==ht_Count)
   {
   before=before+","+myEnumerator.Key+")";
   }
   else
   {
   before=before+","+myEnumerator.Key;
   }
   i=i+1;
  }
  behide=" Values"+before.Replace(",",",:").Replace("(","(:");
  str_Sql="Insert into "+TableName+before+behide;
  return str_Sql;
  }
  #endregion

  #region 根據表名，where條件，哈稀表自動生成更新語句(引數型別的)
  public static string GetUpdateSqlbyHt(string Table,string ht_Where,Hashtable ht)
  {
  string str_Sql="";
  int i=0;
  int ht_Count=ht.Count; // 雜湊表個數
  IDictionaryEnumerator myEnumerator = ht.GetEnumerator();
  while ( myEnumerator.MoveNext() )
  {
   if (i==0)
   {
   if (ht_Where.ToString().ToLower().IndexOf((myEnumerator.Key+"=:"+myEnumerator.Key).ToLower())==-1)
   {
    str_Sql=myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   else
   {
   if (ht_Where.ToString().ToLower().IndexOf((":"+myEnumerator.Key+" ").ToLower())==-1)
   {
    str_Sql=str_Sql+","+myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   i=i+1;
  }
  if (ht_Where==null || ht_Where.Replace(" ","")=="") // 更新時候沒有條件
  {
   str_Sql="update "+Table+" set "+str_Sql;
  }
  else
  {
   str_Sql="update "+Table+" set "+str_Sql+" where "+ht_Where;
  }
  str_Sql=str_Sql.Replace("set ,","set ").Replace("update ,","update ");
  return str_Sql;
  }
  #endregion

  #region 根據表名，where條件，哈稀表自動生成del語句(引數型別的)
  public static string GetDelSqlbyHt(string Table,string ht_Where,Hashtable ht)
  {
  string str_Sql="";
  int i=0;
  
  int ht_Count=ht.Count; // 雜湊表個數
  IDictionaryEnumerator myEnumerator = ht.GetEnumerator();
  while ( myEnumerator.MoveNext() )
  {
   if (i==0)
   {
   if (ht_Where.ToString().ToLower().IndexOf((myEnumerator.Key+"=:"+myEnumerator.Key).ToLower())==-1)
   {
    str_Sql=myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   else
   {
   if (ht_Where.ToString().ToLower().IndexOf((":"+myEnumerator.Key+" ").ToLower())==-1)
   {
    str_Sql=str_Sql+","+myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   i=i+1;
  }
  if (ht_Where==null || ht_Where.Replace(" ","")=="") // 更新時候沒有條件
  {
   str_Sql="Delete "+Table;
  }
  else
  {
   str_Sql="Delete "+Table+" where "+ht_Where;
  }
  return str_Sql;
  }
  #endregion

  #region 生成oracle引數
  /// 
  /// 生成oracle引數
  /// 欄位名
  /// 資料型別
  /// 資料大小
  /// 值
  public static OracleParameter MakeParam(string ParamName,System.Data.OracleClient.OracleType otype,int size,Object Value) 
  {
  OracleParameter para=new OracleParameter(ParamName,Value);
  para.OracleType=otype;
  para.Size=size;
  return para;
  }
  #endregion
  #region 生成oracle引數
  public static OracleParameter MakeParam(string ParamName,string Value) 
  {
  return new OracleParameter(ParamName, Value);
  }
  #endregion
  #region 根據表結構欄位的型別和長度拼裝oracle sql語句引數
  public static void GetoType(string key,DataTable dt,out System.Data.OracleClient.OracleType otype,out int size)
  {
  DataView dv=dt.DefaultView;
  dv.RowFilter="column_name='"+key+"'";
  string fType=dv[0]["data_type"].ToString().ToUpper();
  switch (fType)
  {
   case "DATE":
   otype= OracleType.DateTime;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "CHAR":
   otype= OracleType.Char;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "LONG":
   otype= OracleType.Double;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "NVARCHAR2":
   otype= OracleType.NVarChar;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "VARCHAR2":
   otype= OracleType.NVarChar;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   default:
   otype= OracleType.NVarChar;
   size=100;
   break;
  }
  }
  #endregion
  #region動態 取表裡欄位的型別和長度,此處沒有動態用到connstr,是預設的！by/文少
  public System.Data.DataTable GetTabType(string tabnale)
  {
  string sql="select column_name,data_type,data_length from all_tab_columns where table_name='"+tabnale.ToUpper()+"'";
  OpenConn();
  return (ReturnDataSet(sql,"dv")).Tables[0];
  }
  #endregion
  #region 執行sql語句 
  public int ExecuteNonQuery(string cmdText, params OracleParameter[] cmdParms) 
  {
  OracleCommand cmd = new OracleCommand();
  OpenConn(); 
  cmd.Connection=Connection;
  cmd.CommandText = cmdText;
  if (cmdParms != null) 
  {
   foreach (OracleParameter parm in cmdParms)
   cmd.Parameters.Add(parm);
  }
  int val = cmd.ExecuteNonQuery();
  cmd.Parameters.Clear();
  //conn.CloseConn();
  return val;
  }
  #endregion
 }
 }

使用時可將上述程式碼儲存成oracle_dbconn.cs檔案，再進行呼叫。

本文所述為C#實現的Oracle資料庫操作類，可執行超多常用的Oracle資料庫操作，包含了基礎資料庫連線、關閉連線、輸出記錄集、執行Sql語句，返回帶分頁功能的dataset 、取表裡欄位的型別和長度等，同時還有哈稀表自動插入資料庫等高階任務。需要特別指出的是：在執行SQL語句，返回 DataReader之前一定要先用.read()開啟,然後才能讀到資料，再用hashTable對資料庫進行insert,update,del操作,注意此時只能用預設的資料庫連線"connstr"。

完整的C# Oracle資料庫類例項程式碼如下：

using System;
using System.Data;
using System.Data.OracleClient;
using System.Collections;
using System.Reflection;
namespace MyOraComm
{
 /// ConnDbForOracle 的摘要說明。
 public class ConnForOracle
 {
  protected OracleConnection Connection;
  private string connectionString;
  public ConnForOracle()
  {
  string connStr;
  connStr = System.Configuration.ConfigurationSettings.AppSettings["connStr"].ToString();
  connectionString = connStr;
  Connection = new OracleConnection(connectionString);
  }
 
  #region 帶引數的建構函式 
  /// 帶引數的建構函式
  /// 資料庫聯接字串
  public ConnForOracle(string ConnString)
  {
  string connStr;
  connStr = System.Configuration.ConfigurationSettings.AppSettings[ConnString].ToString();
  Connection = new OracleConnection(connStr);
  }
  #endregion

  #region 開啟資料庫 
  /// 開啟資料庫
  public void OpenConn()
  {
  if(this.Connection.State!=ConnectionState.Open)
   this.Connection.Open();
  }
  #endregion
  #region 關閉資料庫聯接 
  /// 關閉資料庫聯接
  public void CloseConn()
  {
  if(Connection.State==ConnectionState.Open)
   Connection.Close();
  }
  #endregion

  #region 執行SQL語句，返回資料到DataSet中
  /// 執行SQL語句，返回資料到DataSet中
  /// sql語句
  /// 自定義返回的DataSet表名
  /// 返回DataSet
  public DataSet ReturnDataSet(string sql,string DataSetName)
  {
  DataSet dataSet=new DataSet();
  OpenConn();
  OracleDataAdapter OraDA=new OracleDataAdapter(sql,Connection);
  OraDA.Fill(dataSet,DataSetName);
  //  CloseConn();
  return dataSet;
  }
  #endregion

  #region 執行Sql語句,返回帶分頁功能的dataset 
  /// 執行Sql語句,返回帶分頁功能的dataset
  /// Sql語句
  /// 每頁顯示記錄數
  /// <當前頁/param>
  /// 返回dataset表名
  /// 返回DataSet
  public DataSet ReturnDataSet(string sql,int PageSize,int CurrPageIndex,string DataSetName)
  {
  DataSet dataSet=new DataSet();
  OpenConn();
  OracleDataAdapter OraDA=new OracleDataAdapter(sql,Connection);
  OraDA.Fill(dataSet,PageSize * (CurrPageIndex - 1), PageSize,DataSetName);
  //  CloseConn();
  return dataSet;
  }
  #endregion

  #region 執行SQL語句，返回 DataReader,用之前一定要先.read()開啟,然後才能讀到資料
  /// 執行SQL語句，返回 DataReader,用之前一定要先.read()開啟,然後才能讀到資料 
  /// sql語句
  /// 返回一個OracleDataReader
  public OracleDataReader ReturnDataReader(String sql)
  {
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  return command.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
  }
  #endregion

  #region 執行SQL語句，返回記錄總數數
  /// 執行SQL語句，返回記錄總數數
  /// sql語句
  /// 返回記錄總條數
  public int GetRecordCount(string sql)
  {
  int recordCount = 0;
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  OracleDataReader dataReader = command.ExecuteReader();
  while(dataReader.Read())
  {
   recordCount++;
  }
  dataReader.Close();
  //CloseConn();
  return recordCount;
  }
  #endregion

  #region 取當前序列,條件為seq.nextval或seq.currval
  /// 
  /// 取當前序列
  public decimal GetSeq(string seqstr)
  {
  decimal seqnum = 0;
  string sql="select "+seqstr+" from dual";
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  OracleDataReader dataReader = command.ExecuteReader();
  if(dataReader.Read())
  {
   seqnum=decimal.Parse(dataReader[0].ToString());
  }
  dataReader.Close();
  //  CloseConn();
  return seqnum;
  }
  #endregion
  #region 執行SQL語句,返回所影響的行數
  /// 執行SQL語句,返回所影響的行數
  public int ExecuteSQL(string sql)
  {
  int Cmd=0;
  OpenConn();
  OracleCommand command = new OracleCommand(sql,Connection);
  try
  {
   Cmd =command.ExecuteNonQuery(); 
  }
  catch
  {
  }
  finally
  {
   //CloseConn();
  }
  return Cmd;
  }
  #endregion
 
  //＝＝用hashTable對資料庫進行insert,update,del操作,注意此時只能用預設的資料庫連線"connstr"
  #region 根據表名及哈稀表自動插入資料庫 用法：Insert("test",ht)
  public int Insert(string TableName,Hashtable ht)
  {
  OracleParameter[] Parms=new OracleParameter[ht.Count];
  IDictionaryEnumerator et = ht.GetEnumerator();
  DataTable dt=GetTabType(TableName);
  System.Data.OracleClient.OracleType otype;
  int size=0;
  int i=0;
  while ( et.MoveNext() ) // 作雜湊表迴圈
  {
   GetoType(et.Key.ToString().ToUpper(),dt,out otype,out size);
   System.Data.OracleClient.OracleParameter op=MakeParam(":"+et.Key.ToString(),otype,size,et.Value.ToString());
   Parms[i]=op; // 新增SqlParameter物件
   i=i+1;
  }
  string str_Sql=GetInsertSqlbyHt(TableName,ht); // 獲得插入sql語句
  int val=ExecuteNonQuery(str_Sql,Parms);
  return val;
  }
  #endregion
 
  #region 根據相關條件對資料庫進行更新操作 用法：Update("test","Id=:Id",ht); 
  public int Update(string TableName,string ht_Where, Hashtable ht)
  {
  OracleParameter[] Parms=new OracleParameter[ht.Count];
  IDictionaryEnumerator et = ht.GetEnumerator();
  DataTable dt=GetTabType(TableName);
  System.Data.OracleClient.OracleType otype;
  int size=0;
  int i=0;
  // 作雜湊表迴圈
  while ( et.MoveNext() )
  {
   GetoType(et.Key.ToString().ToUpper(),dt,out otype,out size);
   System.Data.OracleClient.OracleParameter op=MakeParam(":"+et.Key.ToString(),otype,size,et.Value.ToString());
   Parms[i]=op; // 新增SqlParameter物件
   i=i+1;
  }
  string str_Sql=GetUpdateSqlbyHt(TableName,ht_Where,ht); // 獲得插入sql語句
  int val=ExecuteNonQuery(str_Sql,Parms);
  return val;
  }
  #endregion
 
  #region del操作,注意此處條件個數與hash裡引數個數應該一致 用法：Del("test","Id=:Id",ht)
  public int Del(string TableName,string ht_Where,Hashtable ht)
  {
  OracleParameter[] Parms=new OracleParameter[ht.Count];
  IDictionaryEnumerator et = ht.GetEnumerator();
  DataTable dt=GetTabType(TableName);
  System.Data.OracleClient.OracleType otype;
  int i=0;
  int size=0;
  // 作雜湊表迴圈
  while ( et.MoveNext() )
  {
   GetoType(et.Key.ToString().ToUpper(),dt,out otype,out size);
   System.Data.OracleClient.OracleParameter op=MakeParam(":"+et.Key.ToString(),et.Value.ToString());
   Parms[i]=op; // 新增SqlParameter物件
   i=i+1;
  }
  string str_Sql=GetDelSqlbyHt(TableName,ht_Where,ht); // 獲得刪除sql語句
  int val=ExecuteNonQuery(str_Sql,Parms);
  return val;
  }
  #endregion 

  //　＝＝＝＝＝＝＝＝上面三個操作的內部呼叫函式＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

  #region 根據哈稀表及表名自動生成相應insert語句(引數型別的)
  /// 根據哈稀表及表名自動生成相應insert語句 
  /// 要插入的表名
  /// 哈稀表
  /// 返回sql語句
  public static string GetInsertSqlbyHt(string TableName,Hashtable ht)
  {
  string str_Sql="";
  int i=0;
  int ht_Count=ht.Count; // 雜湊表個數
  IDictionaryEnumerator myEnumerator = ht.GetEnumerator();
  string before="";
  string behide="";
  while ( myEnumerator.MoveNext() )
  {
   if (i==0)
   {
   before="("+myEnumerator.Key;
   }
   else if (i+1==ht_Count)
   {
   before=before+","+myEnumerator.Key+")";
   }
   else
   {
   before=before+","+myEnumerator.Key;
   }
   i=i+1;
  }
  behide=" Values"+before.Replace(",",",:").Replace("(","(:");
  str_Sql="Insert into "+TableName+before+behide;
  return str_Sql;
  }
  #endregion

  #region 根據表名，where條件，哈稀表自動生成更新語句(引數型別的)
  public static string GetUpdateSqlbyHt(string Table,string ht_Where,Hashtable ht)
  {
  string str_Sql="";
  int i=0;
  int ht_Count=ht.Count; // 雜湊表個數
  IDictionaryEnumerator myEnumerator = ht.GetEnumerator();
  while ( myEnumerator.MoveNext() )
  {
   if (i==0)
   {
   if (ht_Where.ToString().ToLower().IndexOf((myEnumerator.Key+"=:"+myEnumerator.Key).ToLower())==-1)
   {
    str_Sql=myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   else
   {
   if (ht_Where.ToString().ToLower().IndexOf((":"+myEnumerator.Key+" ").ToLower())==-1)
   {
    str_Sql=str_Sql+","+myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   i=i+1;
  }
  if (ht_Where==null || ht_Where.Replace(" ","")=="") // 更新時候沒有條件
  {
   str_Sql="update "+Table+" set "+str_Sql;
  }
  else
  {
   str_Sql="update "+Table+" set "+str_Sql+" where "+ht_Where;
  }
  str_Sql=str_Sql.Replace("set ,","set ").Replace("update ,","update ");
  return str_Sql;
  }
  #endregion

  #region 根據表名，where條件，哈稀表自動生成del語句(引數型別的)
  public static string GetDelSqlbyHt(string Table,string ht_Where,Hashtable ht)
  {
  string str_Sql="";
  int i=0;
  
  int ht_Count=ht.Count; // 雜湊表個數
  IDictionaryEnumerator myEnumerator = ht.GetEnumerator();
  while ( myEnumerator.MoveNext() )
  {
   if (i==0)
   {
   if (ht_Where.ToString().ToLower().IndexOf((myEnumerator.Key+"=:"+myEnumerator.Key).ToLower())==-1)
   {
    str_Sql=myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   else
   {
   if (ht_Where.ToString().ToLower().IndexOf((":"+myEnumerator.Key+" ").ToLower())==-1)
   {
    str_Sql=str_Sql+","+myEnumerator.Key+"=:"+myEnumerator.Key;
   }
   }
   i=i+1;
  }
  if (ht_Where==null || ht_Where.Replace(" ","")=="") // 更新時候沒有條件
  {
   str_Sql="Delete "+Table;
  }
  else
  {
   str_Sql="Delete "+Table+" where "+ht_Where;
  }
  return str_Sql;
  }
  #endregion

  #region 生成oracle引數
  /// 
  /// 生成oracle引數
  /// 欄位名
  /// 資料型別
  /// 資料大小
  /// 值
  public static OracleParameter MakeParam(string ParamName,System.Data.OracleClient.OracleType otype,int size,Object Value) 
  {
  OracleParameter para=new OracleParameter(ParamName,Value);
  para.OracleType=otype;
  para.Size=size;
  return para;
  }
  #endregion
  #region 生成oracle引數
  public static OracleParameter MakeParam(string ParamName,string Value) 
  {
  return new OracleParameter(ParamName, Value);
  }
  #endregion
  #region 根據表結構欄位的型別和長度拼裝oracle sql語句引數
  public static void GetoType(string key,DataTable dt,out System.Data.OracleClient.OracleType otype,out int size)
  {
  DataView dv=dt.DefaultView;
  dv.RowFilter="column_name='"+key+"'";
  string fType=dv[0]["data_type"].ToString().ToUpper();
  switch (fType)
  {
   case "DATE":
   otype= OracleType.DateTime;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "CHAR":
   otype= OracleType.Char;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "LONG":
   otype= OracleType.Double;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "NVARCHAR2":
   otype= OracleType.NVarChar;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   case "VARCHAR2":
   otype= OracleType.NVarChar;
   size=int.Parse(dv[0]["data_length"].ToString());
   break;
   default:
   otype= OracleType.NVarChar;
   size=100;
   break;
  }
  }
  #endregion
  #region動態 取表裡欄位的型別和長度,此處沒有動態用到connstr,是預設的！by/文少
  public System.Data.DataTable GetTabType(string tabnale)
  {
  string sql="select column_name,data_type,data_length from all_tab_columns where table_name='"+tabnale.ToUpper()+"'";
  OpenConn();
  return (ReturnDataSet(sql,"dv")).Tables[0];
  }
  #endregion
  #region 執行sql語句 
  public int ExecuteNonQuery(string cmdText, params OracleParameter[] cmdParms) 
  {
  OracleCommand cmd = new OracleCommand();
  OpenConn(); 
  cmd.Connection=Connection;
  cmd.CommandText = cmdText;
  if (cmdParms != null) 
  {
   foreach (OracleParameter parm in cmdParms)
   cmd.Parameters.Add(parm);
  }
  int val = cmd.ExecuteNonQuery();
  cmd.Parameters.Clear();
  //conn.CloseConn();
  return val;
  }
  #endregion
 }
 }使用時可將上述程式碼儲存成oracle_dbconn.cs檔案，再進行呼叫。

相關推薦

C#連線oracle例項

本文所述為C#實現的Oracle資料庫操作類，可執行超多常用的Oracle資料庫操作，包含了基礎資料庫連線、關閉連線、輸出記錄集、執行Sql語句，返回帶分頁功能的dataset 、取表裡欄位的型別和長度等，同時還有哈稀表自動插入資料庫等高階任務。需要特別指出的是：在執行SQ

C#連線Oracle資料庫(直接引用dll使用)，查詢資料

    首先，下載Oracle.ManagedDataAccess.dll將其放到自己的專案中，然後引用。程式碼如下：      static void Main(string[] args)     &

C#連線Oracle資料庫通過儲存過程操作資料庫

之前筆者一直用C#連線SQL Server資料庫。近期由於工作需要，需要用C#連線Oracle資料庫，並且要通過儲存過程，來操作資料庫中的資料，實現增、刪、改、查（有分頁功能）功能。並且，為了今後對資料庫擴充套件方便，對現在的程式碼改動最小的情況下，實現資料庫的平穩切換，必須

C# 連線 Oracle 資料庫（三種方式：OracleClient、ODBC、OLEDB）

1、OracleClient //基於.NET 2.0，只有2.0中包含OracleClient using System; using System.Collections; using System.ComponentModel; using System.Data;

【.NET】C#連線oracle實現登入及查詢

C#中連線Oracle資料庫的方法有:微軟的System.Data.OracleClient (可直接引用，已過時)，Oracle的Oracle.DataAccess.Client (ODP.net;區分X86與X64) 和Oracle的Oracle.ManagedDataA

C#連線Oracle資料庫的方法(Oracle.DataAccess.Client也叫ODP.net)(重要)

官方下載地址（ODP.net）（中文）：http://www.oracle.com/technetwork/cn/topics/dotnet/downloads/index.html 官方下載地址（ODP.net）：http://www.oracle.com/technetwork/topics

C#連線Oracle 11g 無需安裝Oracle客戶端

1.首先到Oracle網站上下載ODAC 下載地址1：http://download.csdn.net/detail/easyboot/9456476 下載地址2：http://www.oracle.com/technetwork/topics/dotnet/downloa

C#連線Oracle資料庫的四種方法

            OleDbConnection conn = new OleDbConnection("Provider=MSDAORA.1;User ID=XXX;password=XXX;Data Source=XXX;Persist Security Info=False");  Provi

C# 連線Oracle 11g，（注：可少走彎路）

string connString = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=130.147.246.144)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=ECMS)));Persist Secur

C# 連線Oracle資料庫

資料庫 訪問 using System; using System.Data; using System.Collections.Generic; using Oracle.ManagedDataAccess.Client; namespace myTool {

C#連線Oracle資料庫的連線字串

Oracle XE     標準連線         Oracle XE(或者"Oracle Database 10g Express Edition")是一個簡單免費釋出的版本。 以下是語法格式： Driver=(Oracle in XEClient);dbq=111.21.31.99:1521/XE

ORA-12514:C#連線Oracle資料庫出錯

    如題，在連線甲骨文資料庫的時候出現了問題，顯示無法識別該連線符，連線程式碼如下：             string ConnectionString; string QueryString; Connection

C#連線Oracle資料庫字串(引入DLL)

需求：從一臺Oracle資料庫獲取資料，本以為是很簡單的事情，直接將原來的SqlClient換成OracleClient呼叫，結果遠沒自己想的簡單。要麼安裝Oracle客戶端，要麼安裝PLSQL。網上這方面搜尋後，太多的文章，還要不停的去測試。最後找個引入外部類庫的方式。這個DLL其實是Oracle為C#專門

JDBC連線Oracle資料庫例項

本文給出一個通過JDBC連線Oracle資料庫的例項，希望對JDBC初學者有所幫助。我沒有像很多例子那樣一個函式就把整個JDBC的操作全部完成，這樣的程式碼在企業專案開發中一般是不能通過稽核的，我現在工作的公司就對程式碼規範有嚴格要求。比如，“一個函式，只做一件事”。這意味著你不能把一大堆功能程式碼

C#呼叫oracle儲存過程最簡單的例項

              OracleParameter[] parameters={                                  new OracleParameter("paramin",OracleType.VarChar,20),                       

C#不安裝Oracle客戶端連線Oracle資料庫

方法如下：（環境：Vs2003+Oracle10g） 1、把instantclient-basic-win32-10.2.0.4.zip中的檔案解壓到指定位置(我本機是解壓到D:/fox，並命名為：instantclient)其內面應該包括:BASIC_README、oci.

c#使用2013連線Oracle資料庫

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.T

C++使用POCO庫連線oracle資料庫（ODBC）

POCO庫是個功能很強大的工具庫，這次專案中就用到了POCO庫中的DATA連線資料庫的方式，直接上程式碼！         //使用ODBC的方式連線oracle資料庫 ODBC::Connector::registerConnector();//註冊 Ses

C++通過OCILIB連線Oracle

先附上參考 http://blog.csdn.net/rznice/article/details/74466123 準備：1.ocilib，直接百度然後有個GitHub的連結，我這邊下的是ocilib-4.4.0-windows.zip 2.VS2012/15/17均可 3.Or

ASP.NET(C#) VS2010連線Oracle資料庫

    首先介紹個人環境：win7 + VS2010 + Oracle 11g Client （注意：我這裡只是安裝的client，如果安裝了整個資料庫也是可以的）  。     正題：    一.