77 lines
2.6 KiB
Go
77 lines
2.6 KiB
Go
// Code generated by sqlc. DO NOT EDIT.
|
|
// versions:
|
|
// sqlc v1.29.0
|
|
// source: payment_method_mappings.sql
|
|
|
|
package stripe
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
)
|
|
|
|
const getPaymentMethodMappingByPaymentMethodID = `-- name: GetPaymentMethodMappingByPaymentMethodID :one
|
|
SELECT payment_method_id, stripe_payment_method_id, sync_status, created_at, updated_at FROM stripe.payment_method_mappings
|
|
WHERE payment_method_id = $1
|
|
`
|
|
|
|
func (q *Queries) GetPaymentMethodMappingByPaymentMethodID(ctx context.Context, paymentMethodID string) (PaymentMethodMapping, error) {
|
|
row := q.db.QueryRowContext(ctx, getPaymentMethodMappingByPaymentMethodID, paymentMethodID)
|
|
var i PaymentMethodMapping
|
|
err := row.Scan(
|
|
&i.PaymentMethodID,
|
|
&i.StripePaymentMethodID,
|
|
&i.SyncStatus,
|
|
&i.CreatedAt,
|
|
&i.UpdatedAt,
|
|
)
|
|
return i, err
|
|
}
|
|
|
|
const getPaymentMethodMappingByStripeID = `-- name: GetPaymentMethodMappingByStripeID :one
|
|
SELECT payment_method_id, stripe_payment_method_id, sync_status, created_at, updated_at FROM stripe.payment_method_mappings
|
|
WHERE stripe_payment_method_id = $1
|
|
`
|
|
|
|
func (q *Queries) GetPaymentMethodMappingByStripeID(ctx context.Context, stripePaymentMethodID sql.NullString) (PaymentMethodMapping, error) {
|
|
row := q.db.QueryRowContext(ctx, getPaymentMethodMappingByStripeID, stripePaymentMethodID)
|
|
var i PaymentMethodMapping
|
|
err := row.Scan(
|
|
&i.PaymentMethodID,
|
|
&i.StripePaymentMethodID,
|
|
&i.SyncStatus,
|
|
&i.CreatedAt,
|
|
&i.UpdatedAt,
|
|
)
|
|
return i, err
|
|
}
|
|
|
|
const upsertPaymentMethodMapping = `-- name: UpsertPaymentMethodMapping :one
|
|
INSERT INTO stripe.payment_method_mappings (payment_method_id, stripe_payment_method_id, sync_status)
|
|
VALUES ($1, $2, $3)
|
|
ON CONFLICT (payment_method_id) DO UPDATE
|
|
SET stripe_payment_method_id = EXCLUDED.stripe_payment_method_id,
|
|
sync_status = EXCLUDED.sync_status,
|
|
updated_at = NOW()
|
|
RETURNING payment_method_id, stripe_payment_method_id, sync_status, created_at, updated_at
|
|
`
|
|
|
|
type UpsertPaymentMethodMappingParams struct {
|
|
PaymentMethodID string `json:"payment_method_id"`
|
|
StripePaymentMethodID sql.NullString `json:"stripe_payment_method_id"`
|
|
SyncStatus string `json:"sync_status"`
|
|
}
|
|
|
|
func (q *Queries) UpsertPaymentMethodMapping(ctx context.Context, arg UpsertPaymentMethodMappingParams) (PaymentMethodMapping, error) {
|
|
row := q.db.QueryRowContext(ctx, upsertPaymentMethodMapping, arg.PaymentMethodID, arg.StripePaymentMethodID, arg.SyncStatus)
|
|
var i PaymentMethodMapping
|
|
err := row.Scan(
|
|
&i.PaymentMethodID,
|
|
&i.StripePaymentMethodID,
|
|
&i.SyncStatus,
|
|
&i.CreatedAt,
|
|
&i.UpdatedAt,
|
|
)
|
|
return i, err
|
|
}
|