diff --git a/packages/drizzle/src/queries/buildOrderBy.ts b/packages/drizzle/src/queries/buildOrderBy.ts index da779bbb200..758b8854ce7 100644 --- a/packages/drizzle/src/queries/buildOrderBy.ts +++ b/packages/drizzle/src/queries/buildOrderBy.ts @@ -1,7 +1,7 @@ -import type { Table } from 'drizzle-orm' +import type { SQL, Table } from 'drizzle-orm' import type { FlattenedField, Sort } from 'payload' -import { asc, desc } from 'drizzle-orm' +import { asc, desc, or } from 'drizzle-orm' import type { DrizzleAdapter, GenericColumn } from '../types.js' import type { BuildQueryJoinAliases, BuildQueryResult } from './buildQuery.js' @@ -16,6 +16,7 @@ type Args = { joins: BuildQueryJoinAliases locale?: string parentIsLocalized: boolean + rawSort?: SQL selectFields: Record sort?: Sort tableName: string @@ -31,6 +32,7 @@ export const buildOrderBy = ({ joins, locale, parentIsLocalized, + rawSort, selectFields, sort, tableName, @@ -74,12 +76,18 @@ export const buildOrderBy = ({ value: sortProperty, }) if (sortTable?.[sortTableColumnName]) { + let order = sortDirection === 'asc' ? asc : desc + + if (rawSort) { + order = () => rawSort + } + orderBy.push({ column: aliasTable && tableName === getNameFromDrizzleTable(sortTable) ? aliasTable[sortTableColumnName] : sortTable[sortTableColumnName], - order: sortDirection === 'asc' ? asc : desc, + order, }) selectFields[sortTableColumnName] = sortTable[sortTableColumnName] diff --git a/packages/drizzle/src/queries/buildQuery.ts b/packages/drizzle/src/queries/buildQuery.ts index 9b5326b9cc8..b91869c46f7 100644 --- a/packages/drizzle/src/queries/buildQuery.ts +++ b/packages/drizzle/src/queries/buildQuery.ts @@ -79,6 +79,7 @@ const buildQuery = function buildQuery({ joins, locale, parentIsLocalized, + rawSort: context.rawSort, selectFields, sort: context.sort, tableName, diff --git a/packages/drizzle/src/queries/parseParams.ts b/packages/drizzle/src/queries/parseParams.ts index 90bba4136e1..8ca75036694 100644 --- a/packages/drizzle/src/queries/parseParams.ts +++ b/packages/drizzle/src/queries/parseParams.ts @@ -14,7 +14,7 @@ import { buildAndOrConditions } from './buildAndOrConditions.js' import { getTableColumnFromPath } from './getTableColumnFromPath.js' import { sanitizeQueryValue } from './sanitizeQueryValue.js' -export type QueryContext = { sort: Sort } +export type QueryContext = { rawSort?: SQL; sort: Sort } type Args = { adapter: DrizzleAdapter @@ -348,6 +348,7 @@ export function parseParams({ } if (geoConstraints.length) { context.sort = relationOrPath + context.rawSort = sql`${table[columnName]} <-> ST_SetSRID(ST_MakePoint(${lng}, ${lat}), 4326)` constraints.push(and(...geoConstraints)) } break