Class: Lafcadio::ObjectStore::DbBridge

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

Overview

:nodoc:

Defined Under Namespace

Classes: Transaction

Constant Summary collapse

@@last_pk_id_inserted = 
nil

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ DbBridge

Returns a new instance of DbBridge.



581
582
583
584
 
# File 'lib/lafcadio/objectStore.rb', line 581

def initialize
  @db_conn = DbConnection.get_db_connection
  @transaction = nil
end

Class Method Details

._load(aString) ⇒ Object 



560
561
562
563
564
565
566
567
568
569
570
 
# File 'lib/lafcadio/objectStore.rb', line 560

def self._load(aString)
  aString =~ /db_conn:/
  db_conn_str = $'
  begin
    db_conn = Marshal.load db_conn_str
  rescue TypeError
    db_conn = nil
  end
  DbConnection.set_db_connection db_conn
  new
end

.last_inserted_pk_id_pair(domain_class) ⇒ Object 



572
573
574
575
576
577
578
579
 
# File 'lib/lafcadio/objectStore.rb', line 572

def self.last_inserted_pk_id_pair( domain_class )
  case ObjectStore.db_type
  when 'Mysql'
    [ 'last_insert_id()', 'last_insert_id()' ]
  when 'Pg'
    [ "currval('#{ domain_class.postgres_pk_id_seq }')", 'currval' ]
  end
end

Instance Method Details

#_dump(aDepth) ⇒ Object 



586
587
588
589
 
# File 'lib/lafcadio/objectStore.rb', line 586

def _dump(aDepth)
  dbDump = @dbh.respond_to?( '_dump' ) ? @dbh._dump : @dbh.class.to_s
  "dbh:#{dbDump}"
end

#commit(db_object) ⇒ Object 



591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
 
# File 'lib/lafcadio/objectStore.rb', line 591

def commit(db_object)
  statements_and_binds = ObjectStore::CommitSqlStatementsAndBinds.new(
    db_object
  )
  statements_and_binds.each do |sql, binds|
    maybe_log sql
    @db_conn.do( sql, *binds )
  end
  if statements_and_binds[0].first =~ /insert/
    @@last_pk_id_inserted = get_last_pk_id_inserted(
      db_object.domain_class
    )
  end
  @db_conn.do( 'commit' ) unless @transaction
end

#get_last_pk_id_inserted(domain_class) ⇒ Object 



607
608
609
610
611
612
613
614
615
616
617
618
619
 
# File 'lib/lafcadio/objectStore.rb', line 607

def get_last_pk_id_inserted( domain_class )
  pair = self.class.last_inserted_pk_id_pair( domain_class )
  sql = 'select ' + pair.first
  begin
    select_all( sql ).first[pair.last].to_i
  rescue RuntimeError
    error_msg =
        "The field \"" + domain_class.sql_primary_key_name +
        "\" can\'t be found in the table \"" + 
        domain_class.table_name + "\"."
    raise FieldMatchError, error_msg, caller
  end
end

#group_query(query) ⇒ Object 



621
622
623
 
# File 'lib/lafcadio/objectStore.rb', line 621

def group_query( query )
  select_all( query.to_sql ).map { |row| query.result_row( row ) }
end

#last_pk_id_inserted ⇒ Object 



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

def last_pk_id_inserted; @@last_pk_id_inserted; end

#maybe_log(sql) ⇒ Object 



627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
 
# File 'lib/lafcadio/objectStore.rb', line 627

def maybe_log(sql)
  config = LafcadioConfig.new
  if config['logSql'] == 'y'
    sqllog = Log4r::Logger['sql'] || Log4r::Logger.new( 'sql' )
    if sqllog.outputters.empty?
      filename = File.join(
        config['logdir'], config['sqlLogFile'] || 'sql'
      )
      outputter = Log4r::FileOutputter.new(
        'outputter', { :filename => filename }
      )
      sqllog.outputters = outputter
    end
    sqllog.info sql
  end
end

#rollback ⇒ Object 



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

def rollback; @transaction.rollback( false ) if @transaction; end

#select_all(sql) ⇒ Object 



646
647
648
649
650
651
652
653
 
# File 'lib/lafcadio/objectStore.rb', line 646

def select_all(sql)
  maybe_log sql
  begin
    @db_conn.select_all( sql )
  rescue DBI::DatabaseError => e
    raise $!.to_s + ": #{ e.errstr }"
  end  
end

#select_dobjs(query) ⇒ Object 



655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
 
# File 'lib/lafcadio/objectStore.rb', line 655

def select_dobjs(query)
  domain_class = query.domain_class
  select_all( query.to_sql( ObjectStore.db_type ) ).collect { |row_hash|
    dobj = domain_class.new(
      SqlToRubyValues.new( domain_class, row_hash )
    )
    if query.include
      query.include.each do |include_sym|
        field = domain_class.field include_sym
        included_dclass = field.linked_type
        if dobj.send( field.name )
          dobj.send( field.name ).db_object = included_dclass.new(
            SqlToRubyValues.new( included_dclass, row_hash )
          )
        end
      end
    end
    dobj
  }
end

#transaction(action) ⇒ Object 



676
677
678
679
680
681
682
683
684
685
686
687
688
 
# File 'lib/lafcadio/objectStore.rb', line 676

def transaction( action )
  @transaction = Transaction.new @db_conn
  @transaction.commit
  begin
    action.call @transaction
    @transaction.commit
  rescue
    err_to_raise = $!
    @transaction.rollback false
    raise err_to_raise
  end
  @transaction = nil
end

#transactional_clone ⇒ Object 



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

def transactional_clone; clone; end