Sha256: c7d545d994e2d2be2c8437a077c6873337b9dc879ad4d24ba5b6e729b87cd82c
Contents?: true
Size: 708 Bytes
Versions: 40
Compression:
Stored size: 708 Bytes
Contents
require 'neo4j/core/cypher_session/transactions'
module Neo4j
module Core
class CypherSession
module Transactions
class Bolt < Base
def initialize(*args)
super
tx_query('BEGIN') if root?
end
def commit
tx_query('COMMIT') if root?
end
def delete
tx_query('ROLLBACK')
end
def started?
true
end
private
def tx_query(cypher)
query = Adaptors::Base::Query.new(cypher, {}, cypher)
adaptor.send(:query_set, self, [query], skip_instrumentation: true)
end
end
end
end
end
end
Version data entries
40 entries across 40 versions & 1 rubygems