Function GetTaskJobId

src/backend/catalog/pg_task.c:175–206

* GetTaskJobId * Get the jobid of a task. */

 *		Get the jobid of a task.
 */
Oid
GetTaskJobId(const char *jobname, const char *username)
{
	Relation 	pg_task;
	HeapTuple	tup;
	SysScanDesc scanDescriptor = NULL;
	ScanKeyData scanKey[2];
	Oid			jobid = InvalidOid;
	Form_pg_task task;

	pg_task = table_open(TaskRelationId, AccessShareLock);

	ScanKeyInit(&scanKey[0], Anum_pg_task_jobname, BTEqualStrategyNumber,
				F_TEXTEQ, CStringGetTextDatum(jobname));
	ScanKeyInit(&scanKey[1], Anum_pg_task_username, BTEqualStrategyNumber,
				F_TEXTEQ, CStringGetTextDatum(username));

	scanDescriptor = systable_beginscan(pg_task, TaskJobNameUserNameIndexId,
										true, NULL, 2, scanKey);
	tup = systable_getnext(scanDescriptor);

	if (HeapTupleIsValid(tup))
	{
		task = (Form_pg_task) GETSTRUCT(tup);
		jobid = task->jobid;
	}

	systable_endscan(scanDescriptor);
	table_close(pg_task, AccessShareLock);

	return jobid;
}

/*
 * GetTaskNameById