chore: split queries.sql into files by table (#762)

coderd/database/queries/provisionerjobs.sql

@@ -0,0 +1,90 @@
+-- Acquires the lock for a single job that isn't started, completed,
+-- canceled, and that matches an array of provisioner types.
+--
+-- SKIP LOCKED is used to jump over locked rows. This prevents
+-- multiple provisioners from acquiring the same jobs. See:
+-- https://www.postgresql.org/docs/9.5/sql-select.html#SQL-FOR-UPDATE-SHARE
+-- name: AcquireProvisionerJob :one
+UPDATE
+	provisioner_jobs
+SET
+	started_at = @started_at,
+	updated_at = @started_at,
+	worker_id = @worker_id
+WHERE
+	id = (
+		SELECT
+			id
+		FROM
+			provisioner_jobs AS nested
+		WHERE
+			nested.started_at IS NULL
+			AND nested.canceled_at IS NULL
+			AND nested.completed_at IS NULL
+			AND nested.provisioner = ANY(@types :: provisioner_type [ ])
+		ORDER BY
+			nested.created_at FOR
+		UPDATE
+			SKIP LOCKED
+		LIMIT
+			1
+	) RETURNING *;
+
+-- name: GetProvisionerJobByID :one
+SELECT
+	*
+FROM
+	provisioner_jobs
+WHERE
+	id = $1;
+
+-- name: GetProvisionerJobsByIDs :many
+SELECT
+	*
+FROM
+	provisioner_jobs
+WHERE
+	id = ANY(@ids :: uuid [ ]);
+
+-- name: InsertProvisionerJob :one
+INSERT INTO
+	provisioner_jobs (
+		id,
+		created_at,
+		updated_at,
+		organization_id,
+		initiator_id,
+		provisioner,
+		storage_method,
+		storage_source,
+		"type",
+		"input"
+	)
+VALUES
+	($1, $2, $3, $4, $5, $6, $7, $8, $9, $10) RETURNING *;
+
+-- name: UpdateProvisionerJobByID :exec
+UPDATE
+	provisioner_jobs
+SET
+	updated_at = $2
+WHERE
+	id = $1;
+
+-- name: UpdateProvisionerJobWithCancelByID :exec
+UPDATE
+	provisioner_jobs
+SET
+	canceled_at = $2
+WHERE
+	id = $1;
+
+-- name: UpdateProvisionerJobWithCompleteByID :exec
+UPDATE
+	provisioner_jobs
+SET
+	updated_at = $2,
+	completed_at = $3,
+	error = $4
+WHERE
+	id = $1;