Method: ActiveOrient::API#execute

Defined in:

lib/java-api.rb

#execute(transaction: true, tolerated_error_code: nil, process_error: true) ⇒ Object

executes a command as sql-query

# File 'lib/java-api.rb', line 296

def execute transaction: true, tolerated_error_code: nil , process_error: true# Set up for classes
  batch = {transaction: transaction, operations: yield}

  logger.progname= "Execute"
  unless batch[:operations].blank?
  unless batch[:operations].is_a? Array
    batch[:operations] = [batch[:operations]]  
    was_array =  true
  else
    was_array =  false
  end
  answer = batch[:operations].map do |command_record|
    return if command_record.blank? 
    begin
    response = @db.run_command  command_record.is_a?(Hash) ?  command_record[:command] : command_record 
    rescue Java::ComOrientechnologiesOrientCoreStorage::ORecordDuplicatedException => e
#     puts e.inspect
#     puts "GetMESSAGE: "+e.getMessage.split(/\r/).first
#     puts "GetComponentName: "+e.getComponentName.to_s
#     puts  e.getMessage =~ tolerated_error_code
#     puts "----"
 if tolerated_error_code.present? &&  e.getMessage =~ tolerated_error_code
   logger.info{ "tolerated_error::#{ e.get_message.split(/\r/).first }"}
   next
 else
#     if process_error
   logger.progname = 'JavaApi#Execute'
   logger.error{ e }
#     else 
#       puts e.inspect
#       raise ArgumentError, e, caller
 end
    end
    if response.is_a? Fixnum
 response
    else
 response.map do | r |
   if r.is_a? Document
    if r.rid.rid? 
update_document r 
    else
ActiveOrient::Model.orientdb_class( name: 'query').new  r
    end
   else 
    puts "Strange things happen in execute: #{r.inspect}"
    r.values
   end
 end  # map response
    end  #  branch response_is_a
  end  # map batch
  answer.pop if answer.size==1 && answer.first.is_a?(Array)
  end # unless
end