Class: Lafcadio::ObjectStore::Cache

Inherits:
Object
  • Object
show all
Includes:
MonitorMixin
Defined in:
lib/lafcadio/objectStore.rb

Overview

:nodoc:

Defined Under Namespace

Classes: DomainClassCache

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(db_bridge = DbBridge.new) ⇒ Cache

Returns a new instance of Cache.



287
288
289
290
291
 
# File 'lib/lafcadio/objectStore.rb', line 287

def initialize( db_bridge = DbBridge.new )
  super()
  @db_bridge = db_bridge
  @domain_class_caches = {}
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(meth, *args) ⇒ Object 



348
349
350
351
352
353
354
355
356
357
358
359
360
361
 
# File 'lib/lafcadio/objectStore.rb', line 348

def method_missing( meth, *args )
  simple_dispatch = [
    :flush, :queries, :save, :set_commit_time, :update_after_commit
  ]
  if simple_dispatch.include?( meth )
    cache( args.first.domain_class ).send( meth, *args )
  elsif [ :[], :last_commit_time ].include?( meth )
    cache( args.first ).send( meth, *args[1..-1] )
  elsif [ :group_query, :rollback, :transaction ].include?( meth )
    @db_bridge.send( meth, *args )
  else
    super
  end
end

Instance Attribute Details

#db_bridge ⇒ Object (readonly)

Returns the value of attribute db_bridge.



284
285
286
 
# File 'lib/lafcadio/objectStore.rb', line 284

def db_bridge
  @db_bridge
end

#domain_class_caches ⇒ Object

Returns the value of attribute domain_class_caches.



285
286
287
 
# File 'lib/lafcadio/objectStore.rb', line 285

def domain_class_caches
  @domain_class_caches
end

Instance Method Details

#cache(domain_class) ⇒ Object 



310
311
312
313
314
315
316
317
 
# File 'lib/lafcadio/objectStore.rb', line 310

def cache( domain_class )
  unless @domain_class_caches[domain_class]
    @domain_class_caches[domain_class] = DomainClassCache.new(
      domain_class, @db_bridge
    )
  end
  @domain_class_caches[domain_class]
end

#commit(db_object) ⇒ Object 



293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
 
# File 'lib/lafcadio/objectStore.rb', line 293

def commit( db_object )
  db_object.verify if LafcadioConfig.new()['checkFields'] == 'onCommit'
  db_object.last_commit_type = get_last_commit db_object
  db_object.pre_commit_trigger
  update_dependent_domain_objects( db_object ) if db_object.delete
  synchronize do
    @db_bridge.commit db_object
    unless db_object.pk_id
      db_object.pk_id = @db_bridge.last_pk_id_inserted
    end
  end
  update_after_commit db_object
  db_object.post_commit_trigger
  db_object.reset_original_values_hash
  db_object
end

#get_by_query(query) ⇒ Object 



319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
 
# File 'lib/lafcadio/objectStore.rb', line 319

def get_by_query( query )
  main_cache = cache query.domain_class
  unless main_cache.queries[query]
    if query.one_pk_id?
      collected = false
    else
      collected = main_cache.collect_from_superset query
    end
    if !collected and main_cache.queries.values
      newObjects = @db_bridge.select_dobjs query
      newObjects.each { |dbObj| main_cache.save dbObj }
      main_cache.queries[query] = newObjects.collect { |dobj|
        dobj.pk_id
      }
    end
  end
  main_cache.queries[query].map { |pk_id| main_cache[pk_id] }.compact
end

#get_last_commit(db_object) ⇒ Object 



338
339
340
341
342
343
344
345
346
 
# File 'lib/lafcadio/objectStore.rb', line 338

def get_last_commit( db_object )
  if db_object.delete
    :delete
  elsif db_object.pk_id
    :update
  else
    :insert
  end
end

#transactional_clone ⇒ Object 



363
364
365
366
367
368
369
370
371
 
# File 'lib/lafcadio/objectStore.rb', line 363

def transactional_clone
  tc = Cache.new @db_bridge.transactional_clone
  dcc_clones = {}
  @domain_class_caches.each do |domain_class, dcc|
    dcc_clones[domain_class] = dcc.transactional_clone
  end
  tc.domain_class_caches = dcc_clones
  tc
end

#update_dependent_domain_class(db_object, aClass, field) ⇒ Object 



373
374
375
376
377
378
379
380
381
382
383
384
 
# File 'lib/lafcadio/objectStore.rb', line 373

def update_dependent_domain_class( db_object, aClass, field )
  object_store = ObjectStore.get_object_store
  collection = aClass.get( db_object, field.name )
  collection.each { |dependentObject|
    if field.delete_cascade
      dependentObject.delete = true
    else
      dependentObject.send( field.name + '=', nil )
    end
    object_store.commit dependentObject
  }
end

#update_dependent_domain_objects(db_object) ⇒ Object 



386
387
388
389
390
391
392
393
 
# File 'lib/lafcadio/objectStore.rb', line 386

def update_dependent_domain_objects( db_object )
  dependent_classes = db_object.domain_class.dependent_classes
  dependent_classes.keys.each { |aClass|
    update_dependent_domain_class(
      db_object, aClass, dependent_classes[aClass]
    )
  }
end