Method sqlxAction

core/session.ts:120–247

(actionOptions: {
    // sqlxConfig has type any here because any object can be passed in from the compiler - the
    // structure of it is verified at later steps.
    sqlxConfig: any;
    sqlStatementCount: number;
    sqlContextable: (
      ctx:
        | TableContext
        | AssertionContext
        | OperationContext
        | DataPreparationContext
        | IActionContext
    ) => string[];
    incrementalWhereContextable: (ctx: ITableContext) => string;
    preOperationsContextable: (ctx: ITableContext) => string[];
    postOperationsContextable: (ctx: ITableContext) => string[];
    inputContextables: [
      {
        refName: string[];
        contextable: (ctx: IActionContext) => string;
      }
    ];
  })

  }

  public sqlxAction(actionOptions: {
    // sqlxConfig has type any here because any object can be passed in from the compiler - the
    // structure of it is verified at later steps.
    sqlxConfig: any;
    sqlStatementCount: number;
    sqlContextable: (
      ctx:
        | TableContext
        | AssertionContext
        | OperationContext
        | DataPreparationContext
        | IActionContext
    ) => string[];
    incrementalWhereContextable: (ctx: ITableContext) => string;
    preOperationsContextable: (ctx: ITableContext) => string[];
    postOperationsContextable: (ctx: ITableContext) => string[];
    inputContextables: [
      {
        refName: string[];
        contextable: (ctx: IActionContext) => string;
      }
    ];
  }) {
    const { sqlxConfig } = actionOptions;
    const actionType = sqlxConfig.hasOwnProperty("type") ? sqlxConfig.type : "operations";
    if (actionOptions.sqlStatementCount > 1 && actionType !== "operations") {
      this.compileError(
        "Actions may only contain more than one SQL statement if they are of type 'operations'."
      );
    }
    if (sqlxConfig.hasOwnProperty("protected") && actionType !== "incremental") {
      this.compileError(
        "Actions may only specify 'protected: true' if they are of type 'incremental'."
      );
    }
    if (actionOptions.incrementalWhereContextable && actionType !== "incremental") {
      this.compileError(
        "Actions may only include incremental_where if they are of type 'incremental'."
      );
    }
    if (actionOptions.inputContextables.length > 0 && actionType !== "test") {
      this.compileError("Actions may only include input blocks if they are of type 'test'.");
    }
    if (actionOptions.preOperationsContextable && !definesDataset(actionType)) {
      this.compileError("Actions may only include pre_operations if they create a dataset.");
    }
    if (actionOptions.postOperationsContextable && !definesDataset(actionType)) {
      this.compileError("Actions may only include post_operations if they create a dataset.");
    }

    if (!sqlxConfig.filename) {
      sqlxConfig.filename = utils.getCallerFile(this.rootDir);
    }

    switch (actionType) {
      case "view":
        const view = new View(this, sqlxConfig).query(ctx => actionOptions.sqlContextable(ctx)[0]);
        if (actionOptions.incrementalWhereContextable) {