Method JobInsertFastMany

riverdriver/riversqlite/river_sqlite_driver.go:529–558

(ctx context.Context, params *riverdriver.JobInsertFastManyParams)

}

func (e *Executor) JobInsertFastMany(ctx context.Context, params *riverdriver.JobInsertFastManyParams) ([]*riverdriver.JobInsertFastResult, error) {
	// We use a special `(xmax != 0)` trick in Postgres to determine whether an
	// upserted row was inserted or skipped, but as far as I can find, there's no
	// such trick possible in SQLite. Instead, we roll a random nonce and insert
	// it to metadata. If the same nonce comes back, we know we really inserted
	// the row. If not, we're getting an existing row back.
	uniqueNonce := randutil.Hex(8)

	jobsParam, err := sqliteJobInsertFastManyJobsParam(params.Jobs, uniqueNonce)
	if err != nil {
		return nil, err
	}

	jobs, err := dbsqlc.New().JobInsertFastMany(schemaTemplateParam(ctx, params.Schema), e.dbtx, jobsParam)
	if err != nil {
		return nil, interpretError(err)
	}

	return sliceutil.MapError(jobs, func(internal *dbsqlc.RiverJob) (*riverdriver.JobInsertFastResult, error) {
		job, err := jobRowFromInternal(internal)
		if err != nil {
			return nil, err
		}

		return &riverdriver.JobInsertFastResult{
			Job:                      job,
			UniqueSkippedAsDuplicate: gjson.GetBytes(job.Metadata, rivercommon.MetadataKeyUniqueNonce).Str != uniqueNonce,
		}, nil
	})
}

func (e *Executor) JobInsertFastManyNoReturning(ctx context.Context, params *riverdriver.JobInsertFastManyParams) (int, error) {
	jobsParam, err := sqliteJobInsertFastManyJobsParam(params.Jobs, "")