Hangfire: Add job directly to DB

If you really want to add job via DB for some reason, you can try to do this SQL query. After some time (QueuePollInterval configured in Hangfire Server) Hangfire will run this enqueued job

But keep in mind, that this is a "hack" and Hangfire tables could be changed in future. So when able, use other approach

BEGIN TRANSACTION

SET XACT_ABORT ON

DECLARE @queue VARCHAR(20) = 'default'

DECLARE @culture VARCHAR(20) = '"en-US"'

DECLARE @uiCulture VARCHAR(20) = '"en-US"'

-- You can InvocationData and Arguments from some completed job in DB

DECLARE @invocationData VARCHAR(MAX) = '{"t":"YourAppNamespace.JobClass, YourAppAssembly","m":"JobName"}'

DECLARE @arguments VARCHAR(MAX) = '[]'

DECLARE @currentTime DATETIME = GETUTCDATE()

IF (SELECT Version FROM HangFire.[Schema]) <> 7
BEGIN
    PRINT 'Invalid HangFire schema, please review the script'
    SET NOEXEC ON
END

DECLARE @jobId TABLE (ID INT)

INSERT INTO HangFire.Job
(
    StateId,
    StateName,
    InvocationData,
    Arguments,
    CreatedAt,
    ExpireAt
)
OUTPUT inserted.Id INTO @jobId
VALUES
(
    NULL,
    'Enqueued',
    @invocationData,
    @arguments,
    @currentTime,
    NULL
)

DECLARE @unixTimeSeconds VARCHAR(20) = CAST(DATEDIFF(SECOND, {d '1970-01-01'}, GETUTCDATE()) AS VARCHAR(20))

DECLARE @stateId TABLE (ID INT)

INSERT INTO HangFire.State
(
    JobId,
    Name,
    Reason,
    CreatedAt,
    Data
)
OUTPUT inserted.Id INTO @stateId
VALUES
(
    (SELECT Id FROM @jobId),
    'Enqueued',
    'Added via SQL script',
    @currentTime,
    CONCAT('{"EnqueuedAt":"', @unixTimeSeconds, '000","Queue":"', @queue, '"}')
)

UPDATE HangFire.Job
SET StateId = (SELECT Id FROM @stateId)
WHERE Id = (SELECT Id FROM @jobId)

INSERT INTO HangFire.JobParameter
(
    JobId,
    Name,
    Value
)
VALUES
(
    (SELECT Id FROM @jobId),
    'CurrentCulture',
    @culture
),
(
    (SELECT Id FROM @jobId),
    'CurrentUICulture',
    @uiCulture
),
(
    (SELECT Id FROM @jobId),
    'Time',
    @unixTimeSeconds
)

INSERT INTO HangFire.JobQueue
(
    JobId,
    Queue
)
VALUES
(
    (SELECT Id FROM @jobId),
    @queue
)

SET NOEXEC OFF

COMMIT