Class: Google::Cloud::Spanner::Session

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

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.single_use_transaction(opts) ⇒ Object

Create a single-use transaction selector.



45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
 
# File 'lib/spanner_client_ext.rb', line 45

def self.single_use_transaction opts
  return nil if opts.nil? || opts.empty?

  exact_timestamp = Convert.time_to_timestamp opts[:read_timestamp]
  exact_staleness = Convert.number_to_duration opts[:exact_staleness]
  min_read_timestamp = Convert.time_to_timestamp opts[:min_read_timestamp]
  max_staleness = Convert.number_to_duration opts[:max_staleness]

  V1::TransactionSelector.new(single_use:
    V1::TransactionOptions.new(read_only:
      V1::TransactionOptions::ReadOnly.new({
        strong: opts[:strong],
        read_timestamp: exact_timestamp,
        exact_staleness: exact_staleness,
        min_read_timestamp: min_read_timestamp,
        max_staleness: max_staleness,
        return_read_timestamp: true
      }.delete_if { |_, v| v.nil? })))
end

.snapshot_from_grpc_arity ⇒ Object 



27
28
29
 
# File 'lib/spanner_client_ext.rb', line 27

def self.snapshot_from_grpc_arity
  @snapshot_from_grpc_arity ||= Snapshot.method(:from_grpc).arity
end

Instance Method Details

#commit_transaction(transaction, mutations = [], commit_options: nil) ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/spanner_client_ext.rb', line 31

def commit_transaction transaction, mutations = [], commit_options: nil
  ensure_service!

  resp = service.commit(
    path,
    mutations,
    transaction_id: transaction.transaction_id,
    commit_options: commit_options
  )
  @last_updated_at = Time.now
  Convert.timestamp_to_time resp.commit_timestamp
end

#create_pdml ⇒ Object 



84
85
86
87
88
 
# File 'lib/spanner_client_ext.rb', line 84

def create_pdml
  ensure_service!
  pdml_grpc = service.create_pdml path
  Transaction.from_grpc pdml_grpc, self
end

#create_snapshot(strong: nil, timestamp: nil, read_timestamp: nil, staleness: nil, exact_staleness: nil) ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lib/spanner_client_ext.rb', line 65

def create_snapshot strong: nil,
                    timestamp: nil, read_timestamp: nil,
                    staleness: nil, exact_staleness: nil
  validate_snapshot_args! strong: strong, timestamp: timestamp,
                          read_timestamp: read_timestamp,
                          staleness: staleness,
                          exact_staleness: exact_staleness
  ensure_service!

  snp_grpc = service.create_snapshot \
    path, timestamp: timestamp || read_timestamp,
    staleness: staleness || exact_staleness
  if Session.snapshot_from_grpc_arity == 3
    Snapshot.from_grpc snp_grpc, self, nil
  else
    Snapshot.from_grpc snp_grpc, self
  end
end