DatabaseQueryListener
Table of Contents
Properties
-
$activeQueries
: array<string|int, mixed>
-
$telemetry
: OpenTelemetryManager
Methods
-
__construct()
: mixed
-
handleQueryExecuted()
: void
-
register()
: void
-
anonymizeBindings()
: array<string|int, mixed>
-
beforeQueryExecution()
: void
-
completeQueryTracking()
: void
-
extractSqlOperation()
: string
-
extractTableName()
: string|null
-
generateQueryId()
: string
-
getConnectionConfig()
: array<string|int, mixed>
-
handleMissedQuery()
: void
-
recordMetrics()
: void
-
setSpanAttributes()
: void
$activeQueries
private
array<string|int, mixed>
$activeQueries
= []
$telemetry
private
OpenTelemetryManager
$telemetry
__construct()
public
__construct(OpenTelemetryManager $telemetry) : mixed
Parameters
-
$telemetry
: OpenTelemetryManager
-
handleQueryExecuted()
public
handleQueryExecuted(QueryExecuted $event) : void
Parameters
-
$event
: QueryExecuted
-
register()
public
register() : void
anonymizeBindings()
private
anonymizeBindings(array<string|int, mixed> $bindings) : array<string|int, mixed>
Parameters
-
$bindings
: array<string|int, mixed>
-
Return values
array<string|int, mixed>
beforeQueryExecution()
private
beforeQueryExecution(string $query, array<string|int, mixed> $bindings) : void
Parameters
-
$query
: string
-
-
$bindings
: array<string|int, mixed>
-
completeQueryTracking()
private
completeQueryTracking(string $queryId, QueryExecuted $event) : void
Parameters
-
$queryId
: string
-
-
$event
: QueryExecuted
-
private
extractSqlOperation(string $sql) : string
Parameters
-
$sql
: string
-
private
extractTableName(string $sql) : string|null
Parameters
-
$sql
: string
-
Return values
string|null
generateQueryId()
private
generateQueryId(string $sql, array<string|int, mixed> $bindings) : string
Parameters
-
$sql
: string
-
-
$bindings
: array<string|int, mixed>
-
getConnectionConfig()
private
getConnectionConfig(string $connectionName) : array<string|int, mixed>
Parameters
-
$connectionName
: string
-
Return values
array<string|int, mixed>
handleMissedQuery()
private
handleMissedQuery(QueryExecuted $event) : void
Parameters
-
$event
: QueryExecuted
-
recordMetrics()
private
recordMetrics(QueryExecuted $event, string $operation, string|null $table) : void
Parameters
-
$event
: QueryExecuted
-
-
$operation
: string
-
-
$table
: string|null
-
setSpanAttributes()
private
setSpanAttributes(SpanInterface $span, string $query, array<string|int, mixed> $bindings, array<string|int, mixed> $config, string $operation, string|null $table, string $connectionName) : void
Parameters
-
$span
: SpanInterface
-
-
$query
: string
-
-
$bindings
: array<string|int, mixed>
-
-
$config
: array<string|int, mixed>
-
-
$operation
: string
-
-
$table
: string|null
-
-
$connectionName
: string
-