Joshen/fe 2558 shift sql queries to contextual folders update codeowners (#42770)

## Context

Related to Dashboard Scalability, specifically having Postgres team as
CODEOWNERS for dashboard queries

This is just a clean up as we're currently piling manual queries into
one folder under `data/sql/queries`, whereas I reckon it'll be better
for each query to sit within their RQ folder for better context.

Am opting the naming format for files housing queries to be `*.sql.ts`,
and also updating CODEOWNERS to reflect as such

Next step will also be to shift all the dashboard queries within pg-meta
into studio itself as requested by the pg-meta team

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

## Summary by CodeRabbit

* **Refactor**
* Consolidated and reorganized internal module structure for the data
layer to improve maintainability and reduce redundancy.
* Streamlined import paths across components to align with new
consolidated module organization.

* **Chores**
* Updated code ownership patterns to reflect reorganized file structure.

<!-- end of auto-generated comment: release notes by coderabbit.ai -->

---------

Co-authored-by: Ali Waseem <waseema393@gmail.com>

Author: joshenlim

.github/CODEOWNERS

@@ -19,6 +19,6 @@
 /apps/studio/components/interfaces/Organization/Documents/          @supabase/security
 /apps/studio/pages/new/index.tsx                                    @supabase/security
 
-/apps/studio/data/sql/queries/                                      @supabase/postgres @avallete
+/apps/studio/data/**/*.sql.ts                                       @supabase/postgres @avallete
 
 /packages/shared-data/compute-disk-limits.ts @supabase/infra

apps/studio/components/interfaces/Integrations/CronJobs/CronJobsTab.CleanupNotice.tsx

@@ -1,4 +1,4 @@
-import { getScheduleDeleteCronJobRunDetailsSql } from 'data/sql/queries/delete-cron-job-run-details'
+import { getScheduleDeleteCronJobRunDetailsSql } from 'data/database-cron-jobs/database-cron-jobs.sql'
 import { CheckCircle2, XCircle } from 'lucide-react'
 import {
   Button,

apps/studio/components/interfaces/Integrations/CronJobs/CronJobsTab.useCleanupActions.ts

@@ -1,11 +1,11 @@
-import { useExecuteSqlMutation } from 'data/sql/execute-sql-mutation'
 import {
   CTID_BATCH_PAGE_SIZE,
   getDeleteOldCronJobRunDetailsByCtidKey,
   getDeleteOldCronJobRunDetailsByCtidSql,
   getJobRunDetailsPageCountKey,
   getJobRunDetailsPageCountSql,
-} from 'data/sql/queries/delete-cron-job-run-details'
+} from 'data/database-cron-jobs/database-cron-jobs.sql'
+import { useExecuteSqlMutation } from 'data/sql/execute-sql-mutation'
 import { useCallback, useRef, useState } from 'react'
 import { toast } from 'sonner'
 

apps/studio/components/interfaces/Storage/StorageSettings/StorageFileSizeLimitErrorMessage.tsx

@@ -1,9 +1,9 @@
+import { InlineLink } from 'components/ui/InlineLink'
+import { LARGEST_SIZE_LIMIT_BUCKETS_COUNT } from 'data/storage/storage.sql'
 import Link from 'next/link'
 import { type FieldError } from 'react-hook-form'
-
-import { InlineLink } from 'components/ui/InlineLink'
-import { LARGEST_SIZE_LIMIT_BUCKETS_COUNT } from 'data/sql/queries/get-largest-size-limit-buckets'
 import { cn, Tooltip, TooltipContent, TooltipTrigger } from 'ui'
+
 import {
   decodeBucketLimitErrorMessage,
   formatBytesForDisplay,

apps/studio/data/sql/queries/get-user.ts apps/studio/data/auth/auth.sql.tsapps/studio/data/sql/queries/get-user.ts renamed to apps/studio/data/auth/auth.sql.ts

@@ -1,11 +1,11 @@
 import { useQuery } from '@tanstack/react-query'
-
-import { UUID_REGEX } from '@/lib/constants'
 import { executeSql, type ExecuteSqlError } from 'data/sql/execute-sql-query'
-import { getUserSQL } from 'data/sql/queries/get-user'
 import { UseCustomQueryOptions } from 'types'
+
+import { getUserSQL } from './auth.sql'
 import { authKeys } from './keys'
 import { User } from './users-infinite-query'
+import { UUID_REGEX } from '@/lib/constants'
 
 type UserVariables = {
   projectRef?: string

apps/studio/data/auth/user-query.ts

@@ -1,11 +1,7 @@
 import { useQuery } from '@tanstack/react-query'
-
 import type { ConnectionVars } from 'data/common.types'
+import { getLiveTupleEstimate, getLiveTupleEstimateKey } from 'data/database/database.sql'
 import { executeSql } from 'data/sql/execute-sql-query'
-import {
-  getLiveTupleEstimate,
-  getLiveTupleEstimateKey,
-} from 'data/sql/queries/get-live-tuple-stats'
 import type { UseCustomQueryOptions } from 'types'
 
 type DatabaseCronJobsCountEstimateVariables = ConnectionVars

apps/studio/data/database-cron-jobs/database-cron-jobs-count-estimate-query.ts

@@ -2,7 +2,7 @@ import { InfiniteData, useInfiniteQuery } from '@tanstack/react-query'
 import { COST_THRESHOLD_ERROR, executeSql } from 'data/sql/execute-sql-query'
 import type { ResponseError, UseCustomInfiniteQueryOptions } from 'types'
 
-import { getCronJobsSql } from '../sql/queries/get-cron-jobs'
+import { getCronJobsSql } from './database-cron-jobs.sql'
 import { databaseCronJobsKeys } from './keys'
 
 export const CRON_JOBS_PAGE_LIMIT = 20

apps/studio/data/database-cron-jobs/database-cron-jobs-infinite-query.ts

@@ -2,12 +2,12 @@ import { InfiniteData, useInfiniteQuery } from '@tanstack/react-query'
 import { executeSql } from 'data/sql/execute-sql-query'
 import type { ResponseError, UseCustomInfiniteQueryOptions } from 'types'
 
-import { getCronJobsMinimalSql } from '../sql/queries/get-cron-jobs'
 import {
   CRON_JOBS_PAGE_LIMIT,
   CronJob,
   DatabaseCronJobRunsVariables,
 } from './database-cron-jobs-infinite-query'
+import { getCronJobsMinimalSql } from './database-cron-jobs.sql'
 import { databaseCronJobsKeys } from './keys'
 
 export async function getDatabaseCronJobsMinimal({

apps/studio/data/database-cron-jobs/database-cron-jobs-minimal-infinite-query.ts

@@ -1,6 +1,6 @@
 import { literal } from '@supabase/pg-meta/src/pg-format'
 
-import { sqlKeys } from '../keys'
+import { sqlKeys } from '../sql/keys'
 
 const CRON_CLEANUP_SCHEDULE_NAME = 'delete-job-run-details'
 const CRON_CLEANUP_SCHEDULE_EXPRESSION = '0 12 * * *'
@@ -89,3 +89,74 @@ export const getScheduleDeleteCronJobRunDetailsKey = (
   projectRef: string | undefined,
   interval: string
 ) => sqlKeys.query(projectRef, ['cron-job-run-details', 'schedule', interval])
+
+// [Joshen] Just omits the LEFT JOIN as that's the heavy part
+export const getCronJobsMinimalSql = ({
+  searchTerm,
+  page,
+  limit,
+}: {
+  searchTerm?: string
+  page: number
+  limit: number
+}) =>
+  `
+SELECT 
+  job.jobid,
+  job.jobname,
+  job.schedule,
+  job.command,
+  job.active
+FROM 
+  cron.job job
+${!!searchTerm ? `WHERE job.jobname ILIKE ${literal(`%${searchTerm}%`)}` : ''}
+ORDER BY job.jobid
+LIMIT ${limit}
+OFFSET ${page * limit};
+`.trim()
+
+export const getCronJobsSql = ({
+  searchTerm,
+  page,
+  limit,
+}: {
+  searchTerm?: string
+  page: number
+  limit: number
+}) =>
+  `
+WITH latest_runs AS (
+  SELECT 
+    jobid,
+    status,
+    MAX(start_time) AS latest_run
+  FROM cron.job_run_details
+  GROUP BY jobid, status
+), most_recent_runs AS (
+  SELECT 
+    jobid, 
+    status, 
+    latest_run
+  FROM latest_runs lr1
+  WHERE latest_run = (
+    SELECT MAX(latest_run) 
+    FROM latest_runs lr2 
+    WHERE lr2.jobid = lr1.jobid
+  )
+)
+SELECT 
+  job.jobid,
+  job.jobname,
+  job.schedule,
+  job.command,
+  job.active,
+  mr.latest_run,
+  mr.status
+FROM 
+  cron.job job
+LEFT JOIN most_recent_runs mr ON job.jobid = mr.jobid
+${!!searchTerm ? `WHERE job.jobname ILIKE ${literal(`%${searchTerm}%`)}` : ''}
+ORDER BY job.jobid
+LIMIT ${limit}
+OFFSET ${page * limit};
+`.trim()