Method batchUpdateAttributes

internal/storage/postgres/data_writer.go:506–519

Batch update attributes

(batch *pgx.Batch, xid db.XID8, tenantID string, deleteClauses []squirrel.Eq)

// Batch update attributes
func (w *DataWriter) batchUpdateAttributes(batch *pgx.Batch, xid db.XID8, tenantID string, deleteClauses []squirrel.Eq) error {
	for _, condition := range deleteClauses {
		query, args, err := w.database.Builder.Update(AttributesTable).
			Set("expired_tx_id", xid).
			Where(squirrel.Eq{"expired_tx_id": utils.ActiveRecordTxnID, "tenant_id": tenantID}).
			Where(condition).
			ToSql()
		if err != nil {
			return err
		}
		batch.Queue(query, args...)
	}
	return nil
}

// Build delete clauses for attributes
func buildDeleteClausesForAttributes(attributeCollection *database.AttributeCollection) []squirrel.Eq { // Build delete clauses