22 lines
742 B
SQL
22 lines
742 B
SQL
-- name: UpsertSubscriptionMapping :one
|
|
INSERT INTO stripe.subscription_mappings (subscription_id, stripe_subscription_id, sync_status)
|
|
VALUES ($1, $2, $3)
|
|
ON CONFLICT (subscription_id) DO UPDATE
|
|
SET stripe_subscription_id = EXCLUDED.stripe_subscription_id,
|
|
sync_status = EXCLUDED.sync_status,
|
|
updated_at = NOW()
|
|
RETURNING *;
|
|
|
|
-- name: GetSubscriptionMappingBySubscriptionID :one
|
|
SELECT * FROM stripe.subscription_mappings
|
|
WHERE subscription_id = $1;
|
|
|
|
-- name: GetSubscriptionMappingByStripeID :one
|
|
SELECT * FROM stripe.subscription_mappings
|
|
WHERE stripe_subscription_id = $1;
|
|
|
|
-- name: UpdateSubscriptionMappingSyncStatus :exec
|
|
UPDATE stripe.subscription_mappings
|
|
SET sync_status = $2, updated_at = NOW()
|
|
WHERE subscription_id = $1;
|