TapKit::DatabaseContext

Class/Module:
Class
In:
lib/tapkit/access/database_context.rb
Parent:
CooperatingObjectStore

Methods

array_fault
available_channel
commit
fault
fault_for_raw_row
fetch
finalize_commit_changes
forget_snapshot
forget_snapshots
handle_fetch_spec?
handle_notification
initialize_object
lock
new
objects_for_source_gid
own?
perform_changes
prepare_for_save
record_changes
record_snapshot
record_to_many_snapshots
record_update
refault
register_channel
rollback
set_timestamp_to_now
snapshot
snapshot_for_source
unlock
unregister_channel

Attributes

adapter_context [R]
channels [R]
coordinator [R]
database [R]

Public Class Methods

handle_notification( notification )
new( database )

Public Instance Methods

array_fault( gid, relationship_name, editing_context )
available_channel()

Create a new channel if all existed channels are busy.

commit()
fault( gid, editing_context )

faulting

fault_for_raw_row( row, entity_name, editing_context )
fetch( fetch_spec, editing_context )
finalize_commit_changes()
  • Delete snapshots of deleted objects
  • Set timestamp to now
  • Register new snapshots
  • Update global IDs for new records
  • Notificate GID_CHANGED_NOTIFICATION
  • End the transaction
forget_snapshot( gid )
forget_snapshots( gids )
handle_fetch_spec?( fetch_spec )
initialize_object( object, gid, editing_context )
lock()

Not yet implemented.

objects_for_source_gid( src_gid, name, editing_context )
own?( object )

Returns true if the receiver is responsible for fetching and saving the object (or GlobalID), false otherwise.

perform_changes()
prepare_for_save( coordinator, editing_context )
record_changes()
record_snapshot( gid, snapshot )

snapshots

record_to_many_snapshots( snapshots )
record_update( object, changes )
refault( object, gid, editing_context )
register_channel( channel )
rollback()
set_timestamp_to_now()
snapshot( gid, time = nil )
snapshot_for_source( gid, name, time = nil )
unlock()

Not yet implemented.

unregister_channel( channel )