stmt.go

package pgpq

const (
	stmtPush = `
		INSERT INTO pgpq_tasks (namespace, priority, payload, not_before, created_at, updated_at)
		VALUES ($1, $2, $3, $4, $5, $6)
		RETURNING id
	`

	stmtPushWithID = `
		INSERT INTO pgpq_tasks (id, namespace, priority, payload, not_before, created_at, updated_at)
		VALUES ($1, $2, $3, $4, $5, $6, $7)
		RETURNING id
	`

	stmtGet = `
		SELECT
			id,
			namespace,
			priority,
			payload,
			not_before,
			created_at,
			updated_at
		FROM pgpq_tasks
		WHERE id = $1
	`

	stmtShift = `
		SELECT
			id,
			namespace,
			priority,
			payload,
			not_before,
			created_at,
			updated_at
		FROM pgpq_tasks
		WHERE namespace = $1
			AND not_before <= $2
		ORDER BY
			priority DESC,
			updated_at ASC
		FOR UPDATE SKIP LOCKED
		LIMIT 1
	`

	stmtClaim = `
		SELECT
			id,
			namespace,
			priority,
			payload,
			not_before,
			created_at,
			updated_at
		FROM pgpq_tasks
		WHERE id = $1
		FOR UPDATE SKIP LOCKED
		LIMIT 1
	`

	stmtList = `
		SELECT
			id,
			namespace,
			priority,
			payload,
			not_before,
			created_at,
			updated_at
		FROM pgpq_tasks
		WHERE namespace = $1
		ORDER BY
			priority DESC,
			updated_at ASC
		LIMIT $2
		OFFSET $3
	`

	stmtUpdate = `
		UPDATE pgpq_tasks
		SET
			namespace  = $1,
			priority   = $2,
			payload    = $3,
			not_before = $4,
			updated_at = $5
		WHERE id = $6
	`

	stmtDone = `
		DELETE FROM pgpq_tasks
		WHERE id = $1
	`
)