Skip to content
Merged
Prev Previous commit
Next Next commit
Add if not exists
  • Loading branch information
jjoyce0510 committed Jun 17, 2021
commit 54dabdc5962215fef4d5774926b4b22dfe49024a
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public Function<UpgradeContext, UpgradeStepResult> executable() {
return (context) -> {
try {
_server.execute(_server.createSqlUpdate(
"CREATE INDEX aspectName ON metadata_aspect_v2 (aspect)"));
"CREATE INDEX IF NOT EXISTS aspectName ON metadata_aspect_v2 (aspect)"));
} catch (Exception e) {
context.report().addLine(String.format("Failed to create aspect index for metadata_aspect_v2: %s", e.toString()));
return new DefaultUpgradeStepResult(
Expand Down
2 changes: 1 addition & 1 deletion docker/mariadb/init.sql
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ create table metadata_aspect_v2 (
);

-- create index on the "aspect" column to support aspect-oriented queries.
CREATE INDEX aspectName ON metadata_aspect_v2 (aspect);
create INDEX if not exists aspectName on metadata_aspect_v2 (aspect);

insert into metadata_aspect_v2 (urn, aspect, version, metadata, createdon, createdby) values(
'urn:li:corpuser:datahub',
Expand Down
2 changes: 1 addition & 1 deletion docker/mysql-setup/init.sql
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ WHERE NOT EXISTS (SELECT * from metadata_aspect_v2);
DROP TABLE temp_metadata_aspect_v2;

-- create index on the "aspect" column to support aspect-oriented queries.
CREATE INDEX aspectName ON metadata_aspect_v2 (aspect);
CREATE INDEX IF NOT EXISTS aspectName ON metadata_aspect_v2 (aspect);

-- create metadata index table
CREATE TABLE IF NOT EXISTS metadata_index (
Expand Down
2 changes: 1 addition & 1 deletion docker/mysql/init.sql
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ CREATE TABLE metadata_aspect_v2 (
);

-- create index on the "aspect" column to support aspect-oriented queries.
CREATE INDEX aspectName ON metadata_aspect_v2 (aspect);
CREATE INDEX IF NOT EXISTS aspectName ON metadata_aspect_v2 (aspect);

INSERT INTO metadata_aspect_v2 (urn, aspect, version, metadata, createdon, createdby) VALUES(
'urn:li:corpuser:datahub',
Expand Down
2 changes: 1 addition & 1 deletion docker/postgres/init.sql
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ create table metadata_aspect_v2 (
);

-- create index on the "aspect" column to support aspect-oriented queries.
CREATE INDEX aspectName ON metadata_aspect_v2 (aspect);
CREATE INDEX IF NOT EXISTS aspectName ON metadata_aspect_v2 (aspect);

insert into metadata_aspect_v2 (urn, aspect, version, metadata, createdon, createdby) values(
'urn:li:corpuser:datahub',
Expand Down