代码拉取完成,页面将自动刷新
// 版权所有 GoFrame 作者(https://goframe.org)。保留所有权利。
//
// 此源代码形式受 MIT 许可证的条款约束。
// 如果未随此文件一起分发 MIT 许可证的副本,
// 您可以在 https://github.com/gogf/gf 获取一个。
// md5:a114f4bdd106ab31
package db类
import (
"context"
"fmt"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/codes"
semconv "go.opentelemetry.io/otel/semconv/v1.18.0"
"go.opentelemetry.io/otel/trace"
"gitee.com/go_888/goframe/net/gtrace"
)
const (
traceInstrumentName = "github.com/gogf/gf/v2/database/gdb"
traceAttrDbType = "db.type"
traceAttrDbHost = "db.host"
traceAttrDbPort = "db.port"
traceAttrDbName = "db.name"
traceAttrDbUser = "db.user"
traceAttrDbLink = "db.link"
traceAttrDbGroup = "db.group"
traceEventDbExecution = "db.execution"
traceEventDbExecutionSql = "db.execution.sql"
traceEventDbExecutionCost = "db.execution.cost"
traceEventDbExecutionRows = "db.execution.rows"
traceEventDbExecutionTxID = "db.execution.txid"
traceEventDbExecutionType = "db.execution.type"
)
// addSqlToTracing 如果启用追踪,则将SQL信息添加到追踪器中。 md5:a591b35a0635d132
func (c *X结构_Core) traceSpanEnd(ctx context.Context, span trace.Span, sql *X结构_Sql) {
if gtrace.IsUsingDefaultProvider() || !gtrace.IsTracingInternal() {
return
}
if sql.Error != nil {
span.SetStatus(codes.Error, fmt.Sprintf(`%+v`, sql.Error))
}
labels := make([]attribute.KeyValue, 0)
labels = append(labels, gtrace.CommonLabels()...)
labels = append(labels,
attribute.String(traceAttrDbType, c.db.X取当前节点配置().Type),
semconv.DBStatement(sql.Format),
)
if c.db.X取当前节点配置().Host != "" {
labels = append(labels, attribute.String(traceAttrDbHost, c.db.X取当前节点配置().Host))
}
if c.db.X取当前节点配置().Port != "" {
labels = append(labels, attribute.String(traceAttrDbPort, c.db.X取当前节点配置().Port))
}
if c.db.X取当前节点配置().Name != "" {
labels = append(labels, attribute.String(traceAttrDbName, c.db.X取当前节点配置().Name))
}
if c.db.X取当前节点配置().User != "" {
labels = append(labels, attribute.String(traceAttrDbUser, c.db.X取当前节点配置().User))
}
if filteredLink := c.db.X取Core对象().X取数据库链接信息(); filteredLink != "" {
labels = append(labels, attribute.String(traceAttrDbLink, c.db.X取Core对象().X取数据库链接信息()))
}
if group := c.db.X取配置组名称(); group != "" {
labels = append(labels, attribute.String(traceAttrDbGroup, group))
}
span.SetAttributes(labels...)
events := []attribute.KeyValue{
attribute.String(traceEventDbExecutionSql, sql.Format),
attribute.String(traceEventDbExecutionCost, fmt.Sprintf(`%d ms`, sql.End-sql.Start)),
attribute.String(traceEventDbExecutionRows, fmt.Sprintf(`%d`, sql.RowsAffected)),
}
if sql.IsTransaction {
if v := ctx.Value(transactionIdForLoggerCtx); v != nil {
events = append(events, attribute.String(
traceEventDbExecutionTxID, fmt.Sprintf(`%d`, v.(uint64)),
))
}
}
events = append(events, attribute.String(traceEventDbExecutionType, string(sql.Type)))
span.AddEvent(traceEventDbExecution, trace.WithAttributes(events...))
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。