using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;
using System.Text;
using System.Data.OracleClient;/// <summary>
/// DB 的摘要说明
/// </summary>
public class Oracle_DB
{ public Oracle_DB()
{ } public int ExcuteSqlWithNoQuery(string vSql)
{
int vI = 0; OracleConnection vOracleConnection = OpenOraDBConn();
OracleCommand vOracleCommand = new OracleCommand(vSql, vOracleConnection);
try
{
vI = vOracleCommand.ExecuteNonQuery();
vOracleCommand.Dispose();
}
catch (OracleException ex)
{
throw ex;
}
finally
{
CloseOraDBConn(vOracleConnection); }
return vI;
} public int ExcuteSqlWithSingleNum(string vSql)
{
int vI = -9999;
OracleConnection vOracleConnection = OpenOraDBConn();
OracleCommand vOracleCommand = new OracleCommand(vSql, vOracleConnection);
OracleDataReader vOracleDataReader = vOracleCommand.ExecuteReader();
while (vOracleDataReader.Read())
{
vI = vOracleDataReader.GetInt32(0);
break;
}
vOracleDataReader.Close();
vOracleConnection.Close();
if (vI == -9999)
{
return -9999;
} return vI;
}
public string ExcuteSqlWithSingleString(string vSql)
{
string vTempStr = null;
OracleConnection vOracleConnection = OpenOraDBConn();
OracleCommand vOracleCommand = new OracleCommand(vSql, vOracleConnection);
OracleDataReader vOracleDataReader = vOracleCommand.ExecuteReader(); while (vOracleDataReader.Read())
{
vTempStr = vOracleDataReader.GetString(0);
break;
} vOracleDataReader.Close();
vOracleConnection.Close();
return vTempStr;
} public DataTable ExcuteSqlWithDataTable(string vSql)
{
DataTable vDataTable = new DataTable();
try
{
OracleDataAdapter vOracleDataAdapter = CreateOracleDataAdapter(vSql); vOracleDataAdapter.Fill(vDataTable);
vOracleDataAdapter.Dispose();
}
catch
{
return null;
} return vDataTable;
} public DataSet ExcuteSqlWithDataSet(string vSql, string vTableName)
{
OracleDataAdapter vOracleDataAdapter = CreateOracleDataAdapter(vSql);
DataSet vDataSet = new DataSet();
vOracleDataAdapter.Fill(vDataSet, vTableName);
vOracleDataAdapter.Dispose();
return vDataSet;
} private OracleConnection OpenOraDBConn()
{
string vConnStr = ConfigurationManager.AppSettings["CONNSTRING"].ToString();
OracleConnection vOracleConnection = new OracleConnection(vConnStr);
if (vOracleConnection.State != ConnectionState.Open)
{
vOracleConnection.Open();
}
return vOracleConnection;
}
private void CloseOraDBConn(OracleConnection vOracleConnection)
{
if (vOracleConnection.State == ConnectionState.Open)
{
vOracleConnection.Close();
}
}
private OracleDataAdapter CreateOracleDataAdapter(string vSql)
{
OracleConnection vOracleConnection = OpenOraDBConn();
OracleDataAdapter vOracleDataAdapter = new OracleDataAdapter(vSql, vOracleConnection);
CloseOraDBConn(vOracleConnection);
return vOracleDataAdapter;
} public string GetDateTimeNow()
{
return System.DateTime.Now.ToString("u").Replace("Z", "").Replace("z", "");
}
}
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;
using System.Text;
using System.Data.OracleClient;/// <summary>
/// DB 的摘要说明
/// </summary>
public class Oracle_DB
{ public Oracle_DB()
{ } public int ExcuteSqlWithNoQuery(string vSql)
{
int vI = 0; OracleConnection vOracleConnection = OpenOraDBConn();
OracleCommand vOracleCommand = new OracleCommand(vSql, vOracleConnection);
try
{
vI = vOracleCommand.ExecuteNonQuery();
vOracleCommand.Dispose();
}
catch (OracleException ex)
{
throw ex;
}
finally
{
CloseOraDBConn(vOracleConnection); }
return vI;
} public int ExcuteSqlWithSingleNum(string vSql)
{
int vI = -9999;
OracleConnection vOracleConnection = OpenOraDBConn();
OracleCommand vOracleCommand = new OracleCommand(vSql, vOracleConnection);
OracleDataReader vOracleDataReader = vOracleCommand.ExecuteReader();
while (vOracleDataReader.Read())
{
vI = vOracleDataReader.GetInt32(0);
break;
}
vOracleDataReader.Close();
vOracleConnection.Close();
if (vI == -9999)
{
return -9999;
} return vI;
}
public string ExcuteSqlWithSingleString(string vSql)
{
string vTempStr = null;
OracleConnection vOracleConnection = OpenOraDBConn();
OracleCommand vOracleCommand = new OracleCommand(vSql, vOracleConnection);
OracleDataReader vOracleDataReader = vOracleCommand.ExecuteReader(); while (vOracleDataReader.Read())
{
vTempStr = vOracleDataReader.GetString(0);
break;
} vOracleDataReader.Close();
vOracleConnection.Close();
return vTempStr;
} public DataTable ExcuteSqlWithDataTable(string vSql)
{
DataTable vDataTable = new DataTable();
try
{
OracleDataAdapter vOracleDataAdapter = CreateOracleDataAdapter(vSql); vOracleDataAdapter.Fill(vDataTable);
vOracleDataAdapter.Dispose();
}
catch
{
return null;
} return vDataTable;
} public DataSet ExcuteSqlWithDataSet(string vSql, string vTableName)
{
OracleDataAdapter vOracleDataAdapter = CreateOracleDataAdapter(vSql);
DataSet vDataSet = new DataSet();
vOracleDataAdapter.Fill(vDataSet, vTableName);
vOracleDataAdapter.Dispose();
return vDataSet;
} private OracleConnection OpenOraDBConn()
{
string vConnStr = ConfigurationManager.AppSettings["CONNSTRING"].ToString();
OracleConnection vOracleConnection = new OracleConnection(vConnStr);
if (vOracleConnection.State != ConnectionState.Open)
{
vOracleConnection.Open();
}
return vOracleConnection;
}
private void CloseOraDBConn(OracleConnection vOracleConnection)
{
if (vOracleConnection.State == ConnectionState.Open)
{
vOracleConnection.Close();
}
}
private OracleDataAdapter CreateOracleDataAdapter(string vSql)
{
OracleConnection vOracleConnection = OpenOraDBConn();
OracleDataAdapter vOracleDataAdapter = new OracleDataAdapter(vSql, vOracleConnection);
CloseOraDBConn(vOracleConnection);
return vOracleDataAdapter;
} public string GetDateTimeNow()
{
return System.DateTime.Now.ToString("u").Replace("Z", "").Replace("z", "");
}
}
FortuneBase里面有直接QueryForOracleDataTable等方法
参考地址www.cnblogs.com/mail-ricklee