Commit 11987bac authored by Suleimi Ahmed's avatar Suleimi Ahmed 🔴
Browse files

feat(datastore): add index on blobs id column

parent e4427b17
Loading
Loading
Loading
Loading
+32 −0
Original line number Diff line number Diff line
//go:build integration

package postmigrations

import (
	"github.com/docker/distribution/registry/datastore/migrations"
	migrate "github.com/rubenv/sql-migrate"
)

func init() {
	m := &migrations.Migration{
		Migration: &migrate.Migration{
			Id: "20251210074156_post_create_blobs_partitions_id_index_testing",
			Up: []string{
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_0_on_id ON partitions.blobs_p_0 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_1_on_id ON partitions.blobs_p_1 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_2_on_id ON partitions.blobs_p_2 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_3_on_id ON partitions.blobs_p_3 USING btree (id)",
			},
			Down: []string{
				"DROP INDEX IF EXISTS partitions.index_blobs_p_0_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_1_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_2_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_3_on_id CASCADE",
			},
			DisableTransactionUp:   true,
			DisableTransactionDown: true,
		},
	}

	migrations.AppendPostMigration(m)
}
+58 −0
Original line number Diff line number Diff line
//go:build !integration

package postmigrations

import (
	"github.com/docker/distribution/registry/datastore/migrations"
	migrate "github.com/rubenv/sql-migrate"
)

func init() {
	m := &migrations.Migration{
		Migration: &migrate.Migration{
			Id: "20251210074231_post_create_blobs_partitions_id_index_batch_1",
			Up: []string{
				"SET statement_timeout TO 0",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_0_on_id ON partitions.blobs_p_0 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_1_on_id ON partitions.blobs_p_1 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_2_on_id ON partitions.blobs_p_2 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_3_on_id ON partitions.blobs_p_3 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_4_on_id ON partitions.blobs_p_4 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_5_on_id ON partitions.blobs_p_5 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_6_on_id ON partitions.blobs_p_6 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_7_on_id ON partitions.blobs_p_7 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_8_on_id ON partitions.blobs_p_8 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_9_on_id ON partitions.blobs_p_9 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_10_on_id ON partitions.blobs_p_10 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_11_on_id ON partitions.blobs_p_11 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_12_on_id ON partitions.blobs_p_12 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_13_on_id ON partitions.blobs_p_13 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_14_on_id ON partitions.blobs_p_14 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_15_on_id ON partitions.blobs_p_15 USING btree (id)",
				"RESET statement_timeout",
			},
			Down: []string{
				"DROP INDEX IF EXISTS partitions.index_blobs_p_0_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_1_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_2_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_3_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_4_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_5_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_6_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_7_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_8_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_9_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_10_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_11_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_12_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_13_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_14_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_15_on_id CASCADE",
			},
			DisableTransactionUp:   true,
			DisableTransactionDown: true,
		},
	}

	migrations.AppendPostMigration(m)
}
+58 −0
Original line number Diff line number Diff line
//go:build !integration

package postmigrations

import (
	"github.com/docker/distribution/registry/datastore/migrations"
	migrate "github.com/rubenv/sql-migrate"
)

func init() {
	m := &migrations.Migration{
		Migration: &migrate.Migration{
			Id: "20251210074415_post_create_blobs_partitions_id_index_batch_2",
			Up: []string{
				"SET statement_timeout TO 0",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_16_on_id ON partitions.blobs_p_16 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_17_on_id ON partitions.blobs_p_17 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_18_on_id ON partitions.blobs_p_18 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_19_on_id ON partitions.blobs_p_19 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_20_on_id ON partitions.blobs_p_20 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_21_on_id ON partitions.blobs_p_21 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_22_on_id ON partitions.blobs_p_22 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_23_on_id ON partitions.blobs_p_23 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_24_on_id ON partitions.blobs_p_24 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_25_on_id ON partitions.blobs_p_25 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_26_on_id ON partitions.blobs_p_26 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_27_on_id ON partitions.blobs_p_27 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_28_on_id ON partitions.blobs_p_28 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_29_on_id ON partitions.blobs_p_29 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_30_on_id ON partitions.blobs_p_30 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_31_on_id ON partitions.blobs_p_31 USING btree (id)",
				"RESET statement_timeout",
			},
			Down: []string{
				"DROP INDEX IF EXISTS partitions.index_blobs_p_16_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_17_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_18_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_19_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_20_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_21_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_22_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_23_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_24_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_25_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_26_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_27_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_28_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_29_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_30_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_31_on_id CASCADE",
			},
			DisableTransactionUp:   true,
			DisableTransactionDown: true,
		},
	}

	migrations.AppendPostMigration(m)
}
+58 −0
Original line number Diff line number Diff line
//go:build !integration

package postmigrations

import (
	"github.com/docker/distribution/registry/datastore/migrations"
	migrate "github.com/rubenv/sql-migrate"
)

func init() {
	m := &migrations.Migration{
		Migration: &migrate.Migration{
			Id: "20251210074419_post_create_blobs_partitions_id_index_batch_3",
			Up: []string{
				"SET statement_timeout TO 0",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_32_on_id ON partitions.blobs_p_32 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_33_on_id ON partitions.blobs_p_33 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_34_on_id ON partitions.blobs_p_34 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_35_on_id ON partitions.blobs_p_35 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_36_on_id ON partitions.blobs_p_36 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_37_on_id ON partitions.blobs_p_37 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_38_on_id ON partitions.blobs_p_38 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_39_on_id ON partitions.blobs_p_39 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_40_on_id ON partitions.blobs_p_40 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_41_on_id ON partitions.blobs_p_41 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_42_on_id ON partitions.blobs_p_42 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_43_on_id ON partitions.blobs_p_43 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_44_on_id ON partitions.blobs_p_44 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_45_on_id ON partitions.blobs_p_45 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_46_on_id ON partitions.blobs_p_46 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_47_on_id ON partitions.blobs_p_47 USING btree (id)",
				"RESET statement_timeout",
			},
			Down: []string{
				"DROP INDEX IF EXISTS partitions.index_blobs_p_32_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_33_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_34_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_35_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_36_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_37_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_38_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_39_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_40_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_41_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_42_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_43_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_44_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_45_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_46_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_47_on_id CASCADE",
			},
			DisableTransactionUp:   true,
			DisableTransactionDown: true,
		},
	}

	migrations.AppendPostMigration(m)
}
+58 −0
Original line number Diff line number Diff line
//go:build !integration

package postmigrations

import (
	"github.com/docker/distribution/registry/datastore/migrations"
	migrate "github.com/rubenv/sql-migrate"
)

func init() {
	m := &migrations.Migration{
		Migration: &migrate.Migration{
			Id: "20251210074422_post_create_blobs_partitions_id_index_batch_4",
			Up: []string{
				"SET statement_timeout TO 0",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_48_on_id ON partitions.blobs_p_48 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_49_on_id ON partitions.blobs_p_49 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_50_on_id ON partitions.blobs_p_50 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_51_on_id ON partitions.blobs_p_51 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_52_on_id ON partitions.blobs_p_52 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_53_on_id ON partitions.blobs_p_53 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_54_on_id ON partitions.blobs_p_54 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_55_on_id ON partitions.blobs_p_55 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_56_on_id ON partitions.blobs_p_56 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_57_on_id ON partitions.blobs_p_57 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_58_on_id ON partitions.blobs_p_58 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_59_on_id ON partitions.blobs_p_59 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_60_on_id ON partitions.blobs_p_60 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_61_on_id ON partitions.blobs_p_61 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_62_on_id ON partitions.blobs_p_62 USING btree (id)",
				"CREATE INDEX CONCURRENTLY IF NOT EXISTS index_blobs_p_63_on_id ON partitions.blobs_p_63 USING btree (id)",
				"RESET statement_timeout",
			},
			Down: []string{
				"DROP INDEX IF EXISTS partitions.index_blobs_p_48_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_49_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_50_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_51_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_52_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_53_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_54_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_55_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_56_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_57_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_58_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_59_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_60_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_61_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_62_on_id CASCADE",
				"DROP INDEX IF EXISTS partitions.index_blobs_p_63_on_id CASCADE",
			},
			DisableTransactionUp:   true,
			DisableTransactionDown: true,
		},
	}

	migrations.AppendPostMigration(m)
}
Loading