Oracle.ManagedDataAccess.Client
为了简化oracle的操作，重新设计了新的client，即Oracle.ManagedDataAccess.Client。它跟以前的API差别很小，在使用时，需要添加命名空间using Oracle.ManagedDataAccess.Client;
OracleConnection 类
一个 OracleConnection对象，表示到 Oracle 数据库的一个连接
- 构造函数
OracleConnection()初始化OracleConnection的新实例
OracleConnection(String)使用字符串初始化OracleConnection类 - 两种初始化方法
string connstr = "data source=orcl;User Id =scott;Password =tiger";
OracleConnection conn = new OracleConnection(connstr);
OracleConnection conn = new OracleConnection();
conn.ConnectionString = "data source=orcl;User Id =scott;Password =tiger";
- 常用函数
-
conn.Open()使用指定的ConnectionString属性设置打开一个到数据库的连接 -
conn.Close()关闭与数据库的连接 -
conn.Dispose()释放占用的资源
- 常用属性
ConnectionString指定的连接字符串
OracleCommand 类
表示要对数据库执行的 SQL 语句或存储过程
- 构造函数
OracleCommand()初始化OracleCommand的新实例
OracleCommand(String)使用查询的文本初始化OracleCommand类的新实例
OracleCommand(String, OracleConnection)用文本和一个OracleConnection 创建新实例 - 常用属性
CommandTextSQL语句或存储过程的文本
ConnectionOracleCommand的此实例使用的OracleConnection - 两种初始化方法
OracleCommand cmd = new OracleCommand();
cmd.CommandText = "select * from gy_yonghuxx";
cmd.Connection = con;
text = "select * from gy_yonghuxx";
con = conn;
OracleCommand cmd = new OracleCommand(text, con);
- 常用函数
ExecuteReader()执行SELECT返回的行
ExecuteOracleNonQuery()执行 SQL 语句并返回受影响的行数
ExecuteNonQuery()执行 SQL INSERT、DELETE、UPDATE和SET等语句
OracleDataReader 类检索数据
常用属性
IsClosed指示是否OracleDataReader 已关闭
RecordsAffected执行更改、插入或删除等语句产生影响的行数
FieldCount获取当前行中的列数
HasRows指示OracleDataReader是否包含行常用函数
Close()关闭 OracleDataReader 对象
GetBoolean(Int32)以布尔值的形式获取指定列的值
GetByte(Int32)以字节的形式获取指定列的值
GetChar(Int32)字符的形式获取指定列的值
GetDateTime(Int32)以DateTime对象的形式获取指定列的值
GetDecimal(Int32)以Decimal对象的形式获取指定列的值
GetDouble(Int32)以双精度浮点数字的形式获取指定列的值
GetFloat(Int32)获取指定列的值作为单精度浮点数
GetInt16(Int32)16位有符号整数形式获取指定列的值
GetInt32(Int32)32位有符号整数形式获取指定列的值
GetInt64(Int32)64位有符号整数形式获取指定列的值
GetString(Int32)获取指定列的值作为字符串
GetName(Int32)获取指定列的名称
Read()前移 OracleDataReader 到下一个记录
ReadAsync()异步版本Read
NextResult()前移 OracleDataReader 到下一个结果
NextResultAsync()异步版本NextResult()举例
static void HasRows(SqlConnection connection)
{
using (connection)
{
SqlCommand command = new SqlCommand( "SELECT CategoryID, CategoryName FROM Categories;", connection);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
if (reader.HasRows)
{
while (reader.Read())
{
Console.WriteLine("{0}\t{1}", reader.GetInt32(0), reader.GetString(1));
}
}
else
{
Console.WriteLine("No rows found."); } reader.Close();
}
}
}
- 使用 NextResult 检索多个结果集
如果返回的是多个结果集，DataReader 会提供 NextResult 方法来按顺序循环访问这些结果集
static void RetrieveMultipleResults(SqlConnection connection)
{
using (connection)
{
SqlCommand command = new SqlCommand( "SELECT CategoryID, CategoryName FROM dbo.Categories;" + "SELECT EmployeeID, LastName FROM dbo.Employees", connection);
connection.Open();
SqlDataReader reader = command.ExecuteReader();
while (reader.HasRows)
{
Console.WriteLine("\t{0}\t{1}", reader.GetName(0), reader.GetName(1));
while (reader.Read())
{
Console.WriteLine("\t{0}\t{1}", reader.GetInt32(0), reader.GetString(1));
}
reader.NextResult(); }
}
}
- 注意事项
- 创建 OracleDataReader，必须调用 OracleCommand 对象的 ExecuteReader 方法， 而不能直接使用构造函数
- OracleDataReader 的用户可能会看到在读取数据时另一进程或线程对结果集所做的更改
- 当 OracleDataReader 关闭后，只能调用 IsClosed 和 RecordsAffected 属性
- 有些情况下，必须先调用 Close，然后才能调用 RecordsAffected
- 在任何给定的时间，可以打开多个 OracleDataReader
- 每次使用完 DataReader 对象后都应调用 Close 方法
使用拼接插入数据
public static int insert(int ruleId, int equipmentId, String equipmentName, String propertyName, int ruleType, String ruleRequest, String ruleRequestOther, String ruleExplain)
{
String sql = "insert into Device_Attr t(CA_ID,BASEID,BASENAME,CA_NAME,CA_RULETYPE,CA_RULETEXT,CA_RULETEXT2,t.CONTENT) values(" + ruleId + "," + equipmentId + ",'" + equipmentName + "$','" + propertyName + "','" + ruleType + "','" + ruleRequest + "','" + ruleRequestOther + "','" + ruleExplain + "')";
Console.WriteLine(sql);
OracleCommand oc = new OracleCommand(sql, conn);
int result = oc.ExecuteNonQuery();
return result;
}
动态SQL修改数据
public static int update(int ruleId, int equipmentId, String equipmentName, String propertyName, int ruleType, String ruleRequest, String ruleRequestOther, String ruleExplain)
{
String sql = "update Device_Attr t set t.BASEID = :equipmentId, t.BASENAME = :equipmentName,t.CA_NAME = :propertyName,t.CA_RULETYPE = :ruleType,t.CA_RULETEXT = :ruleRequest,t.CA_RULETEXT2 = :ruleRequestOther,t.CONTENT = :ruleExplain where t.CA_ID =:ruleId";
OracleCommand cmd = new OracleCommand(sql, conn);
OracleParameter param_1 = new OracleParameter(":equipmentId", equipmentId);
cmd.Parameters.Add(param_1);
OracleParameter param_2 = new OracleParameter(":equipmentName", equipmentName + "$");
cmd.Parameters.Add(param_2);
OracleParameter param_3 = new OracleParameter(":propertyName", propertyName);
cmd.Parameters.Add(param_3);
OracleParameter param_4 = new OracleParameter(":ruleType", ruleType);
cmd.Parameters.Add(param_4);
OracleParameter param_5 = new OracleParameter(":ruleRequest", ruleRequest);
cmd.Parameters.Add(param_5);
OracleParameter param_6 = new OracleParameter(":ruleRequestOther", ruleRequestOther);
cmd.Parameters.Add(param_6);
OracleParameter param_7 = new OracleParameter(":ruleExplain", ruleExplain);
cmd.Parameters.Add(param_7);
OracleParameter param_8 = new OracleParameter(":ruleId", ruleId);
cmd.Parameters.Add(param_8);
int result = cmd.ExecuteNonQuery();
return result;
}
例子
OracleConnection con = new OracleConnection();
con.ConnectionString = "user id=his3;password=his3;data source=192.168.1.237/ORCL";
con.Open();
OracleCommand cmd = new OracleCommand();
cmd.CommandType = System.Data.CommandType.Text;
cmd.CommandText = "select * from gy_yonghuxx";
cmd.Connection = con;
OracleDataAdapter da = new OracleDataAdapter();
da.SelectCommand = cmd;
DataSet ds = new DataSet();
da.Fill(ds);
con.Close();
da.Dispose();
cmd.Dispose();
con.Dispose();
