diff --git a/apps/studio/components/interfaces/TableGridEditor/GridHeaderActions.tsx b/apps/studio/components/interfaces/TableGridEditor/GridHeaderActions.tsx index 30e35398fbc..748a8f98eaa 100644 --- a/apps/studio/components/interfaces/TableGridEditor/GridHeaderActions.tsx +++ b/apps/studio/components/interfaces/TableGridEditor/GridHeaderActions.tsx @@ -159,16 +159,20 @@ const GridHeaderActions = ({ table, isViewSelected, isTableSelected }: GridHeade
{policies.length < 1 ? ( - - - - + + @@ -190,23 +194,24 @@ const GridHeaderActions = ({ table, isViewSelected, isTableSelected }: GridHeade ) : ( - - - + + )}
) : ( diff --git a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnEditor.tsx b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnEditor.tsx index 5a432887f5b..fd562a11a04 100644 --- a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnEditor.tsx +++ b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnEditor.tsx @@ -25,7 +25,10 @@ import { Constraint, useTableConstraintsQuery, } from 'data/database/constraints-query' -import { useForeignKeyConstraintsQuery } from 'data/database/foreign-key-constraints-query' +import { + ForeignKeyConstraint, + useForeignKeyConstraintsQuery, +} from 'data/database/foreign-key-constraints-query' import { useEnumeratedTypesQuery } from 'data/enumerated-types/enumerated-types-query' import { EXCLUDED_SCHEMAS_WITHOUT_EXTENSIONS } from 'lib/constants/schemas' import { Dictionary } from 'types' @@ -45,6 +48,7 @@ import { import ColumnForeignKey from './ColumnForeignKey' import ColumnType from './ColumnType' import HeaderTitle from './HeaderTitle' +import toast from 'react-hot-toast' export interface ColumnEditorProps { column?: PostgresColumn @@ -57,6 +61,8 @@ export interface ColumnEditorProps { configuration: { columnId?: string primaryKey?: Constraint + foreignKeyRelations: ForeignKey[] + existingForeignKeyRelations: ForeignKeyConstraint[] }, resolve: any ) => void @@ -107,6 +113,11 @@ const ColumnEditor = ({ const foreignKeys = foreignKeyMeta.filter((relation) => { return relation.source_id === column?.table_id && relation.source_columns.includes(column.name) }) + const lockColumnType = + fkRelations.find( + (fk) => + fk.columns.find((col) => col.source === columnFields?.name) !== undefined && !fk.toRemove + ) !== undefined useEffect(() => { if (visible) { @@ -147,7 +158,12 @@ const ColumnEditor = ({ const payload = isNewRecord ? generateCreateColumnPayload(selectedTable.id, columnFields) : generateUpdateColumnPayload(column!, selectedTable, columnFields) - const configuration = { columnId: column?.id, primaryKey } + const configuration = { + columnId: column?.id, + primaryKey, + foreignKeyRelations: fkRelations, + existingForeignKeyRelations: foreignKeys, + } saveChanges(payload, isNewRecord, configuration, resolve) } else { resolve() @@ -240,11 +256,9 @@ const ColumnEditor = ({ enumTypes={enumTypes} error={errors.format} description={ - columnFields.foreignKey !== undefined - ? 'Column type cannot be changed as it has a foreign key relation' - : '' + lockColumnType ? 'Column type cannot be changed as it has a foreign key relation' : '' } - disabled={columnFields.foreignKey !== undefined} + disabled={lockColumnType} onOptionSelect={(format: string) => onUpdateField({ format, defaultValue: null })} /> {columnFields.foreignKey === undefined && ( @@ -291,13 +305,13 @@ const ColumnEditor = ({ header={Foreign Keys} > -
- -
+ onUpdateField({ format, defaultValue: null })} + onUpdateFkRelations={setFkRelations} + /> diff --git a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnForeignKey.tsx b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnForeignKey.tsx index 67e6cd8fcd1..d55d02e9e09 100644 --- a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnForeignKey.tsx +++ b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ColumnEditor/ColumnForeignKey.tsx @@ -1,29 +1,45 @@ -import { noop } from 'lodash' -import { AlertDescription_Shadcn_, AlertTitle_Shadcn_, Alert_Shadcn_, Button } from 'ui' +import { useParams } from 'common' +import { useState } from 'react' +import { Button } from 'ui' import { useProjectContext } from 'components/layouts/ProjectLayout/ProjectContext' import { useForeignKeyConstraintsQuery } from 'data/database/foreign-key-constraints-query' +import useTable from 'hooks/misc/useTable' +import { ForeignKeySelector } from '../ForeignKeySelector/ForeignKeySelector' import { ForeignKey } from '../ForeignKeySelector/ForeignKeySelector.types' import { ColumnField } from '../SidePanelEditor.types' import { ForeignKeyRow } from '../TableEditor/ForeignKeysManagement/ForeignKeyRow' import { checkIfRelationChanged } from '../TableEditor/ForeignKeysManagement/ForeignKeysManagement.utils' -import { useTableEditorStateSnapshot } from 'state/table-editor' interface ColumnForeignKeyProps { column: ColumnField relations: ForeignKey[] closePanel: () => void + onUpdateColumnType: (type: string) => void + onUpdateFkRelations: (fks: ForeignKey[]) => void } -const ColumnForeignKey = ({ column, relations, closePanel }: ColumnForeignKeyProps) => { +const ColumnForeignKey = ({ + column, + relations, + closePanel, + onUpdateColumnType, + onUpdateFkRelations, +}: ColumnForeignKeyProps) => { + const { id: _id } = useParams() + const [open, setOpen] = useState(false) + const [selectedFk, setSelectedFk] = useState() + const { project } = useProjectContext() - const snap = useTableEditorStateSnapshot() const { data } = useForeignKeyConstraintsQuery({ projectRef: project?.ref, connectionString: project?.connectionString, schema: column.schema, }) + const id = _id ? Number(_id) : undefined + const { data: table } = useTable(id) + const getRelationStatus = (fk: ForeignKey) => { const existingRelation = (data ?? []).find((x) => x.id === fk.id) const stateRelation = relations.find((x) => x.id === fk.id) @@ -38,53 +54,88 @@ const ColumnForeignKey = ({ column, relations, closePanel }: ColumnForeignKeyPro } return ( -
-
- {relations.map((relation) => { - const status = getRelationStatus(relation) - return ( - - ) - })} -
- - - {relations.length > 0 ? ( - <> - These are the foreign keys which the column{' '} - {column.name} is included - - ) : column.isNewColumn ? ( - <>Foreign keys can be added after creating the column - ) : ( - <> - Foreign keys which include the column {column.name}{' '} - will be shown here - - )} - - - All foreign keys on the table can be managed by editing the{' '} - - {column.schema}.{column.table} - {' '} - table. - - - -
+ + + {table !== undefined && ( + { + setOpen(false) + setSelectedFk(undefined) + }} + onSaveRelation={(fk) => { + const existingRelationIds = relations.map((x) => x.id) + if (fk.id !== undefined && existingRelationIds.includes(fk.id)) { + onUpdateFkRelations( + relations.map((x) => { + if (x.id === fk.id) return fk + return x + }) + ) + } else { + onUpdateFkRelations(relations.concat([fk])) + } + const targetType = fk.columns.find((col) => col.source === column.name)?.targetType + if (targetType) onUpdateColumnType(targetType) + }} + /> + )} + ) } diff --git a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ForeignKeySelector/ForeignKeySelector.tsx b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ForeignKeySelector/ForeignKeySelector.tsx index ad3ffc64479..16f0a622a9f 100644 --- a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ForeignKeySelector/ForeignKeySelector.tsx +++ b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/ForeignKeySelector/ForeignKeySelector.tsx @@ -28,6 +28,7 @@ import { NUMERICAL_TYPES, TEXT_TYPES } from '../SidePanelEditor.constants' import { FOREIGN_KEY_CASCADE_OPTIONS } from './ForeignKeySelector.constants' import { ForeignKey } from './ForeignKeySelector.types' import { generateCascadeActionDescription } from './ForeignKeySelector.utils' +import { ColumnField } from '../SidePanelEditor.types' const EMPTY_STATE: ForeignKey = { id: undefined, @@ -40,7 +41,12 @@ const EMPTY_STATE: ForeignKey = { interface ForeignKeySelectorProps { visible: boolean - table: { id: number; name: string; columns: any[] } + table: { + id: number + name: string + columns: { id: string; name: string; format: string; isNewColumn: boolean }[] + } + column?: ColumnField // For ColumnEditor, to prefill when adding a new foreign key foreignKey?: ForeignKey onClose: () => void onSaveRelation: (fk: ForeignKey) => void @@ -49,6 +55,7 @@ interface ForeignKeySelectorProps { export const ForeignKeySelector = ({ visible, table, + column, foreignKey, onClose, onSaveRelation, @@ -83,17 +90,8 @@ export const ForeignKeySelector = ({ const updateSelectedTable = (tableId: number) => { setErrors({}) - if (!tableId) { - return setFk({ - ...EMPTY_STATE, - id: fk.id, - name: fk.name, - schema: fk.schema, - columns: [{ source: '', target: '' }], - }) - } const table = (tables ?? []).find((x) => x.id === tableId) - if (table) + if (table) { setFk({ ...EMPTY_STATE, id: fk.id, @@ -101,8 +99,12 @@ export const ForeignKeySelector = ({ tableId: table.id, schema: table.schema, table: table.name, - columns: [{ source: '', target: '' }], + columns: + column !== undefined + ? [{ source: column.name, target: '' }] + : [{ source: '', target: '' }], }) + } } const addColumn = () => { @@ -160,7 +162,7 @@ export const ForeignKeySelector = ({ fk.columns.forEach((column) => { const { source, target, sourceType: sType, targetType: tType } = column const sourceColumn = table.columns.find((col) => col.name === source) - const sourceType = sType ?? sourceColumn?.format + const sourceType = sType ?? sourceColumn?.format ?? '' const targetType = tType ?? selectedTable?.columns?.find((col) => col.name === target)?.format ?? '' @@ -246,6 +248,7 @@ export const ForeignKeySelector = ({ key={schema.id} value={schema.name} label={schema.name} + className="min-w-96" addOnBefore={() => } >
@@ -264,7 +267,7 @@ export const ForeignKeySelector = ({ value={selectedTable?.id ?? 1} onChange={(value: string) => updateSelectedTable(Number(value))} > - + --- {sortBy(tables, ['schema']).map((table) => { @@ -273,6 +276,7 @@ export const ForeignKeySelector = ({ key={table.id} value={table.id} label={table.name} + className="min-w-96" addOnBefore={() => } >
@@ -312,7 +316,7 @@ export const ForeignKeySelector = ({ )} {fk.columns.map((_, idx) => ( - +
{ const selectedColumnToEdit = snap.sidePanel?.type === 'column' && snap.sidePanel.column - const { columnId, primaryKey } = configuration + const { columnId, primaryKey, foreignKeyRelations, existingForeignKeyRelations } = configuration const response = isNewRecord ? await createColumn({ @@ -215,6 +220,7 @@ const SidePanelEditor = ({ payload: payload as CreateColumnPayload, selectedTable: selectedTable as PostgresTable, primaryKey, + foreignKeyRelations, }) : await updateColumn({ projectRef: project?.ref!, @@ -223,6 +229,8 @@ const SidePanelEditor = ({ payload: payload as UpdateColumnPayload, selectedTable: selectedTable as PostgresTable, primaryKey, + foreignKeyRelations, + existingForeignKeyRelations, }) if (response?.error) { diff --git a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/SidePanelEditor.utils.tsx b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/SidePanelEditor.utils.tsx index 0ad5c98e484..e9bf7ee13ed 100644 --- a/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/SidePanelEditor.utils.tsx +++ b/apps/studio/components/interfaces/TableGridEditor/SidePanelEditor/SidePanelEditor.utils.tsx @@ -269,12 +269,14 @@ export const createColumn = async ({ payload, selectedTable, primaryKey, + foreignKeyRelations = [], }: { projectRef: string connectionString: string | undefined payload: CreateColumnPayload selectedTable: PostgresTable primaryKey?: Constraint + foreignKeyRelations?: ForeignKey[] }) => { const toastId = toast.loading(`Creating column "${payload.name}"...`) try { @@ -311,6 +313,17 @@ export const createColumn = async ({ primaryKeyColumns ) } + + // Then add the foreign key constraints here + if (foreignKeyRelations.length > 0) { + await addForeignKey({ + projectRef, + connectionString, + table: { schema: column.schema, name: column.table }, + foreignKeys: foreignKeyRelations, + }) + } + toast.success(`Successfully created column "${column.name}"`, { id: toastId }) } catch (error: any) { toast.error(`An error occurred while creating the column "${payload.name}"`, { id: toastId }) @@ -325,6 +338,8 @@ export const updateColumn = async ({ payload, selectedTable, primaryKey, + foreignKeyRelations = [], + existingForeignKeyRelations = [], skipPKCreation, skipSuccessMessage = false, }: { @@ -334,14 +349,16 @@ export const updateColumn = async ({ payload: UpdateColumnPayload selectedTable: PostgresTable primaryKey?: Constraint + foreignKeyRelations?: ForeignKey[] + existingForeignKeyRelations?: ForeignKeyConstraint[] skipPKCreation?: boolean skipSuccessMessage?: boolean }) => { try { const { isPrimaryKey, ...formattedPayload } = payload const column = await updateDatabaseColumn({ - projectRef: projectRef, - connectionString: connectionString, + projectRef, + connectionString, id, payload: formattedPayload, }) @@ -374,6 +391,18 @@ export const updateColumn = async ({ ) } } + + // Then update foreign keys + if (foreignKeyRelations.length > 0) { + await updateForeignKeys({ + projectRef, + connectionString, + table: { schema: column.schema, name: column.table }, + foreignKeys: foreignKeyRelations, + existingForeignKeyRelations, + }) + } + if (!skipSuccessMessage) toast.success(`Successfully updated column "${column.name}"`) } catch (error: any) { return { error } @@ -762,43 +791,13 @@ export const updateTable = async ({ } // Foreign keys will get updated here accordingly - const relationsToAdd = foreignKeyRelations.filter((x) => typeof x.id === 'string') - if (relationsToAdd.length > 0) { - await addForeignKey({ - projectRef, - connectionString, - table: updatedTable, - foreignKeys: relationsToAdd, - }) - } - - const relationsToRemove = foreignKeyRelations.filter((x) => x.toRemove) - if (relationsToRemove.length > 0) { - await removeForeignKey({ - projectRef, - connectionString, - table: updatedTable, - foreignKeys: relationsToRemove, - }) - } - - const remainingRelations = foreignKeyRelations.filter( - (x) => typeof x.id === 'number' && !x.toRemove - ) - const relationsToUpdate = remainingRelations.filter((x) => { - const existingRelation = existingForeignKeyRelations.find((y) => x.id === y.id) - if (existingRelation !== undefined) { - return checkIfRelationChanged(existingRelation as unknown as ForeignKeyConstraint, x) - } else return false + await updateForeignKeys({ + projectRef, + connectionString, + table: updatedTable, + foreignKeys: foreignKeyRelations, + existingForeignKeyRelations, }) - if (relationsToUpdate.length > 0) { - await updateForeignKey({ - projectRef, - connectionString, - table: updatedTable, - foreignKeys: relationsToUpdate, - }) - } const queryClient = getQueryClient() @@ -939,3 +938,54 @@ export const insertTableRows = async ( } return { error: insertError } } + +const updateForeignKeys = async ({ + projectRef, + connectionString, + table, + foreignKeys, + existingForeignKeyRelations, +}: { + projectRef: string + connectionString?: string + table: { schema: string; name: string } + foreignKeys: ForeignKey[] + existingForeignKeyRelations: ForeignKeyConstraint[] +}) => { + // Foreign keys will get updated here accordingly + const relationsToAdd = foreignKeys.filter((x) => typeof x.id === 'string') + if (relationsToAdd.length > 0) { + await addForeignKey({ + projectRef, + connectionString, + table, + foreignKeys: relationsToAdd, + }) + } + + const relationsToRemove = foreignKeys.filter((x) => x.toRemove) + if (relationsToRemove.length > 0) { + await removeForeignKey({ + projectRef, + connectionString, + table, + foreignKeys: relationsToRemove, + }) + } + + const remainingRelations = foreignKeys.filter((x) => typeof x.id === 'number' && !x.toRemove) + const relationsToUpdate = remainingRelations.filter((x) => { + const existingRelation = existingForeignKeyRelations.find((y) => x.id === y.id) + if (existingRelation !== undefined) { + return checkIfRelationChanged(existingRelation as unknown as ForeignKeyConstraint, x) + } else return false + }) + if (relationsToUpdate.length > 0) { + await updateForeignKey({ + projectRef, + connectionString, + table, + foreignKeys: relationsToUpdate, + }) + } +}