Sha256: a10866cbe592dab9cb2da283f1735267363755ee163e6e84e40f3fc0c24b5ddd

Contents?: true

Size: 1.15 KB

Versions: 3

Compression:

Stored size: 1.15 KB

Contents

module Pacer
  module Orient
    import com.orientechnologies.orient.core.db.ODatabaseListener

    class DbListener
      include ODatabaseListener

      attr_reader :graph

      def initialize(graph)
        # TDOO: use graph factory?
        @graph = graph
      end

      def onCreate(db)
      end

      def onDelete(db)
      end

      def onOpen(db)
      end

      def onBeforeTxBegin(db)
      end

      def onBeforeTxRollback(db)
      end

      def onAfterTxRollback(db)
      end

      def onBeforeTxCommit(db)
        data = TxDataWrapper.new db, graph
        pp transaction: { getAllRecordEntries: data.entries,
                          length: data.entries.length,
                          contents: data.entries.to_a }
        pp created_v: data.created_v
        pp created_e: data.created_e
        pp changed_v: data.changed_v
        pp changed_e: data.changed_e
        pp deleted_v: data.deleted_v
        pp deleted_e: data.deleted_e

      end

      def onAfterTxCommit(db)
      end

      def onClose(db)
      end

      def onCorruptionRepairDatabase(db, iReason, iWhatWillbeFixed)
        return false
      end
    end

  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
pacer-orient-2.3.6-java lib/pacer-orient/db_listener.rb
pacer-orient-2.3.5-java lib/pacer-orient/db_listener.rb
pacer-orient-2.2.2.pre-java lib/pacer-orient/db_listener.rb