// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.31.1
// source: query.sql

package db

import (
	"context"
	"time"
)

const updateEntities = `-- name: UpdateEntities :execrows
UPDATE target_table
SET active = 0
WHERE EXISTS (
  SELECT 1
  FROM source_table s
  WHERE s.updated_at >= ?
)
`

func (q *Queries) UpdateEntities(ctx context.Context, updatedAfter time.Time) (int64, error) {
	result, err := q.db.ExecContext(ctx, updateEntities, updatedAfter)
	if err != nil {
		return 0, err
	}
	return result.RowsAffected()
}

// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.25.0
// source: query.sql

package db

import (
	"context"
)

const updateEntities = `-- name: UpdateEntities :execrows
UPDATE target_table
SET active = 0
WHERE NOT (
    EXISTS (
        SELECT 1
        FROM source_table s
        WHERE s.updated_at >= sqlc.arg(updated_after)
    )
)
`

func (q *Queries) UpdateEntities(ctx context.Context) (int64, error) {
	result, err := q.db.ExecContext(ctx, updateEntities)
	if err != nil {
		return 0, err
	}
	return result.RowsAffected()
}

-- no output --

CREATE TABLE target_table
(
    id     BIGINT PRIMARY KEY,
    active BOOLEAN NOT NULL
);

CREATE TABLE source_table
(
    id         BIGINT PRIMARY KEY,
    updated_at TIMESTAMP NOT NULL
);

-- name: UpdateEntities :execrows
UPDATE target_table
SET active = 0
WHERE NOT (
    EXISTS (
        SELECT 1
        FROM source_table s
        WHERE s.updated_at >= sqlc.arg(updated_after)
    )
);

{
  "version": "2",
  "sql": [{
    "schema": "schema.sql",
    "queries": "query.sql",
    "engine": "mysql",
    "gen": {
      "go": {
        "out": "db"
      }
    }
  }]
}