zoukankan      html  css  js  c++  java
  • Web重温系列(三):OracleDependency实现监听数据库变化

           有个小项目(后来由另一个小组以Java开发了),内容是监控一个Oracle数据库。如果其中一个表A有数据变动,则需要将相关内容重组后通过接口发送给B。

           通常的解决办法是定时查询,时间间隔可以小一点,还可以加上时间戳之类的,减少查询量。在与经常访问数据库的同事聊的过程,发现通过监听数据库的变动也是一种可行方案,于是准备尝试一下。

           查了一下,.Net对自己家SQL Server的监听用的是SQLDependency类,而Oracle的相应实现则是OracleDependency类,这个应该是ODP.Net的一部分。

      操作流程如下:

    1. 安装Oracle Developer Tools for Visual Studio

    下载页面时https://www.oracle.com/technetwork/developer-tools/visual-studio/downloads/index.html,下载前请确认自己的Visual Studio版本,我的2015;

      2. 在VS中创建项目,并利用NuGet包管理器安装Oracle.ManagedDataAccess

      3. 完善配置文件(特别是连接串)

    创建ADO.Net实体模型,选择Oracle 数据库 (ODP.NET, 托管驱动程序),然后选择TN或者ET方式链接。果是ET方式,输入服务器、端口、用户名和密码,创建成功后,连接字符串就自动设置好了;

      4. 创建命令并设置监听如下

      其中Properties.Settings.Default.OracleDevConnStr是连接字符串名字

           OracleConnection con1 = new OracleConnection(Properties.Settings.Default.OracleDevConnStr);
    
                var sql = "select * from ZQ";
                OracleCommand cmd1 = new OracleCommand(sql, con1);
    
                con1.Open();
    
                cmd1.AddRowid = true;
                OracleDependency dep = new OracleDependency(cmd1);
                cmd1.Notification.IsNotifiedOnce = false;
                dep.OnChange += OnDbChange;

      5. 处理OnDbChange事件

        

          private void OnDbChange(object sender, OracleNotificationEventArgs eventArgs)
            {
                //TODO:...
            }

      此外,如果阅读英文无障碍,可以查看如下链接https://www.oracle.com/webfolder/technetwork/tutorials/obe/db/hol08/dotnet/changenotification/odpnetchg_otn.htm

  • 相关阅读:
    Kafka 1.0.0集群安装
    java实现以docx格式导出
    基于java处理.docx格式的word合并
    基于java 合并.doc和docx格式的Word文件
    Docker版本Jenkins的使用
    Codeforces 1243 D 0-1 MST
    Public model for matrix
    Codeforces 1220 E Tourism
    Codeforces 1221 G Graph And Numbers
    Codeforces 1221 F Choose a Square
  • 原文地址:https://www.cnblogs.com/ceachy/p/OracleDependency.html
Copyright © 2011-2022 走看看