Sha256: b57f4c7a1c403e6ce8a2613001644ccddb80494fae42cf34f969d40ee4a4f45a
Contents?: true
Size: 940 Bytes
Versions: 6
Compression:
Stored size: 940 Bytes
Contents
# -*- coding: utf-8 -*-
#
# 採番
#
module ActiveRecord::Turntable
class Sequencer
class Mysql < Sequencer
def initialize(klass, options = {})
@klass = klass
@options = options
end
def next_sequence_value(sequence_name)
conn = @klass.connection.seq.connection
conn.execute "UPDATE #{@klass.connection.quote_table_name(sequence_name)} SET id=LAST_INSERT_ID(id+1)"
res = conn.execute("SELECT LAST_INSERT_ID()")
new_id = res.first.first.to_i
raise SequenceNotFoundError if new_id.zero?
new_id
end
def current_sequence_value(sequence_name)
conn = @klass.connection.seq.connection
conn.execute "UPDATE #{@klass.connection.quote_table_name(sequence_name)} SET id=LAST_INSERT_ID(id)"
res = conn.execute("SELECT LAST_INSERT_ID()")
current_id = res.first.first.to_i
current_id
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems