schema_statements.rb in torque-postgresql-3.0.0

- old
+ new

@@ -5,25 +5,10 @@
     module Adapter
       module SchemaStatements
 
         TableDefinition = ActiveRecord::ConnectionAdapters::PostgreSQL::TableDefinition
 
-        # Create a new schema
-        def create_schema(name, options = {})
-          drop_schema(name, options) if options[:force]
-
-          check = 'IF NOT EXISTS' if options.fetch(:check, true)
-          execute("CREATE SCHEMA #{check} #{quote_schema_name(name.to_s)}")
-        end
-
-        # Drop an existing schema
-        def drop_schema(name, options = {})
-          force = options.fetch(:force, '').upcase
-          check = 'IF EXISTS' if options.fetch(:check, true)
-          execute("DROP SCHEMA #{check} #{quote_schema_name(name.to_s)} #{force}")
-        end
-
         # Drops a type.
         def drop_type(name, options = {})
           force = options.fetch(:force, '').upcase
           check = 'IF EXISTS' if options.fetch(:check, true)
           execute <<-SQL.squish
@@ -31,32 +16,17 @@
             #{quote_type_name(name, options[:schema])} #{force}
           SQL
         end
 
         # Renames a type.
-        def rename_type(type_name, new_name, options = {})
+        def rename_type(type_name, new_name)
           execute <<-SQL.squish
-            ALTER TYPE #{quote_type_name(type_name, options[:schema])}
+            ALTER TYPE #{quote_type_name(type_name)}
             RENAME TO #{Quoting::Name.new(nil, new_name.to_s).quoted}
           SQL
         end
 
-        # Creates a new PostgreSQL enumerator type
-        #
-        # Example:
-        #   create_enum 'status', ['foo', 'bar']
-        #   create_enum 'status', ['foo', 'bar'], prefix: true
-        #   create_enum 'status', ['foo', 'bar'], suffix: 'test'
-        #   create_enum 'status', ['foo', 'bar'], force: true
-        def create_enum(name, values, options = {})
-          drop_type(name, options) if options[:force]
-          execute <<-SQL.squish
-            CREATE TYPE #{quote_type_name(name, options[:schema])} AS ENUM
-            (#{quote_enum_values(name, values, options).join(', ')})
-          SQL
-        end
-
         # Changes the enumerator by adding new values
         #
         # Example:
         #   add_enum_values 'status', ['baz']
         #   add_enum_values 'status', ['baz'], before: 'bar'
@@ -92,58 +62,16 @@
           SQL
         end
 
         # Rewrite the method that creates tables to easily accept extra options
         def create_table(table_name, **options, &block)
-          table_name = "#{options[:schema]}.#{table_name}" if options[:schema].present?
-
           options[:id] = false if options[:inherits].present? &&
             options[:primary_key].blank? && options[:id].blank?
 
           super table_name, **options, &block
         end
 
-        # Simply add the schema to the table name when changing a table
-        def change_table(table_name, **options)
-          table_name = "#{options[:schema]}.#{table_name}" if options[:schema].present?
-          super table_name, **options
-        end
-
-        # Simply add the schema to the table name when dropping a table
-        def drop_table(table_name, **options)
-          table_name = "#{options[:schema]}.#{table_name}" if options[:schema].present?
-          super table_name, **options
-        end
-
-        # Add the schema option when extracting table options
-        def table_options(table_name)
-          parts = table_name.split('.').reverse
-          return super unless parts.size == 2 && parts[1] != 'public'
-
-          (super || {}).merge(schema: parts[1])
-        end
-
-        # When dumping the schema we need to add all schemas, not only those
-        # active for the current +schema_search_path+
-        def quoted_scope(name = nil, type: nil)
-          return super unless name.nil?
-
-          super.merge(schema: "ANY ('{#{user_defined_schemas.join(',')}}')")
-        end
-
-        # Fix the query to include the schema on tables names when dumping
-        def data_source_sql(name = nil, type: nil)
-          return super unless name.nil?
-
-          super.sub('SELECT c.relname FROM', "SELECT n.nspname || '.' || c.relname FROM")
-        end
-
         private
-
-          # Remove the schema from the sequence name
-          def sequence_name_from_parts(table_name, column_name, suffix)
-            super(table_name.split('.').last, column_name, suffix)
-          end
 
           def quote_enum_values(name, values, options)
             prefix = options[:prefix]
             prefix = name if prefix === true
 