Function updateBalanceChunk

database/balance.go:951–1073

(ctx context.Context, tx *sql.Tx, balances []*model.Balance)

}

func updateBalanceChunk(ctx context.Context, tx *sql.Tx, balances []*model.Balance) error {
	if len(balances) == 0 {
		return nil
	}

	var query strings.Builder
	query.WriteString(`
		UPDATE ledgerforge.balances AS b
		SET balance = v.balance,
		    credit_balance = v.credit_balance,
		    debit_balance = v.debit_balance,
		    inflight_balance = v.inflight_balance,
		    inflight_credit_balance = v.inflight_credit_balance,
		    inflight_debit_balance = v.inflight_debit_balance,
		    currency = v.currency,
		    currency_multiplier = v.currency_multiplier,
		    ledger_id = v.ledger_id,
		    created_at = v.created_at,
		    version = b.version + 1
		FROM (VALUES
	`)

	args := make([]interface{}, 0, len(balances)*12)
	for i, balance := range balances {
		if i > 0 {
			query.WriteString(",")
		}
		base := i*12 + 1
		query.WriteString(fmt.Sprintf(
			"($%d,$%d,$%d,$%d,$%d,$%d,$%d,$%d,$%d,$%d,$%d,$%d)",
			base,
			base+1,
			base+2,
			base+3,
			base+4,
			base+5,
			base+6,
			base+7,
			base+8,
			base+9,
			base+10,
			base+11,
		))
		args = append(args,
			balance.BalanceID,
			balance.Balance.String(),
			balance.CreditBalance.String(),
			balance.DebitBalance.String(),
			balance.InflightBalance.String(),
			balance.InflightCreditBalance.String(),
			balance.InflightDebitBalance.String(),
			balance.Currency,
			balance.CurrencyMultiplier,
			balance.LedgerID,
			balance.CreatedAt,
			balance.Version,
		)
	}