Sha256: 39484ac9d23b789efd87848b717456bfe826fb92a83a9d0493c53219c2b99310

Contents?: true

Size: 889 Bytes

Versions: 6

Compression:

Stored size: 889 Bytes

Contents

# frozen_string_literal: true

module Dynamoid
  module Tasks
    module Database
      module_function

      # Create any new tables for the models. Existing tables are not
      # modified.
      def create_tables
        results = { created: [], existing: [] }
        # We can't quite rely on Dynamoid.included_models alone, we need to select only viable models
        Dynamoid.included_models.reject { |m| m.base_class.try(:name).blank? }.uniq(&:table_name).each do |model|
          if Dynamoid.adapter.list_tables.include? model.table_name
            results[:existing] << model.table_name
          else
            model.create_table(sync: true)
            results[:created] << model.table_name
          end
        end
        results
      end

      # Is the DynamoDB reachable?
      def ping
        Dynamoid.adapter.list_tables
        true
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
dynamoid-3.5.0 lib/dynamoid/tasks/database.rb
dynamoid-3.4.1 lib/dynamoid/tasks/database.rb
dynamoid-3.4.0 lib/dynamoid/tasks/database.rb
dynamoid-3.3.0 lib/dynamoid/tasks/database.rb
dynamoid-3.2.0 lib/dynamoid/tasks/database.rb
dynamoid-3.1.0 lib/dynamoid/tasks/database.rb