You need to enable JavaScript to run this app.
文档中心
大数据研发治理套件(私有化)

大数据研发治理套件(私有化)

复制全文
Oracle 引擎
Oracle SQL
复制全文
Oracle SQL

Oracle 数据库支持结构化查询语言(SQL),是可用于管理和处理数据的标准数据库。
下文将为您介绍通过 DataLeap 创建 Oracle SQL 节点,使用 SQL 语句,周期性的在 Oracle 集群中进行数据加工、查询、分析等操作。

使用前提

  1. DataLeap 目前支持 Oracle 11g、12c 两个版本。
  2. 新建DataLeap项目时,已在引擎服务绑定设置中,勾选 Oracle 数据库引擎。操作详见“新建项目”。

新建任务

  1. 登录DataLeap控制台。
  2. 选择数据开发 > 任务开发,进入任务开发页面。
  3. 单击新建任务 > 数据开发 > Oracle 引擎类型按钮。
  4. 选择离线数据 Oracle SQL 任务。
  5. 填写任务基本信息:
    1. 任务名称:输入任务的名称,只允许字符.、字母、数字、下划线、连字符、[]、【】、()、()以及中文字符,且需要在127个字符以内。
    2. 保存至: 选择任务存放的目标文件夹目录。
      Image
  6. 单击确定按钮,完成任务创建。

任务配置

任务创建完成后,您便可进入 Oracle SQL任务编辑界面,在配置界面中您可按需编写 Oracle 支持的SQL语法。

  1. 编辑任务
    在代码编辑器界面,输入对应 Oracle SQL语句,示例如下:

    --创建数据表
    CREATE TABLE students (
        id NUMBER PRIMARY KEY,
        name VARCHAR2(100) NOT NULL,
        age NUMBER CHECK (age >= 0)
    )
    --添加字段
    ALTER TABLE students ADD (gender CHAR(1),class VARCHAR2(20),address VARCHAR2(100))
    --插入数据
    INSERT INTO students (id, name, age, gender, class, address) VALUES (5, '孙七', 21, 'M', '一班', '北京市海淀区')
    INSERT INTO students (id, name, age, gender, class, address) VALUES (6, '孙八', 22, 'F', '一班', '北京市海淀区')
    --查询数据
    SELECT  * FROM (SELECT * FROM student_1126 WHERE CLASS = '一班' ) base WHERE base.age = 21
    

    下方为调用存储过程示例:

    1. 在调用之前,您需先在 Oracle 引擎数据库上定义好存储过程,引擎中定义示例语句如下:

      CREATE OR REPLACE PROCEDURE get_student_count_by_age(
          students_age IN NUMBER,
          students_count OUT NUMBER
      ) AS
      BEGIN
          SELECT  COUNT(*) INTO students_count
          FROM    students
          WHERE   age > students_age;
      END;
      
    2. 定义存储过程完成后,便可在 DataLeap Oracle SQL 任务中实现调用,示例如下:

      DECLARE
          input_age NUMBER := 18;
          output_count NUMBER;
      BEGIN
          get_student_count_by_age(input_age, output_count);
          DBMS_OUTPUT.PUT_LINE('年龄大于 ' || input_age ||'的学生数量为: ' || output_count);
      END;
      
  2. 格式化 Oracle SQL 语句
    代码编辑区编写完对应 SQL 语句后,您可单击上方导航栏功能区中的格式化按钮,依据在“个性化设置”中的 SQL 格式化风格的设置,格式化编辑完成的代码,使其语法结构看起来简洁明了。

  3. 调度设置
    任务配置完成后,在右侧导航栏中,单击调度配置按钮,配置调度设置相关参数,便可进行 Oracle SQL 任务周期性调度。调度设置说明详见“调度设置”。

查询控制台

  1. 调试任务
    任务代码逻辑和参数配置完成后,您可在编辑器上方,单击操作栏中的保存调试按钮,进行任务调试。

    说明

    调试操作,直接使用线上数据进行调试,需谨慎操作。

  2. 调试记录
    调试任务开始运行后,可在下方查看调试记录,您也可以查看任务的历史运行记录,包括状态、业务日期、开始时间、结束时间、耗时、提交人等。
    单击调试记录,可以查看以下详情内容:
    • 结果:展示代码执行后的查询结果。

      说明

      因结果页预览数据以及项目安全设置均存在限制,查询结果显示数据可能小于实际数据量。建议按如下处理方式:

      • 前往项目控制台,调整项目数据安全设置上限。
      • 项目管理控制台 > 项目配置 > 项目管控 > Select查询结果设置处,勾选允许下载,您便可在查询结果区域单击下载按钮,下载完整数据至本地查看。

      详见“新建项目”。

    • 概览:查看运行结果的代码。
    • 日志:查看运行详情,可下载日志。

提交任务

调试结果无误后,单击提交上线按钮,在提交上线对话框中,选择回溯数据、监控设置、提交设置等参数,最后单击确认按钮,完成作业提交。 提交上线说明详见:提交上线

注意

  • 调试操作,直接使用线上数据进行调试,需谨慎操作。
  • 如果租户项目管理员在项目控制台>流水线管理中启用了流水线流程校验,则您需要确保提交的任务符合流水线扩展程序的校验规则,才能成功提交。详见4 流水线管理

后续任务运维操作详见:离线任务运维

最近更新时间:2025.07.02 17:59:03
这个页面对您有帮助吗?
有用
有用
无用
无用