Function generateForeignKeyQuery

packages/node-core/src/db/sync-helper.ts:658–690

(attribute: ModelAttributeColumnOptions, tableName: string)

  `ALTER TABLE "${schemaName}"."${tableName}" DROP CONSTRAINT IF EXISTS ${fkConstraint};`;

export function generateForeignKeyQuery(attribute: ModelAttributeColumnOptions, tableName: string): string | void {
  const references = attribute?.references as ModelAttributeColumnReferencesOptions;
  if (!references) {
    return;
  }
  const foreignTable = references.model as TableNameWithSchema;
  assert(attribute.field, 'Missing field on attribute');
  const fkey = getFkConstraint(tableName, attribute.field);
  let query = `
  DO $$
  BEGIN
    ALTER TABLE "${foreignTable.schema}"."${tableName}"
      ADD
      CONSTRAINT ${fkey}
      FOREIGN KEY (${attribute.field})
      REFERENCES "${foreignTable.schema}"."${foreignTable.tableName}" (${references.key})`;
  if (attribute.onDelete) {
    query += ` ON DELETE ${attribute.onDelete}`;
  }
  if (attribute.onUpdate) {
    query += ` ON UPDATE ${attribute.onUpdate}`;
  }
  if (references.deferrable) {
    query += ` DEFERRABLE`;
  }
  query += `;
  EXCEPTION
    WHEN duplicate_object THEN
        RAISE NOTICE 'Constraint already exists. Ignoring...';
  END$$;
`;
  return `${query.trim()};`;
}

// indexes
export const dropIndexQuery = (schema: string, hashedIndexName: string): string =>