Files
supabase/apps/studio/data/database-cron-jobs/database-cron-timezone-query.ts
Charis 116faefcda studio: convert more executeSql callers to SafeSqlFragment (#45645)
## Summary

- Converts ~27 `executeSql` call sites in `apps/studio/data/**` to build
SQL through `safeSql` / `ident` / `literal` / `keyword` /
`joinSqlFragments` instead of raw template-string interpolation.
- Tightens the `useDatabaseCronJobCreateMutation` and
`useDatabaseEventTriggerCreateMutation` `sql`/`query` parameter types
from `string` to `SafeSqlFragment` (callers already produce one).
- Updates `getDeleteEnumeratedTypeSQL` in `packages/pg-meta` to return
`SafeSqlFragment`.
- Fixes a bug noticed while testing where Queues integration does not
correctly handle queues with uppercase names.

## Pages to manually test

- Integrations > Cron Jobs
- Integrations > Queues
- Database > Triggers > Event Triggers
- Database > Indexes
- Reports > Query Performance
- Storage

<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->

## Summary by CodeRabbit

## Release Notes

* **Bug Fixes**
  * Queue lookups now correctly handle case-insensitive queue names.
* Queue table references are now properly managed and consistently
applied throughout the queue management interface.
  * Improved queue name display normalization in the user interface.

* **Chores**
* Enhanced SQL query safety across the database layer through
parameterized query construction and safer templating approaches.

<!-- end of auto-generated comment: release notes by coderabbit.ai -->
2026-05-06 12:21:48 -04:00

39 lines
1.3 KiB
TypeScript

import { safeSql } from '@supabase/pg-meta/src/pg-format'
import { useQuery } from '@tanstack/react-query'
import { databaseCronJobsKeys } from './keys'
import { executeSql } from '@/data/sql/execute-sql-query'
import type { ResponseError, UseCustomQueryOptions } from '@/types'
export type DatabaseCronJobsVariables = {
projectRef?: string
connectionString?: string | null
}
export async function getDatabaseCronTimezone({
projectRef,
connectionString,
}: DatabaseCronJobsVariables) {
if (!projectRef) throw new Error('Project ref is required')
const { result } = await executeSql({
projectRef,
connectionString,
sql: safeSql`select setting from pg_settings where name = 'cron.timezone';`,
})
return result[0].setting
}
export type DatabaseCronJobError = ResponseError
export const useCronTimezoneQuery = <TData = string>(
{ projectRef, connectionString }: DatabaseCronJobsVariables,
{ enabled = true, ...options }: UseCustomQueryOptions<string, DatabaseCronJobError, TData> = {}
) =>
useQuery<string, DatabaseCronJobError, TData>({
queryKey: databaseCronJobsKeys.timezone(projectRef),
queryFn: () => getDatabaseCronTimezone({ projectRef, connectionString }),
enabled: enabled && typeof projectRef !== 'undefined',
...options,
})