用C#来操作ORACLE数据库Word文档下载推荐.docx

用C#来操作ORACLE数据库Word文档下载推荐.docx

《用C#来操作ORACLE数据库Word文档下载推荐.docx》由会员分享，可在线阅读，更多相关《用C#来操作ORACLE数据库Word文档下载推荐.docx（15页珍藏版）》请在冰点文库上搜索。

//数据库连接字符串（web.config来配置）

//<

addkey="

ConnectionString"

value="

server=127.0.0.1;

database=DATABASE;

uid=sa;

pwd="

/>

protectedstaticstringconnectionString=ConfigurationSettings.AppSettings["

];

publicDbHelperOra（）

{ 

}

#region公用方法

publicstaticintGetMaxID（stringFieldName,stringTableName）

{

stringstrsql="

selectmax（"

+FieldName+"

）+1from"

+TableName;

objectobj=GetSingle（strsql）;

if（obj==null）

return1;

else

returnint.Parse（obj.ToString（））;

publicstaticboolExists（stringstrSql,paramsSqlParameter[]cmdParms）

objectobj=GetSingle（strSql,cmdParms）;

intcmdresult;

if（（Object.Equals（obj,null））||（Object.Equals（obj,System.DBNull.Value）））

cmdresult=0;

cmdresult=int.Parse（obj.ToString（））;

if（cmdresult==0）

returnfalse;

returntrue;

#endregion

#region 

执行简单SQL语句

///<

///执行SQL语句，返回影响的记录数

paramname="

SQLString"

>

SQL语句<

/param>

returns>

影响的记录数<

/returns>

publicstaticintExecuteSql（stringSQLString）

using（OracleConnectionconnection=newOracleConnection（connectionString））

using（OracleCommandcmd=newOracleCommand（SQLString,connection））

try

connection.Open（）;

introws=cmd.ExecuteNonQuery（）;

returnrows;

catch（System.Data.OracleClient.OracleExceptionE）

connection.Close（）;

thrownewException（E.Message）;

} 

///执行多条SQL语句，实现数据库事务。

SQLStringList"

多条SQL语句<

publicstaticvoidExecuteSqlTran（ArrayListSQLStringList）

using（OracleConnectionconn=newOracleConnection（connectionString））

conn.Open（）;

OracleCommandcmd=newOracleCommand（）;

cmd.Connection=conn;

OracleTransactiontx=conn.BeginTransaction（）;

cmd.Transaction=tx;

for（intn=0;

n<

SQLStringList.Count;

n++）

stringstrsql=SQLStringList[n].ToString（）;

if（strsql.Trim（）.Length>

1）

cmd.CommandText=strsql;

cmd.ExecuteNonQuery（）;

tx.Commit（）;

tx.Rollback（）;

///执行带一个存储过程参数的的SQL语句。

content"

参数内容,比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加<

publicstaticintExecuteSql（stringSQLString,stringcontent）

OracleCommandcmd=newOracleCommand（SQLString,connection）;

System.Data.OracleClient.OracleParameter 

myParameter=newSystem.Data.OracleClient.OracleParameter（"

@content"

OracleDbType.NText）;

myParameter.Value=content;

cmd.Parameters.Add（myParameter）;

finally

cmd.Dispose（）;

}

///向数据库里插入图像格式的字段（和上面情况类似的另一种实例）

strSQL"

fs"

图像字节,数据库的字段类型为image的情况<

publicstaticintExecuteSqlInsertImg（stringstrSQL,byte[]fs）

OracleCommandcmd=newOracleCommand（strSQL,connection）;

@fs"

OracleDbType.Image）;

myParameter.Value=fs;

///执行一条计算查询结果语句，返回查询结果（object）。

计算查询结果语句<

查询结果（object）<

publicstaticobjectGetSingle（stringSQLString）

using（OracleCommandcmd=newOracleCommand（SQLString,connection））

objectobj=cmd.ExecuteScalar（）;

if（（Object.Equals（obj,null））||（Object.Equals（obj,System.DBNull.Value）））

returnnull;

returnobj;

catch（System.Data.OracleClient.OracleExceptione）

thrownewException（e.Message）;

///执行查询语句，返回OracleDataReader

查询语句<

OracleDataReader<

publicstaticOracleDataReaderExecuteReader（stringstrSQL）

OracleConnectionconnection=newOracleConnection（connectionString）;

OracleDataReadermyReader=cmd.ExecuteReader（）;

returnmyReader;

///执行查询语句，返回DataSet

DataSet<

publicstaticDataSetQuery（stringSQLString）

DataSetds=newDataSet（）;

OracleDataAdaptercommand=newOracleDataAdapter（SQLString,connection）;

command.Fill（ds,"

ds"

）;

catch（System.Data.OracleClient.OracleExceptionex）

thrownewException（ex.Message）;

returnds;

#region执行带参数的SQL语句

publicstaticintExecuteSql（stringSQLString,paramsOracleParameter[]cmdParms）

using（OracleCommandcmd=newOracleCommand（））

PrepareCommand（cmd,connection,null,SQLString,cmdParms）;

cmd.Parameters.Clear（）;

SQL语句的哈希表（key为sql语句，value是该语句的OracleParameter[]）<

publicstaticvoidExecuteSqlTran（HashtableSQLStringList）

using（OracleTransactiontrans=conn.BeginTransaction（））

try

//循环

foreach（DictionaryEntrymyDEinSQLStringList）

{

string 

cmdText=myDE.Key.ToString（）;

OracleParameter[]cmdParms=（OracleParameter[]）myDE.Value;

PrepareCommand（cmd,conn,trans,cmdText,cmdParms）;

intval=cmd.ExecuteNonQuery（）;

trans.Commit（）;

catch

trans.Rollback（）;

throw;

publicstaticobjectGetSingle（stringSQLString,paramsOracleParameter[]cmdParms）

publicstaticOracleDataReaderExecuteReader（stringSQLString,par