Class: Lafcadio::ObjectStore::Cache::DomainClassCache

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

Overview

:nodoc:

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(domain_class, db_bridge) ⇒ DomainClassCache

Returns a new instance of DomainClassCache.



399
400
401
402
403
404
 
# File 'lib/lafcadio/objectStore.rb', line 399

def initialize( domain_class, db_bridge )
  super()
  @domain_class, @db_bridge = domain_class, db_bridge
  @commit_times = {}
  @queries = {}
end

Instance Attribute Details

#commit_times ⇒ Object

Returns the value of attribute commit_times.



397
398
399
 
# File 'lib/lafcadio/objectStore.rb', line 397

def commit_times
  @commit_times
end

#domain_class ⇒ Object (readonly)

Returns the value of attribute domain_class.



396
397
398
 
# File 'lib/lafcadio/objectStore.rb', line 396

def domain_class
  @domain_class
end

#queries ⇒ Object

Returns the value of attribute queries.



397
398
399
 
# File 'lib/lafcadio/objectStore.rb', line 397

def queries
  @queries
end

Instance Method Details

#[](pk_id) ⇒ Object 



406
407
408
409
 
# File 'lib/lafcadio/objectStore.rb', line 406

def []( pk_id )
  dobj = super
  dobj ? dobj.clone : nil
end

#collect_from_superset(query) ⇒ Object 



411
412
413
414
415
416
417
418
419
420
421
422
 
# File 'lib/lafcadio/objectStore.rb', line 411

def collect_from_superset( query )
  if ( pk_ids = find_superset_pk_ids( query ) )
    db_objects = ( pk_ids.collect { |pk_id|
      self[ pk_id ]
    } ).select { |dobj| query.dobj_satisfies?( dobj ) }
    db_objects = query.order_and_limit_collection db_objects
    queries[query] = db_objects.collect { |dobj| dobj.pk_id }
    true
  else
    false
  end
end

#find_superset_pk_ids(query) ⇒ Object 



424
425
426
427
428
429
430
 
# File 'lib/lafcadio/objectStore.rb', line 424

def find_superset_pk_ids( query )
  superset_query, pk_ids =
    queries.find { |other_query, pk_ids|
      query.implies?( other_query )
    }
  pk_ids
end

#flush(db_object) ⇒ Object

Flushes a domain object.



433
434
435
436
 
# File 'lib/lafcadio/objectStore.rb', line 433

def flush( db_object )
  delete db_object.pk_id
  flush_queries
end

#flush_queries ⇒ Object 



438
439
440
441
442
 
# File 'lib/lafcadio/objectStore.rb', line 438

def flush_queries
  queries.keys.each do |query|
    queries.delete( query ) if query.domain_class == domain_class
  end
end

#last_commit_time(pk_id) ⇒ Object 



444
 
# File 'lib/lafcadio/objectStore.rb', line 444

def last_commit_time( pk_id ); commit_times[pk_id]; end

#save(db_object) ⇒ Object

Saves a domain object.



447
448
449
450
 
# File 'lib/lafcadio/objectStore.rb', line 447

def save(db_object)
  self[db_object.pk_id] = db_object
  flush_queries
end

#set_commit_time(d_obj) ⇒ Object 



452
 
# File 'lib/lafcadio/objectStore.rb', line 452

def set_commit_time( d_obj ); commit_times[d_obj.pk_id] = Time.now; end

#transactional_clone ⇒ Object 



454
455
456
457
458
459
 
# File 'lib/lafcadio/objectStore.rb', line 454

def transactional_clone
  tc = clone
  tc.commit_times = commit_times.clone
  tc.queries = queries.clone
  tc
end

#update_after_commit(db_object) ⇒ Object

:nodoc:



461
462
463
464
465
466
467
468
469
470
 
# File 'lib/lafcadio/objectStore.rb', line 461

def update_after_commit( db_object ) #:nodoc:
  if [ :update, :insert ].include?(
    db_object.last_commit_type
  )
    save db_object
  elsif db_object.last_commit_type == :delete
    flush db_object
  end
  set_commit_time db_object
end