Class: ActiveOrient::OrientDB

Inherits:
Object
  • Object
show all
Includes:
ClassUtils, DatabaseUtils, OrientDbPrivate, OrientSupport::Logging, OrientSupport::Support, RestChange, RestCreate, RestDelete, RestOperations, RestRead
Defined in:
lib/rest/rest.rb

Overview

OrientDB points to an OrientDB-Database. The communication is based on the OrientDB-REST-API.

Its usually initialised through ActiveOrient::Init.connect

Instance Method Summary collapse

Methods included from RestDelete

#delete_class, #delete_database, #delete_property, #delete_record, #delete_records

Methods included from RestOperations

#_execute, #call_function, #count, #execute, #manage_transaction, #read_transaction

Methods included from RestChange

#alter_property, #change_database, #patch_record, #update, #update_records

Methods included from RestCreate

#create_database, #create_index, #create_properties, #create_property, #create_record, #upsert

Methods included from RestRead

#get_class_properties, #get_classes, #get_databases, #get_record, #get_records, #print_class_properties

Methods included from ClassUtils

#allocate_class_in_ruby, #classname, #create_class, #create_edge_class, #create_vertex_class, #delete_edge

Methods included from DatabaseUtils

#class_hierarchy, #database_classes, #get_db_superclass, #preallocate_classes, #system_classes

Methods included from OrientSupport::Logging

included

Methods included from OrientSupport::Support

#as, #compose_where, #generate_sql_list, #where, #while_s

Constructor Details

#initialize(database: nil, preallocate: true, model_dir: nil, **defaults) ⇒ OrientDB

OrientDB is conventionally initialized.

The first call initialises database-name and -classes, server-adress and user-credentials.

Subsequent initialisations are made to initialise namespaced database classes, ie.

ORD = ActiveOrient.init.connect database: ‘temp’ server: ‘localhost’, port: 2480, user: root, password: root module HC; end ActiveOrient::Init.define_namespace { HC } ActiveOrient::OrientDB.new preallocate: true



59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/rest/rest.rb', line 59

def initialize database: nil, preallocate: true, model_dir: nil, **defaults
  ActiveOrient.database ||= database || 'temp'
  ActiveOrient.database_classes ||=   Hash.new

      ActiveOrient.default_server ||= { :server => defaults[:server] || 'localhost' ,
                                :port   => defaults[:port] ||= 2480,
                                :user   => defaults[:user].to_s ,
                                :password => defaults[:password].to_s }
      # setup connection pool
      # database-settings: client.channel.maxPool = 100
      ActiveOrient.db_pool ||= Pond.new( :maximum_size => 25, :timeout => 50) {  get_resource }
#     ActiveOrient.db_pool.collection = :stack
  connect() 
  database_classes # initialize @classes-array and ActiveOrient.database_classes 
      ActiveOrient::Base.logger =  logger
  ActiveOrient::Model.orientdb = self 
  ActiveOrient::Model.db = self 
  ActiveOrient::Model.keep_models_without_file ||= nil
  preallocate_classes( model_dir )  if preallocate
      Thread.abort_on_exception = true
end

Instance Method Details

#connect ⇒ Object

Used to connect to the database



93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/rest/rest.rb', line 93

def connect 
  first_tentative = true
  begin
    database =  ActiveOrient.database
    logger.progname = 'OrientDB#Connect'
    r = ActiveOrient.db_pool.checkout do | conn |
      r = conn["/connect/#{database}"].get
    end
    if r.code == 204
      logger.info{"Connected to database #{database}"}
      true
    else
      logger.error{"Connection to database #{database} could NOT be established"}
      nil
    end
  rescue RestClient::Unauthorized => e
    if first_tentative
      logger.info{"Database #{database} NOT present --> creating"}
      first_tentative = false
      create_database database: database
      retry
    else
      Kernel.exit
    end
  end
end

#get_resource ⇒ Object

thread safe method to allocate a resource



82
83
84
85
86
87
 
# File 'lib/rest/rest.rb', line 82

def get_resource
      logger.debug {"ALLOCATING NEW RESOURCE --> #{ ActiveOrient.db_pool.size }" }
   = [ActiveOrient.default_server[:user] , ActiveOrient.default_server[:password]]
  server_adress = "http://#{ActiveOrient.default_server[:server]}:#{ActiveOrient.default_server[:port]}"
RestClient::Resource.new(server_adress, *)
end