Class: Dcmgr::Models::BaseNew

Inherits:

Sequel::Model

• Object
• Sequel::Model
• Dcmgr::Models::BaseNew

Defined in:

lib/dcmgr/models/base_new.rb

Direct Known Subclasses

Account, AccountResource, FrontendSystem, History, HostnameLease, InstanceNetfilterGroup, InstanceNic, IpLease, MacLease, NetfilterRule, RequestLog, TagMapping

Constant Summary

LOCK_TABLES_KEY =

'__locked_tables'

Class Method Summary

• .dataset ⇒ Object
• .install_data ⇒ Object

  Callback when the initial data is setup to the database.

• .install_data_hooks(&blk) ⇒ Object

  Add callbacks to setup the initial data.

• .lock! ⇒ Object
• .Proxy(klass) ⇒ Object
• .unlock! ⇒ Object

Class Method Details

.dataset ⇒ Object

# File 'lib/dcmgr/models/base_new.rb', line 415

def self.dataset
  locktbls = Thread.current[LOCK_TABLES_KEY]
  if locktbls && locktbls[self.db.uri.to_s + @dataset.first_source_alias.to_s]
    @dataset.opts = @dataset.opts.merge({:lock=>:update})
  else
    @dataset.opts = @dataset.opts.merge({:lock=>nil})
  end
  @dataset
end

.install_data ⇒ Object

Callback when the initial data is setup to the database.

# File 'lib/dcmgr/models/base_new.rb', line 444

def self.install_data
  install_data_hooks.each{|h| h.call }
end

.install_data_hooks(&blk) ⇒ Object

Add callbacks to setup the initial data. The hooks will be called when Model1.install_data() is called.

class Model1 < Base

install_data_hooks do
  Model1.create({:col1=>1, :col2=>2})
end

end

# File 'lib/dcmgr/models/base_new.rb', line 456

def self.install_data_hooks(&blk)
  @install_data_hooks ||= []
  if blk
    @install_data_hooks << blk
  end
  @install_data_hooks
end

.lock! ⇒ Object

# File 'lib/dcmgr/models/base_new.rb', line 401

def self.lock!
  locktbls = Thread.current[LOCK_TABLES_KEY]
  if locktbls
    locktbls[self.db.uri.to_s + @dataset.first_source_alias.to_s]=1
  end
end

.Proxy(klass) ⇒ Object

# File 'lib/dcmgr/models/base_new.rb', line 427

def self.Proxy(klass)
  colnames = klass.schema.columns.map {|i| i[:name] }
  colnames.delete_if(klass.primary_key) if klass.restrict_primary_key?
  s = ::Struct.new(*colnames) do
    def to_hash
      n = {}
      self.each_pair { |k,v|
        n[k.to_sym]=v
      }
      n
    end
  end
  s
end

.unlock! ⇒ Object

# File 'lib/dcmgr/models/base_new.rb', line 408

def self.unlock!
  locktbls = Thread.current[LOCK_TABLES_KEY]
  if locktbls
    locktbls.delete(self.db.uri.to_s + @dataset.first_source_alias.to_s)
  end
end