- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Configuration;
- using System.Data;
- using Oracle.DataAccess.Client;
- using System.Runtime.InteropServices;
- using System.Text.RegularExpressions;
- using System.Diagnostics;
- using System.Data.Common;
- using System.Collections;
- namespace DB_Server
- {
- #region // 操作 Oracle 数据库
- public class OracleDBService
- {public OracleDBService(string ConnectionString)
- {
- OracleConStr = ConnectionString;
- }
- #region// 连接数据库所需变量及方法
- private string OracleConStr = "";
- private OracleConnection conn;// 创建 sql 连接
- private OracleCommand com;// 创建 sql 命令对象
- private OracleDataReader dr;// 创建 sql 数据阅读器
- private OracleDataAdapter sdr;// 创建 sql 适配器
- private DataSet ds;// 创建数据集
- /// <summary>
- /// 创建数据库连接并打开
- /// </summary>
- public void open()
- {
- // 创建连接
- conn = new OracleConnection(OracleConStr);
- if (conn.State == ConnectionState.Closed)
- {
- conn.Open();
- }
- else if (conn.State == ConnectionState.Broken)
- {
- conn.Close();
- conn.Open();
- }
- }
- #region// 事务操作数据库
- /// <summary>
- /// 提交一组 (多条)SQL 语句操作数据库
- /// </summary>
- /// <param name="commandStringList">SQL 列表 </param>
- /// <returns > 执行结果 </returns>
- public int UpdateBatchCommand(ArrayList commandStringList)
- {
- open();
- OracleTransaction m_OraTrans = conn.BeginTransaction();// 创建事务对象
- com = new OracleCommand();
- com.Connection = conn;
- string tmpStr = "";
- int influenceRowCount = 0;
- try
- {
- foreach (string commandString in commandStringList)
- {
- tmpStr = commandString;
- com.CommandText = tmpStr;
- influenceRowCount += com.ExecuteNonQuery();
- }
- m_OraTrans.Commit();
- return influenceRowCount;
- }
- catch (OracleException ex)
- {
- m_OraTrans.Rollback();
- throw ex;
- }
- }
- #endregion
来源: http://www.linuxidc.com/Linux/2018-05/152645.htm