----------------------------------------------------------------------------------------------------------
-- PROCEDURE NAME : PROC_SYN_DATA
-- DESCRIPTION : 同步抽取数据
----------------------------------------------------------------------------------------------------------
IS
cnt INTEGER;
BEGIN

--判断表是否已存在,如果存在先删除
SELECT COUNT(*) INTO cnt FROM USER_TABLES WHERE TABLE_NAME = 'ETL_PRJ_CONTRACTPLANCOSTBILL';
IF cnt >0 THEN

EXECUTE IMMEDIATE 'DROP TABLE ETL_PRJ_CONTRACTPLANCOSTBILL';
   DBMS_OUTPUT.PUT_LINE('ETL_PRJ_CONTRACTPLANCOSTBILL表存在,删除成功!');
END IF;

SELECT COUNT(*) INTO cnt FROM USER_TABLES WHERE TABLE_NAME = 'ETL_PRJ_PRJCONTRACT';
IF cnt > 0 THEN
   EXECUTE IMMEDIATE 'DROP TABLE ETL_PRJ_PRJCONTRACT';
   DBMS_OUTPUT.PUT_LINE('ETL_PRJ_PRJCONTRACT表存在,删除成功!');
END IF;

--抽取数据并存储
EXECUTE IMMEDIATE 'CREATE TABLE ETL_PRJ_CONTRACTPLANCOSTBILL AS SELECT * FROM PBYL1030.CT_PRJ_CONTRACTPLANCOSTBILL@eas_220_dblink WHERE CFSTATE IN (''10'', ''25'', ''60'')'; --10:暂存、25:提交、60:生效
EXECUTE IMMEDIATE 'CREATE TABLE ETL_PRJ_PRJCONTRACT AS SELECT * FROM PBYL1030.CT_PRJ_PRJCONTRACT@eas_220_dblink WHERE CFSTATE = ''60'' ';

--增加同步时间字段
EXECUTE IMMEDIATE 'ALTER TABLE ETL_PRJ_CONTRACTPLANCOSTBILL ADD (CREATE_TIME DATE DEFAULT SYSDATE NOT NULL)';
EXECUTE IMMEDIATE 'ALTER TABLE ETL_PRJ_CONTRACTPLANCOSTBILL ADD (LAST_UPDATE_TIME DATE DEFAULT SYSDATE NOT NULL)';
EXECUTE IMMEDIATE 'ALTER TABLE ETL_PRJ_PRJCONTRACT ADD (CREATE_TIME DATE DEFAULT SYSDATE NOT NULL)';
EXECUTE IMMEDIATE 'ALTER TABLE ETL_PRJ_PRJCONTRACT ADD (LAST_UPDATE_TIME DATE DEFAULT SYSDATE NOT NULL)';

END  PROC_SYN_DATA;

从源数据库抽取数据到中间库相关推荐

  1. Oracle通过定时任务+dblink+存储过程传数据到中间库

    --- 1.先看看有没有 放临时表 的目录,没有创建下:或者改放其他目录 cd /usr/local/oracle/oradata--- 2.将目录所有者换成oracle chown -R oracl ...

  2. 通过OGG实现多源端数据库的数据集中分发

    来自:DBAplus社群 作者介绍 许珣,新炬网络数据库运维专家,OCP.拥有五年的Oracle数据库运维经验,精通OGG技术相关应用. 一.需求来源 自从阿里喊出"去IOE"的口 ...

  3. java查询oracle数据库_Oracle数据库之java 从Oracle数据库到处数据到Elasticsearch全文检索库进行全文查询...

    本文主要向大家介绍了Oracle数据库之java 从Oracle数据库到处数据到Elasticsearch全文检索库进行全文查询,通过具体的内容向大家展现,希望对大家学习Oracle数据库有所帮助. ...

  4. 数据库可视化库_漂亮的javascript数据可视化库

    数据库可视化库 If you're building a web app using JavaScript, it is inevitable that at some point you'll ne ...

  5. Linux GBase数据库登录、建库、导入sql数据

    Linux GBase数据库登录.建库.导入sql数据 连接GBase 建库 导入数据 连接GBase 进入安装目录 cd /opt/GBase/Server/bin 执行登录命令 -u 指定用户 - ...

  6. 数据库基础--数据库基础管理(创建库/表 以及插入修改删除表数据)

    1.啥子是数据库–存储数据的仓库 2.什么是数据–音乐,电影,文本,图片等 常见的数据库软件 Oracle 不开源 跨平台 厂商:甲骨文 MySQL 开源 跨平台 厂商:甲骨文 SQL Server ...

  7. 在MVC3中使用code first生成数据局库并操作数据库

    1.建立Users和UserInfos两个实体类 对应的是数据库中的表 public class User{//类名+Id(User+Id)组成的字符串在数据库表中会设置该字段是主键且是按1的增量增长 ...

  8. mysql从库数据源_SoapUI Pro教程:如何使用MySQL服务器作为数据源-从MySQL数据库获取数据...

    SoapUI Pro拥有许多其他web服务测试工具所不具备的高级技术和功能.对于REST.SOAP以及其他流行的API和物联网协议,SoapUI Pro提供了业界最全面的功能测试功能.通过易用的图形界 ...

  9. mysql 从库数据损坏_MySQL数据库中数据损坏恢复全过程

    MySQL数据库中数据损坏恢复全过程 前几天因为MySQL数据库部分数据损坏原因,我尝试了下恢复数据,之后整理以下文档,供各位参考,以备各位同事以后如有类似问题,可以少走些弯路,尽快解决问题. 环境: ...

最新文章

  1. 第一天写,希望能坚持下去。
  2. 写在马哥教育第八期开始之前
  3. thrift多平台安装
  4. 启明云端分享| 在应用启明云端sigmastar SSD201 / SSD202D核心板时,ISP烧录uboot遇到问题怎么解决呢
  5. log4j 新建日志 重启_Log4j 动态修改日志级别,不用重启服务器
  6. weblogic中数据源_如何在WebLogic Server中创建MySQL数据源
  7. 从零开始使用CodeArt实践最佳领域驱动开发(三)
  8. 最详细的equals和hashcode详解
  9. 计算机大赛软件应用与开发,我院学生在2019年中国大学生计算机设计大赛“软件应用与开发”决赛中荣获佳绩...
  10. C++_类和对象_C++继承_继承的方式_公共继承_保护继承_私有继承---C++语言工作笔记062
  11. python删除特定字符串之后的,如何删除字符串中某个字符后的所有内容?
  12. bzoj 2302: [HAOI2011]Problem c(DP)
  13. cmake的安装与基本使用
  14. docker腾讯云加速器
  15. java水果类用equal重量价格,Java基础练习题 附答案
  16. 单目标跟踪(模板更新)(UpdateNet)《Learning the Model Update for Siamese Trackers》
  17. 嵌入式与物联网的关系还是挺复杂的,去同存异分析一波
  18. python概率分布拟合_用Python实现概率分布
  19. win10快捷键【常用】桌面切换等快捷键
  20. 联通沃云开启80端口

热门文章

  1. macos 版本_如何检查您使用的macOS版本
  2. Outperform
  3. Angular NgModule
  4. C语言实现埃拉托色尼筛选法(剔除数组中的非质数)
  5. 正版鬼泣手游服务器,鬼泣手游
  6. Bob,我要怎样才能成为一名 iOS 开发者
  7. 英语笔记(单词来自Shiro文档)02
  8. 五面阿里拿下飞猪事业部offer,统统给你解决!
  9. 做了个抓取全网群二维码和个人二维码的平台
  10. Python数据提取-lxml模块