Function resolvePartitionKey

packages/sql/src/schema/partitioning.ts:211–235

(meta: EntityMetadata, key: string, quoteIdentifier: (id: string) => string)

};

const resolvePartitionKey = (meta: EntityMetadata, key: string, quoteIdentifier: (id: string) => string): string => {
  const trimmed = key.trim().replaceAll('"', '');

  if (!trimmed) {
    throw new Error(`Entity ${meta.className} has invalid partitionBy option: empty partition key`);
  }

  const prop =
    meta.root.properties[trimmed as keyof typeof meta.root.properties] ??
    Object.values(meta.root.properties).find(
      candidate => candidate.fieldNames?.length === 1 && candidate.fieldNames[0] === trimmed,
    );

  if (!prop) {
    throw new Error(`Entity ${meta.className} has invalid partitionBy option: unknown partition key '${key.trim()}'`);
  }

  if (prop.fieldNames?.length !== 1) {
    throw new Error(
      `Entity ${meta.className} has invalid partitionBy option: partition key '${key.trim()}' maps to multiple columns ('${prop.fieldNames?.join("', '")}'); list them explicitly as partition keys`,
    );
  }

  return quoteIdentifier(prop.fieldNames[0]);
};

/**
 * Resolve the partition expression to a SQL fragment. Column-reference forms (array of keys