oracle数据库连接

以上是oracle数据库的连接字符串 name：连接字符串名

connectionString：连接字符串

Data Souuce：本地机：就是数据库名；远程机子：如果在本地装有oracle数据库的客户端则也是数据库名，否则参考网络资源要加一个域。 User ID：用户名 文件

******************************************************************************* using System; using ; using ; using ; using ; using

onnectionString;

public OraDBHelper() { }

#region 建立数据库连接对象 ///

/// 返回一个数据库的连接OracleConnection对象 public static OracleConnection init() { try {

conn = new OracleConnection(connstr); if != { (); } }

catch (Exception e) {

throw new Exception } return conn; }

#endregion

#region 设置OracleCommand对象 ///

/// OracleCommand对象 /// 命令文本 /// 命令类型 2

/// 参数集合

private static void SetCommand(OracleCommand cmd, string cmdText, CommandType cmdType, OracleParameter[] cmdParms) {

= conn; = cmdText; = cmdType;

if (cmdParms != null) {

} }

#endregion

#region 执行相应的sql语句，返回相应的DataSet对象 ///

/// sql语句 /// 返回相应的DataSet对象 public static DataSet GetDataSet(string sqlstr) {

DataSet set = new DataSet(); try {

init();

OracleDataAdapter adp = new OracleDataAdapter(sqlstr, conn); (set); 3

(); }

catch (Exception e) {

throw new Exception } return set; }

#endregion

#region 执行相应的sql语句，返回相应的DataSet对象 ///

/// sql语句 /// 表名 /// 返回相应的DataSet对象

public static DataSet GetDataSet(string sqlstr, string tableName) {

DataSet set = new DataSet(); try {

init();

OracleDataAdapter adp = new OracleDataAdapter(sqlstr, conn); (set, tableName); (); }

catch (Exception e) 4

{

throw new Exception } return set; }

#endregion

#region 执行不带参数sql语句，返回所影响的行数 ///

/// 增，删，改sql语句 /// 返回所影响的行数 public static int ExecuteNonQuery(string cmdText) {

int count; try {

init();

cmd = new OracleCommand(cmdText, conn); count = (); (); }

catch (Exception ex) {

throw new Exception } return count; } 5

#endregion

#region 执行带参数sql语句或存储过程，返回所影响的行数 ///

/// 带参数的sql语句和存储过程名 /// 命令类型 /// 参数集合 /// 返回所影响的行数

public static int ExecuteNonQuery(string cmdText, CommandType cmdType, OracleParameter[] cmdParms) {

int count; try {

init();

cmd = new OracleCommand();

SetCommand(cmd, cmdText, cmdType, cmdParms); count = (); (); }

catch (Exception ex) {

throw new Exception } return count; } 6

#endregion

#region 执行不带参数sql语句，返回一个从数据源读取数据的OracleDataReader对象

///

/// 相应的sql语句

/// 返回一个从数据源读取数据的OracleDataReader对象 public static OracleDataReader ExecuteReader(string cmdText) {

OracleDataReader reader; try {

init();

cmd = new OracleCommand(cmdText, conn); reader = ;

}

catch (Exception ex) {

throw new Exception } return reader; }

#endregion

#region 执行带参数的sql语句或存储过程，返回一个从数据源读取数据的7

OracleDataReader对象 ///

/// sql语句或存储过程名 /// 命令类型 /// 参数集合

/// 返回一个从数据源读取数据的OracleDataReader对象 public static OracleDataReader ExecuteReader(string cmdText, CommandType cmdType, OracleParameter[] cmdParms) {

OracleDataReader reader; try {

init();

cmd = new OracleCommand();

SetCommand(cmd, cmdText, cmdType, cmdParms); reader = ; }

catch (Exception ex) {

throw new Exception } return reader; }

#endregion 8

#region 执行不带参数sql语句,返回结果集首行首列的值object ///

/// 相应的sql语句 /// 返回结果集首行首列的值object public static object ExecuteScalar(string cmdText) {

object obj; try {

init();

cmd = new OracleCommand(cmdText, conn); obj = (); (); }

catch (Exception ex) {

throw new Exception } return obj; }

#endregion

#region 执行带参数sql语句或存储过程,返回结果集首行首列的值object ///

/// sql语句或存储过程名 /// 命令类型

/// 返回结果集首行首列的值object ///

public static object ExecuteScalar(string cmdText, CommandType cmdType, OracleParameter[] cmdParms) {

object obj; try {

init();

cmd = new OracleCommand();

SetCommand(cmd, cmdText, cmdType, cmdParms); obj = (); (); }

catch (Exception ex) {

throw new Exception } return obj; }

#endregion }

这是oracle数据库的一个DBHelp类，方法参考来源于网络

10