Contents

module Executrix
  class Connection
    def initialize(username, password, api_version, sandbox)
      @username = username
      @password = password
      @api_version = api_version
      @sandbox = sandbox
    end

    def login
      response = Executrix::Http.login(
        @sandbox,
        @username,
        @password,
        @api_version)

      @session_id = response[:session_id]
      @instance = response[:instance]
      self
    end

    def create_job operation, sobject, external_field
      Executrix::Http.create_job(
        @instance,
        @session_id,
        operation,
        sobject,
        @api_version,
        external_field)[:id]
    end

    def close_job job_id
      Executrix::Http.close_job(
        @instance,
        @session_id,
        job_id,
        @api_version)[:id]
    end

    def add_query job_id, data_or_soql
      Executrix::Http.add_batch(
        @instance,
        @session_id,
        job_id,
        data_or_soql,
        @api_version)[:id]
    end

    def query_batch job_id, batch_id
      Executrix::Http.query_batch(
        @instance,
        @session_id,
        job_id,
        batch_id,
        @api_version,
      )
    end

    def query_batch_result_id job_id, batch_id
      Executrix::Http.query_batch_result_id(
        @instance,
        @session_id,
        job_id,
        batch_id,
        @api_version,
      )
    end

    def query_batch_result_data job_id, batch_id, result_id
      Executrix::Http.query_batch_result_data(
        @instance,
        @session_id,
        job_id,
        batch_id,
        result_id,
        @api_version,
      )
    end

    def add_batch job_id, records
      return -1 if records.nil? || records.empty?

      Executrix::Http.add_batch(
        @instance,
        @session_id,
        job_id,
        Executrix::Helper.records_to_csv(records),
        @api_version)[:id]
    end

    def self.connect(username, password, api_version, sandbox)
      self.new(username, password, api_version, sandbox).login
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
executrix-1.0.0	lib/executrix/connection.rb