ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

在.NetCore(C#)中使用ODP.NET Core+Dapper操作Oracle数据库

2021-05-24 19:04:43  阅读:170  来源: 互联网

标签:Core name NetCore C# var Oracle new Dapper connStr


前言
虽然一直在说“去IOE化”,但是在国企和政府,Oracle的历史包袱实在太重了,甚至很多业务逻辑都是写在Oracle的各种存储过程里面实现的……

我们的系统主要的技术栈是Django / Spring / AspNetCore,Java的不必说对Oracle支持肯定没问题,关键在于Django对Oracle版本有要求,兼容性不是特别好,Oracle版本没办法随意升级的,所以我想到用.Net Core来写个中间层,让其他系统可以方便的使用Oracle的数据和存储过程…


 
ODP.NET Core是一个ADO.NET驱动程序,提供从Microsoft .NET Core客户端到Oracle数据库的快速数据访问。它可以在Windows和Linux上运行。ODP.NET由一个100%托管代码动态链接库Oracle.ManagedDataAccess.dll组成,可通过NuGet安装获得。

这个 Oracle.ManagedDataAccess.Core 是真的方便,不用安装Oracle客户端,兼容性、便捷性,反正就是开箱即用,一把梭就完事了

简单使用
首先用nuget安装这个 Oracle.ManagedDataAccess.Core ,之后就可以执各类操作了,不过从代码量上看还是比较繁琐的,上代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
var connStr = $"DATA SOURCE=127.0.0.1/db_name; PASSWORD=password; PERSIST SECURITY INFO=True; USER ID=user_id";
using (var conn = new OracleConnection(connStr)) {
  using (var command = conn.CreateCommand()) {
    try {
      if (conn.State == ConnectionState.Closed) {
        conn.Open();
      }
 
      command.BindByName = true;
      command.CommandText = $"select * from table_name";
 
      using (var reader = command.ExecuteReader()) {
        while (reader.Read()) {
          Console.WriteLine(reader.GetString("DEPART_NAME"));
        }
      }
    }
    catch (Exception ex) {
      Console.WriteLine(ex.StackTrace);
      Console.WriteLine(ex.Source);
      Console.WriteLine(ex.Message);
    }
  }
}
这就是执行 select * from table_name 这条SQL语句的代码,有点长…… 吐了

再看看执行存储过程的…

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
var connStr = $"DATA SOURCE=127.0.0.1/db_name; PASSWORD=password; PERSIST SECURITY INFO=True; USER ID=user_id";
using (var conn = new OracleConnection(connStr)) {
  conn.Open();
  var command = new OracleCommand("proc_name", conn) {
    CommandType = CommandType.StoredProcedure
  };
 
  // 输入参数
  command.Parameters.Add(new OracleParameter("id", "0001"));
 
  // 输出参数
  var vOut = new OracleParameter("v_out",
    OracleDbType.Varchar2,
    1000,
    "",
    ParameterDirection.InputOutput
  );
 
  command.Parameters.Add(vOut);
 
  var affectRows = command.ExecuteNonQuery();
 
  Console.WriteLine(vOut.Value);
}
这里去掉了错误处理,显得短一点,不过还是麻烦得不行……

所以这里我们要用Dapper这个轻量级ORM来简化操作

使用Dapper
不多说,首先nuget安装是常规操作,包名就是简单的 Dapper 。

首先是增删改查这类普通的SQL语句:

1
2
3
4
5
6
7
8
9
10
using Dapper;
 
var connStr = $"DATA SOURCE=127.0.0.1/db_name; PASSWORD=password; PERSIST SECURITY INFO=True; USER ID=user_id";
using var cn = new OracleConnection(connStr);
 
var result = cn.Query("select * from table_name");
 
foreach (var item in result) {
  Console.WriteLine(item);
}
可以看到引入Dapper之后只要使用 OracleConnection 的扩展方法 Query 来执行SQL就行了~ 返回的结果是 IEnumerable<dynamic> 类型,当然你也可以在 Query 方法的泛型参数里指定返回的类型,我这里为了通用就不指定了

继续看存储过程的,很简单,更上面的差不多,就多一个参数告诉程序我们的SQL类型是啥而已

1
2
3
4
5
6
7
8
var connStr = $"DATA SOURCE=127.0.0.1/db_name; PASSWORD=password; PERSIST SECURITY INFO=True; USER ID=user_id";
using var cn = new OracleConnection(connStr);
 
var result = cn.Query("proc_name", commandType: CommandType.StoredProcedure);
 
foreach (var item in result) {
  Console.WriteLine(item);
}
如果是有带参数的存储过程咋办?

很简单(代码来自官方例子)~

1
2
var user = cnn.Query<User>("spGetUser", new {Id = 1},
    commandType: CommandType.StoredProcedure).SingleOrDefault();
ok,很方便,更多操作看Dapper文档就完事了(我也是第一次接触Dapper,之前都用FreeSQL和EFCore),此文完结~

标签:Core,name,NetCore,C#,var,Oracle,new,Dapper,connStr
来源: https://blog.csdn.net/weixin_55025557/article/details/117229712

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有