mirrors/homebox
1
0
Fork 0
mirror of https://github.com/sysadminsmedia/homebox.git synced 2026-01-03 19:44:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

What should be a working Postgres migration

Browse Source
This commit is contained in:
Matthew Kilgore
2025-09-10 20:28:02 -04:00
parent fa9b7af117
commit 5456390b63
2 changed files with 95 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
backend/internal/data/main.go
View File

@@ -8,11 +8,12 @@ import (
"github.com/sysadminsmedia/homebox/backend/internal/data/ent"
_ "github.com/sysadminsmedia/homebox/backend/internal/data/ent/migrate"
_ "github.com/lib/pq"
_ "github.com/mattn/go-sqlite3"
)
func main() {
client, err := ent.Open("sqlite3", "file?mode=memory&cache=shared&_fk=1")
client, err := ent.Open("postgres", "host=localhost port=5432 user=homebox dbname=homebox password=homebox sslmode=disable")
if err != nil {
log.Fatalf("failed connecting to mysql: %v", err)
}

170
backend/internal/data/migrations/postgres/20250831120000_add_entity_tables.go
View File

@@ -4,9 +4,10 @@ import (
"context"
"database/sql"
"fmt"
"time"
"github.com/google/uuid"
"github.com/pressly/goose/v3"
"time"
)
//nolint:gochecknoinits
@@ -17,19 +18,21 @@ func init() {
func Up20250831120000(ctx context.Context, tx *sql.DB) error {
// Create entity_types table
_, err := tx.ExecContext(ctx, `
CREATE TABLE IF NOT EXISTS "entity_types" (
"id" uuid NOT NULL,
"created_at" timestamp WITH TIME ZONE NOT NULL,
"updated_at" timestamp WITH TIME ZONE NOT NULL,
"name" character varying NOT NULL,
"description" character varying NULL,
"icon" character varying NULL,
"color" character varying NULL,
"is_location" boolean NOT NULL DEFAULT false,
"group_entity_types" uuid NOT NULL,
PRIMARY KEY ("id"),
CONSTRAINT "entity_types_groups_entity_types" FOREIGN KEY ("group_entity_types") REFERENCES "groups" ("id") ON UPDATE NO ACTION ON DELETE CASCADE
CREATE TABLE "entity_types" (
"id" uuid NOT NULL,
"created_at" timestamptz NOT NULL,
"updated_at" timestamptz NOT NULL,
"name" character varying NOT NULL,
"description" character varying NULL,
"icon" character varying NULL,
"color" character varying NULL,
"is_location" boolean NOT NULL DEFAULT false,
"group_entity_types" uuid NOT NULL,
PRIMARY KEY ("id"),
CONSTRAINT "entity_types_groups_entity_types" FOREIGN KEY ("group_entity_types") REFERENCES "groups" ("id") ON DELETE CASCADE
);
CREATE INDEX "entitytype_name" ON "entity_types" ("name");
CREATE INDEX "entitytype_is_location" ON "entity_types" ("is_location");
`)
if err != nil {
return fmt.Errorf("failed to create entity_types table: %w", err)
@@ -37,40 +40,46 @@ func Up20250831120000(ctx context.Context, tx *sql.DB) error {
// Create entities table
_, err = tx.ExecContext(ctx, `
CREATE TABLE IF NOT EXISTS "entities" (
"id" uuid NOT NULL,
"created_at" timestamp WITH TIME ZONE NOT NULL,
"updated_at" timestamp WITH TIME ZONE NOT NULL,
"name" character varying NOT NULL,
"description" character varying NULL,
"import_ref" character varying NULL,
"notes" character varying NULL,
"quantity" bigint NOT NULL DEFAULT 1,
"insured" boolean NOT NULL DEFAULT false,
"archived" boolean NOT NULL DEFAULT false,
"asset_id" bigint NOT NULL DEFAULT 0,
"serial_number" character varying NULL,
"model_number" character varying NULL,
"manufacturer" character varying NULL,
"lifetime_warranty" boolean NOT NULL DEFAULT false,
"warranty_expires" timestamp WITH TIME ZONE NULL,
CREATE TABLE "entities" (
"id" uuid NOT NULL,
"created_at" timestamptz NOT NULL,
"updated_at" timestamptz NOT NULL,
"name" character varying NOT NULL,
"description" character varying NULL,
"import_ref" character varying NULL,
"notes" character varying NULL,
"quantity" bigint NOT NULL DEFAULT 1,
"insured" boolean NOT NULL DEFAULT false,
"archived" boolean NOT NULL DEFAULT false,
"asset_id" bigint NOT NULL DEFAULT 0,
"sync_child_entities_locations" boolean NOT NULL DEFAULT false,
"serial_number" character varying NULL,
"model_number" character varying NULL,
"manufacturer" character varying NULL,
"lifetime_warranty" boolean NOT NULL DEFAULT false,
"warranty_expires" timestamptz NULL,
"warranty_details" character varying NULL,
"purchase_time" timestamp WITH TIME ZONE NULL,
"purchase_time" timestamptz NULL,
"purchase_from" character varying NULL,
"purchase_price" double precision NOT NULL DEFAULT 0,
"sold_time" timestamp WITH TIME ZONE NULL,
"sold_to" character varying NULL,
"sold_time" timestamptz NULL, "sold_to" character varying NULL,
"sold_price" double precision NOT NULL DEFAULT 0,
"sold_notes" character varying NULL,
"entity_parent" uuid NULL,
"entity_location" uuid NULL,
"entity_type_entities" uuid NULL,
"group_entities" uuid NOT NULL,
"entity_children" uuid NULL,
"entity_type" uuid NOT NULL,
"sync_child_entities_locations" boolean NOT NULL DEFAULT false,
PRIMARY KEY ("id"),
CONSTRAINT "entities_groups_entities" FOREIGN KEY ("group_entities") REFERENCES "groups" ("id") ON UPDATE NO ACTION ON DELETE CASCADE,
CONSTRAINT "entities_entities_children" FOREIGN KEY ("entity_children") REFERENCES "entities" ("id") ON UPDATE NO ACTION ON DELETE SET NULL,
CONSTRAINT "entities_entity_types" FOREIGN KEY ("entity_type") REFERENCES "entity_types" ("id") ON UPDATE NO ACTION ON DELETE CASCADE
);
CONSTRAINT "entities_entities_parent" FOREIGN KEY ("entity_parent") REFERENCES "entities" ("id") ON DELETE SET NULL,
CONSTRAINT "entities_entities_location" FOREIGN KEY ("entity_location") REFERENCES "entities" ("id") ON DELETE SET NULL,
CONSTRAINT "entities_entity_types_entities" FOREIGN KEY ("entity_type_entities") REFERENCES "entity_types" ("id") ON DELETE SET NULL,
CONSTRAINT "entities_groups_entities" FOREIGN KEY ("group_entities") REFERENCES "groups" ("id") ON DELETE CASCADE);
CREATE INDEX "entity_name" ON "entities" ("name");
CREATE INDEX "entity_manufacturer" ON "entities" ("manufacturer");
CREATE INDEX "entity_model_number" ON "entities" ("model_number");
CREATE INDEX "entity_serial_number" ON "entities" ("serial_number");
CREATE INDEX "entity_archived" ON "entities" ("archived");
CREATE INDEX "entity_asset_id" ON "entities" ("asset_id");
`)
if err != nil {
return fmt.Errorf("failed to create entities table: %w", err)
@@ -120,7 +129,7 @@ func Up20250831120000(ctx context.Context, tx *sql.DB) error {
_, err = tx.ExecContext(ctx, `
INSERT INTO "entities" (
"id", "created_at", "updated_at", "name", "description",
"group_entities", "entity_children", "entity_type"
"group_entities", "entity_parent", "entity_type_entities"
)
SELECT
l."id", l."created_at", l."updated_at", l."name", l."description",
@@ -140,8 +149,8 @@ func Up20250831120000(ctx context.Context, tx *sql.DB) error {
"asset_id", "serial_number", "model_number", "manufacturer",
"lifetime_warranty", "warranty_expires", "warranty_details", "purchase_time",
"purchase_from", "purchase_price", "sold_time", "sold_to",
"sold_price", "sold_notes", "group_entities", "entity_children", "sync_child_entities_locations",
"entity_type")
"sold_price", "sold_notes", "group_entities", "entity_parent", "sync_child_entities_locations",
"entity_type_entities")
SELECT
i."id", i."created_at", i."updated_at", i."name", i."description",
i."import_ref", i."notes", i."quantity", i."insured", i."archived",
@@ -158,27 +167,10 @@ func Up20250831120000(ctx context.Context, tx *sql.DB) error {
}
_, err = tx.ExecContext(ctx, `
ALTER TABLE "item_fields" ADD COLUMN "entity_fields" uuid NULL;
UPDATE "item_fields" SET "entity_fields" = "item_fields";
ALTER TABLE "item_fields" DROP CONSTRAINT "item_fields_items_fields";
ALTER TABLE "item_fields" RENAME TO "entity_fields";
ALTER TABLE "entity_fields" ADD CONSTRAINT "entity_fields_entities_fields"
FOREIGN KEY ("entity_fields") REFERENCES "entities" ("id")
ON UPDATE NO ACTION ON DELETE CASCADE;
ALTER TABLE "entity_fields" DROP COLUMN "item_fields";
`)
if err != nil {
return fmt.Errorf("failed to migrate item_fields to entity_fields: %w", err)
}
_, err = tx.ExecContext(ctx, `
ALTER TABLE "maintenance_entries" ADD COLUMN "entity_id" uuid NULL;
ALTER TABLE "maintenance_entries" DROP CONSTRAINT "maintenance_entries_items_maintenance_entries",
ADD COLUMN "entity_id" uuid NOT NULL;
UPDATE "maintenance_entries" SET "entity_id" = "item_id";
ALTER TABLE "maintenance_entries" DROP CONSTRAINT "maintenance_entries_items_maintenance_entries";
ALTER TABLE "maintenance_entries"
ADD CONSTRAINT "maintenance_entries_entities_maintenance_entries"
FOREIGN KEY ("entity_id") REFERENCES "entities" ("id")
ON UPDATE NO ACTION ON DELETE CASCADE;
ALTER TABLE "maintenance_entries" ADD CONSTRAINT "maintenance_entries_entities_maintenance_entries" FOREIGN KEY ("entity_id") REFERENCES "entities" ("id") ON DELETE CASCADE;
ALTER TABLE "maintenance_entries" DROP COLUMN "item_id";
`)
if err != nil {
@@ -186,30 +178,54 @@ func Up20250831120000(ctx context.Context, tx *sql.DB) error {
}
_, err = tx.ExecContext(ctx, `
ALTER TABLE "attachments" ADD COLUMN "entity_attachments" uuid NULL;
ALTER TABLE "attachments" DROP CONSTRAINT "attachments_no_self_reference",
DROP CONSTRAINT "attachments_items_attachments",
ALTER COLUMN "mime_type" SET NOT NULL,
ADD COLUMN "entity_attachments" uuid NULL,
ADD CONSTRAINT "attachments_entities_attachments" FOREIGN KEY ("entity_attachments") REFERENCES "entities" ("id") ON DELETE CASCADE;
UPDATE "attachments" SET "entity_attachments" = "item_attachments";
ALTER TABLE "attachments" DROP CONSTRAINT "attachments_items_attachments";
ALTER TABLE "attachments"
ADD CONSTRAINT "attachments_entities_attachments"
FOREIGN KEY ("entity_attachments") REFERENCES "entities" ("id")
ON UPDATE NO ACTION ON DELETE CASCADE;
ALTER TABLE "attachments" DROP COLUMN "item_attachments";
CREATE UNIQUE INDEX "attachments_attachment_thumbnail_key" ON "attachments" ("attachment_thumbnail");
`)
if err != nil {
return fmt.Errorf("failed to migrate attachments to use entities: %w", err)
}
_, err = tx.ExecContext(ctx, `
CREATE TABLE IF NOT EXISTS "label_entities"
(
"label_id" uuid NOT NULL,
"entity_id" uuid NOT NULL,
PRIMARY KEY ("label_id", "entity_id")
);
CREATE TABLE "entity_fields" (
"id" uuid NOT NULL,
"created_at" timestamptz NOT NULL,
"updated_at" timestamptz NOT NULL,
"name" character varying NOT NULL,
"description" character varying NULL,
"type" character varying NOT NULL,
"text_value" character varying NULL,
"number_value" bigint NULL,
"boolean_value" boolean NOT NULL DEFAULT false,
"time_value" timestamptz NOT NULL,
"entity_fields" uuid NULL,
PRIMARY KEY ("id"),
CONSTRAINT "entity_fields_entities_fields" FOREIGN KEY ("entity_fields") REFERENCES "entities" ("id") ON DELETE CASCADE);
INSERT INTO "entity_fields" ("id", "created_at", "updated_at", "name", "description", "type", "text_value", "number_value", "boolean_value", "time_value", "entity_fields")
SELECT "id", "created_at", "updated_at", "name", "description", "type", "text_value", "number_value", "boolean_value", "time_value", item_fields."item_fields"
FROM "item_fields";
`)
if err != nil {
return fmt.Errorf("failed to create entity_fields table and migrate data: %w", err)
}
_, err = tx.ExecContext(ctx, `
CREATE TABLE "label_entities"(
"label_id" uuid NOT NULL,
"entity_id" uuid NOT NULL,
PRIMARY KEY ("label_id", "entity_id"),
CONSTRAINT "label_entities_label_id" FOREIGN KEY ("label_id") REFERENCES "labels" ("id") ON DELETE CASCADE,
CONSTRAINT "label_entities_entity_id" FOREIGN KEY ("entity_id") REFERENCES "entities" ("id") ON DELETE CASCADE);
INSERT INTO "label_entities" ("label_id", "entity_id")
SELECT "label_id", "item_id" FROM "label_items";
ALTER TABLE "label_entities" ADD CONSTRAINT "label_entities_entity_id" FOREIGN KEY ("entity_id") REFERENCES "entities" ("id") ON UPDATE NO ACTION ON DELETE CASCADE;
ALTER TABLE "label_entities" ADD CONSTRAINT "label_entities_label_id" FOREIGN KEY ("label_id") REFERENCES "labels" ("id") ON UPDATE NO ACTION ON DELETE CASCADE;
`)
if err != nil {
return fmt.Errorf("failed to create label_entities table and migrate data: %w", err)