Method batchInsertAttributes

internal/storage/postgres/data_writer.go:488–503

Batch insert attributes

(batch *pgx.Batch, xid db.XID8, tenantID string, attributeCollection *database.AttributeCollection)

// Batch insert attributes
func (w *DataWriter) batchInsertAttributes(batch *pgx.Batch, xid db.XID8, tenantID string, attributeCollection *database.AttributeCollection) error {
	aiter := attributeCollection.CreateAttributeIterator()
	for aiter.HasNext() {
		a := aiter.GetNext()
		jsonBytes, err := protojson.Marshal(a.GetValue())
		if err != nil {
			return err
		}
		jsonStr := string(jsonBytes)
		batch.Queue(
			"INSERT INTO attributes (entity_type, entity_id, attribute, value, created_tx_id, tenant_id) VALUES ($1, $2, $3, $4, $5, $6)",
			a.GetEntity().GetType(), a.GetEntity().GetId(), a.GetAttribute(), jsonStr, xid, tenantID,
		)
	}
	return nil
}

// Batch update attributes
func (w *DataWriter) batchUpdateAttributes(batch *pgx.Batch, xid db.XID8, tenantID string, deleteClauses []squirrel.Eq) error {