using System;  
using System.Data;  
using System.Collections.Generic;  
using System.Configuration;  
using System.Data.OracleClient;  
using System.Text;  
using System.IO;  
  
/// <summary>  
/// Oracle数据库操作类  
/// </summary>  
internal static class OracleHelper  
{  
    //数据库连接字符串  
    private readonly static string connstr = ConfigurationManager.ConnectionStrings["ConnectionStrings"].ConnectionString;  
    /// <summary>  
    /// 执行数据库查询操作,返回受影响的行数  
    /// </summary>  
    /// <param name="cmdText">Oracle存储过程名称或PL/SQL命令</param>  
    /// <param name="commandParameters">命令参数集合</param>  
    /// <returns>当前查询操作影响的数据行数</returns>  
    internal static int ExecuteNonQuery(string cmdText, params OracleParameter[] commandParameters)  
    {  
        OracleCommand command = new OracleCommand();  
        OracleConnection connection = new OracleConnection(connstr);  
        int result = 0;  
  
        try  
        {  
            PrepareCommand(command, connection, null,CommandType.Text, cmdText, commandParameters);  
            result = command.ExecuteNonQuery();  
            command.Parameters.Clear();  
        }  
        catch  
        {  
            throw;  
        }  
        finally  
        {  
            command.Dispose();  
            connection.Close();  
            connection.Dispose();  
        }  
  
        return result;  
    }  
  
    /// <summary>  
    /// 执行数据库事务查询操作,返回受影响的行数  
    /// </summary>  
    /// <param name="transaction">数据库事务对象</param>  
    /// <param name="cmdType">Command类型</param>  
    /// <param name="cmdText">Oracle存储过程名称或PL/SQL命令</param>  
    /// <param name="commandParameters">命令参数集合</param>  
    /// <returns>当前事务查询操作影响的数据行数</returns>  
    internal static int ExecuteNonQuery(OracleTransaction transaction, CommandType cmdType, string cmdText, params OracleParameter[] commandParameters)  
    {  
        OracleCommand command = new OracleCommand();  
        OracleConnection connection = transaction.Connection;  
        int result = 0;  
  
        try  
        {  
            PrepareCommand(command, connection, transaction, cmdType, cmdText, commandParameters);  
            result = command.ExecuteNonQuery();  
            command.Parameters.Clear();  
        }  
        catch  
        {  
            throw;  
        }  
        finally  
        {  
            transaction.Dispose();  
            command.Dispose();  
            connection.Close();  
            connection.Dispose();  
        }  
  
        return result;  
    }  
  
    /// <summary>  
    /// 执行数据库查询操作,返回受影响的行数  
    /// </summary>  
    /// <param name="connection">Oracle数据库连接对象</param>  
    /// <param name="cmdType">Command类型</param>  
    /// <param name="cmdText">Oracle存储过程名称或PL/SQL命令</param>  
    /// <param name="commandParameters">命令参数集合</param>  
    /// <returns>当前查询操作影响的数据行数</returns>  
    internal static int ExecuteNonQuery(OracleConnection connection, CommandType cmdType, string cmdText, params OracleParameter[] commandParameters)  
    {  
        if (connection == null) throw new ArgumentNullException("当前数据库连接不存在");  
        OracleCommand command = new OracleCommand();  
        int result = 0;  
  
        try  
        {  
            PrepareCommand(command, connection, null, cmdType, cmdText, commandParameters);  
            result = command.ExecuteNonQuery();  
            command.Parameters.Clear();  
        }  
        catch  
        {  
            throw;  
        }  
        finally  
        {  
            command.Dispose