Merge pull request #13 from nettrash/postgresql-code-block-escape

Added $pg_dbms_job$ as a block for job execution.
MigOpsRepos · Nov 8, 2023 · 4d6884c · 4d6884c
2 parents 7e1729d + bc342a7
commit 4d6884c
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/bin/pg_dbms_job b/bin/pg_dbms_job
@@ -946,15 +946,15 @@ sub subprocess_asynchronous_jobs
 		my $sqlstate = '';
 		my $t0 = time;
 
-		my $codetoexec = qq{DO \$\$
+		my $codetoexec = qq{DO \$pg_dbms_job\$
 DECLARE
 	job bigint := $jobid;
 	next_date timestamp with time zone := current_timestamp;
 	broken boolean := false;
 BEGIN
 	$ASYNC_JOBS{ $jobid }{ 'what' }
 END;
-\$\$;
+\$pg_dbms_job\$;
 };
 		dprint('DEBUG', "executing code of job id $jobid: $ASYNC_JOBS{ $jobid }{ 'what' }");
 		if (not $ldbh->do($codetoexec))
@@ -1092,15 +1092,15 @@ sub subprocess_scheduled_jobs
 		my $status = '';
 		my $sqlstate = '';
 
-		my $codetoexec = qq{DO \$\$
+		my $codetoexec = qq{DO \$pg_dbms_job\$
 DECLARE
 	job bigint := $jobid;
 	next_date timestamp with time zone := current_timestamp;
 	broken boolean := false;
 BEGIN
 	$SCHEDULED_JOBS{ $jobid }{ 'what' }
 END;
-\$\$;
+\$pg_dbms_job\$;
 };
 		dprint('DEBUG', "executing code of job id $jobid: $SCHEDULED_JOBS{ $jobid }{ 'what' }");