Skip to content

Commit df4a7f6

Browse files
committed
Improved code [skip ci]
1 parent 86db430 commit df4a7f6

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

lib/pgslice/cli/prep_hash.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ def prep_hash(table, column, partitions)
2222

2323
primary_key = table.primary_key
2424
if primary_key.include?(column)
25-
queries << "ALTER TABLE #{quote_table(intermediate_table)} ADD PRIMARY KEY (#{primary_key.map { |k| quote_ident(k) }.join(", ")});" if primary_key.any?
25+
queries << "ALTER TABLE #{quote_table(intermediate_table)} ADD PRIMARY KEY (#{primary_key.map { |k| quote_ident(k) }.join(", ")});"
2626
end
2727

2828
table.index_defs.each do |index_def|
@@ -39,8 +39,8 @@ def prep_hash(table, column, partitions)
3939
CREATE TABLE #{quote_table(partition)} PARTITION OF #{quote_table(intermediate_table)} FOR VALUES WITH (MODULUS #{partitions}, REMAINDER #{i});
4040
SQL
4141

42-
unless primary_key.include?(column)
43-
queries << "ALTER TABLE #{quote_table(partition)} ADD PRIMARY KEY (#{primary_key.map { |k| quote_ident(k) }.join(", ")});" if primary_key.any?
42+
if primary_key.any? && !primary_key.include?(column)
43+
queries << "ALTER TABLE #{quote_table(partition)} ADD PRIMARY KEY (#{primary_key.map { |k| quote_ident(k) }.join(", ")});"
4444
end
4545
end
4646

0 commit comments

Comments
 (0)