Commit 44f9d16e authored by Mayra Cabrera's avatar Mayra Cabrera

Revert "Merge branch 'ab/partition-management' into 'master'"

This reverts merge request !34504
parent 82b29b28
---
title: Create time-space partitions in separate schema
merge_request: 34504
author:
type: other
# Ignore table used temporarily in background migration # Ignore table used temporarily in background migration
ActiveRecord::SchemaDumper.ignore_tables = ["untracked_files_for_uploads"] ActiveRecord::SchemaDumper.ignore_tables = ["untracked_files_for_uploads"]
# Ignore dynamically managed partitions in static application schema
ActiveRecord::SchemaDumper.ignore_tables += ["partitions_dynamic.*"]
# frozen_string_literal: true
class CreateDynamicPartitionsSchema < ActiveRecord::Migration[6.0]
include Gitlab::Database::SchemaHelpers
DOWNTIME = false
def up
execute 'CREATE SCHEMA partitions_dynamic'
create_comment(:schema, :partitions_dynamic, <<~EOS.strip)
Schema to hold partitions managed dynamically from the application, e.g. for time space partitioning.
EOS
end
def down
execute 'DROP SCHEMA partitions_dynamic'
end
end
SET search_path=public; SET search_path=public;
CREATE SCHEMA partitions_dynamic;
COMMENT ON SCHEMA partitions_dynamic IS 'Schema to hold partitions managed dynamically from the application, e.g. for time space partitioning.';
CREATE EXTENSION IF NOT EXISTS pg_trgm WITH SCHEMA public; CREATE EXTENSION IF NOT EXISTS pg_trgm WITH SCHEMA public;
CREATE TABLE public.abuse_reports ( CREATE TABLE public.abuse_reports (
...@@ -14068,7 +14064,6 @@ COPY "schema_migrations" (version) FROM STDIN; ...@@ -14068,7 +14064,6 @@ COPY "schema_migrations" (version) FROM STDIN;
20200610130002 20200610130002
20200613104045 20200613104045
20200615083635 20200615083635
20200615101135
20200615121217 20200615121217
20200615123055 20200615123055
20200615232735 20200615232735
......
...@@ -8,7 +8,6 @@ module Gitlab ...@@ -8,7 +8,6 @@ module Gitlab
WHITELISTED_TABLES = %w[audit_events].freeze WHITELISTED_TABLES = %w[audit_events].freeze
ERROR_SCOPE = 'table partitioning' ERROR_SCOPE = 'table partitioning'
DYNAMIC_PARTITIONS_SCHEMA = 'partitions_dynamic'
# Creates a partitioned copy of an existing table, using a RANGE partitioning strategy on a timestamp column. # Creates a partitioned copy of an existing table, using a RANGE partitioning strategy on a timestamp column.
# One partition is created per month between the given `min_date` and `max_date`. # One partition is created per month between the given `min_date` and `max_date`.
...@@ -126,7 +125,7 @@ module Gitlab ...@@ -126,7 +125,7 @@ module Gitlab
min_date = min_date.beginning_of_month.to_date min_date = min_date.beginning_of_month.to_date
max_date = max_date.next_month.beginning_of_month.to_date max_date = max_date.next_month.beginning_of_month.to_date
create_range_partition_safely("#{table_name}_000000", table_name, 'MINVALUE', to_sql_date_literal(min_date), schema: DYNAMIC_PARTITIONS_SCHEMA) create_range_partition_safely("#{table_name}_000000", table_name, 'MINVALUE', to_sql_date_literal(min_date))
while min_date < max_date while min_date < max_date
partition_name = "#{table_name}_#{min_date.strftime('%Y%m')}" partition_name = "#{table_name}_#{min_date.strftime('%Y%m')}"
...@@ -134,7 +133,7 @@ module Gitlab ...@@ -134,7 +133,7 @@ module Gitlab
lower_bound = to_sql_date_literal(min_date) lower_bound = to_sql_date_literal(min_date)
upper_bound = to_sql_date_literal(next_date) upper_bound = to_sql_date_literal(next_date)
create_range_partition_safely(partition_name, table_name, lower_bound, upper_bound, schema: DYNAMIC_PARTITIONS_SCHEMA) create_range_partition_safely(partition_name, table_name, lower_bound, upper_bound)
min_date = next_date min_date = next_date
end end
end end
...@@ -143,8 +142,8 @@ module Gitlab ...@@ -143,8 +142,8 @@ module Gitlab
connection.quote(date.strftime('%Y-%m-%d')) connection.quote(date.strftime('%Y-%m-%d'))
end end
def create_range_partition_safely(partition_name, table_name, lower_bound, upper_bound, schema:) def create_range_partition_safely(partition_name, table_name, lower_bound, upper_bound)
if table_exists?("#{schema}.#{partition_name}") if table_exists?(partition_name)
# rubocop:disable Gitlab/RailsLogger # rubocop:disable Gitlab/RailsLogger
Rails.logger.warn "Partition not created because it already exists" \ Rails.logger.warn "Partition not created because it already exists" \
" (this may be due to an aborted migration or similar): partition_name: #{partition_name}" " (this may be due to an aborted migration or similar): partition_name: #{partition_name}"
...@@ -152,7 +151,7 @@ module Gitlab ...@@ -152,7 +151,7 @@ module Gitlab
return return
end end
create_range_partition(partition_name, table_name, lower_bound, upper_bound, schema: schema) create_range_partition(partition_name, table_name, lower_bound, upper_bound)
end end
def create_sync_trigger(source_table, target_table, unique_key) def create_sync_trigger(source_table, target_table, unique_key)
......
...@@ -69,11 +69,9 @@ module Gitlab ...@@ -69,11 +69,9 @@ module Gitlab
private private
def create_range_partition(partition_name, table_name, lower_bound, upper_bound, schema:) def create_range_partition(partition_name, table_name, lower_bound, upper_bound)
raise ArgumentError, 'explicit schema is required but currently missing' unless schema
execute(<<~SQL) execute(<<~SQL)
CREATE TABLE #{schema}.#{partition_name} PARTITION OF #{table_name} CREATE TABLE #{partition_name} PARTITION OF #{table_name}
FOR VALUES FROM (#{lower_bound}) TO (#{upper_bound}) FOR VALUES FROM (#{lower_bound}) TO (#{upper_bound})
SQL SQL
end end
......
...@@ -241,7 +241,7 @@ describe Gitlab::Database::PartitioningMigrationHelpers::TableManagementHelpers ...@@ -241,7 +241,7 @@ describe Gitlab::Database::PartitioningMigrationHelpers::TableManagementHelpers
describe '#drop_partitioned_table_for' do describe '#drop_partitioned_table_for' do
let(:expected_tables) do let(:expected_tables) do
%w[000000 201912 202001 202002].map { |suffix| "partitions_dynamic.#{partitioned_table}_#{suffix}" }.unshift(partitioned_table) %w[000000 201912 202001 202002].map { |suffix| "#{partitioned_table}_#{suffix}" }.unshift(partitioned_table)
end end
context 'when the table is not whitelisted' do context 'when the table is not whitelisted' do
......
...@@ -8,8 +8,8 @@ module PartitioningHelpers ...@@ -8,8 +8,8 @@ module PartitioningHelpers
expect(columns_with_part_type).to match_array(actual_columns) expect(columns_with_part_type).to match_array(actual_columns)
end end
def expect_range_partition_of(partition_name, table_name, min_value, max_value, schema: 'partitions_dynamic') def expect_range_partition_of(partition_name, table_name, min_value, max_value)
definition = find_partition_definition(partition_name, schema: schema) definition = find_partition_definition(partition_name)
expect(definition).not_to be_nil expect(definition).not_to be_nil
expect(definition['base_table']).to eq(table_name.to_s) expect(definition['base_table']).to eq(table_name.to_s)
...@@ -40,7 +40,7 @@ module PartitioningHelpers ...@@ -40,7 +40,7 @@ module PartitioningHelpers
SQL SQL
end end
def find_partition_definition(partition, schema: 'partitions_dynamic') def find_partition_definition(partition)
connection.select_one(<<~SQL) connection.select_one(<<~SQL)
select select
parent_class.relname as base_table, parent_class.relname as base_table,
...@@ -48,10 +48,7 @@ module PartitioningHelpers ...@@ -48,10 +48,7 @@ module PartitioningHelpers
from pg_class from pg_class
inner join pg_inherits i on pg_class.oid = inhrelid inner join pg_inherits i on pg_class.oid = inhrelid
inner join pg_class parent_class on parent_class.oid = inhparent inner join pg_class parent_class on parent_class.oid = inhparent
inner join pg_namespace ON pg_namespace.oid = pg_class.relnamespace where pg_class.relname = '#{partition}' and pg_class.relispartition;
where pg_namespace.nspname = '#{schema}'
and pg_class.relname = '#{partition}'
and pg_class.relispartition
SQL SQL
end end
end end
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment