Skip to content

Commit 4ec85ff

Browse files
rekbyrekby
committed
fix name of database sql
1 parent b035f5d commit 4ec85ff

File tree

1 file changed

+35
-35
lines changed

1 file changed

+35
-35
lines changed

‎log/sql.go‎

Lines changed: 35 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -25,18 +25,18 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
2525
return nil
2626
}
2727
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "connector", "connect")
28-
l.Log(ctx, "ydb sql database connect starting...")
28+
l.Log(ctx, "ydb database/sql connect starting...")
2929
start := time.Now()
3030

3131
return func(info trace.DatabaseSQLConnectorConnectDoneInfo) {
3232
if info.Error == nil {
33-
l.Log(WithLevel(ctx, DEBUG), "ydb sql database connect done",
33+
l.Log(WithLevel(ctx, DEBUG), "ydb database/sql connect done",
3434
kv.Latency(start),
3535
kv.String("session_id", info.Session.ID()),
3636
kv.String("session_status", info.Session.Status()),
3737
)
3838
} else {
39-
l.Log(WithLevel(ctx, ERROR), "ydb sql database connect failed",
39+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql connect failed",
4040
kv.Error(info.Error),
4141
kv.Latency(start),
4242
kv.Version(),
@@ -50,16 +50,16 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
5050
return nil
5151
}
5252
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "conn", "ping")
53-
l.Log(ctx, "ydb sql database ping starting...")
53+
l.Log(ctx, "ydb database/sql ping starting...")
5454
start := time.Now()
5555

5656
return func(info trace.DatabaseSQLConnPingDoneInfo) {
5757
if info.Error == nil {
58-
l.Log(ctx, "ydb sql database ping done",
58+
l.Log(ctx, "ydb database/sql ping done",
5959
kv.Latency(start),
6060
)
6161
} else {
62-
l.Log(WithLevel(ctx, ERROR), "ydb sql database ping failed",
62+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql ping failed",
6363
kv.Error(info.Error),
6464
kv.Latency(start),
6565
kv.Version(),
@@ -77,11 +77,11 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
7777

7878
return func(info trace.DatabaseSQLConnCloseDoneInfo) {
7979
if info.Error == nil {
80-
l.Log(ctx, "ydb sql connection close done",
80+
l.Log(ctx, "ydb database/sql connection close done",
8181
kv.Latency(start),
8282
)
8383
} else {
84-
l.Log(WithLevel(ctx, WARN), "ydb sql connection close failed",
84+
l.Log(WithLevel(ctx, WARN), "ydb database/sql connection close failed",
8585
kv.Error(info.Error),
8686
kv.Latency(start),
8787
kv.Version(),
@@ -94,16 +94,16 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
9494
return nil
9595
}
9696
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "conn", "begin", "tx")
97-
l.Log(ctx, "ydb sql transaction begin starting...")
97+
l.Log(ctx, "ydb database/sql transaction begin starting...")
9898
start := time.Now()
9999

100100
return func(info trace.DatabaseSQLConnBeginDoneInfo) {
101101
if info.Error == nil {
102-
l.Log(ctx, "ydb sql transaction begin done",
102+
l.Log(ctx, "ydb database/sql transaction begin done",
103103
kv.Latency(start),
104104
)
105105
} else {
106-
l.Log(WithLevel(ctx, ERROR), "ydb sql transaction begin failed",
106+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql transaction begin failed",
107107
kv.Error(info.Error),
108108
kv.Latency(start),
109109
kv.Version(),
@@ -116,7 +116,7 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
116116
return nil
117117
}
118118
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "conn", "prepare", "stmt")
119-
l.Log(ctx, "ydb sql prepare starting...",
119+
l.Log(ctx, "ydb database/sql prepare starting...",
120120
appendFieldByCondition(l.logQuery,
121121
kv.String("query", info.Query),
122122
)...,
@@ -126,11 +126,11 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
126126

127127
return func(info trace.DatabaseSQLConnPrepareDoneInfo) {
128128
if info.Error == nil {
129-
l.Log(ctx, "ydb sql prepare done",
129+
l.Log(ctx, "ydb database/sql prepare done",
130130
kv.Latency(start),
131131
)
132132
} else {
133-
l.Log(WithLevel(ctx, ERROR), "ydb sql prepare failed",
133+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql prepare failed",
134134
appendFieldByCondition(l.logQuery,
135135
kv.String("query", query),
136136
kv.Error(info.Error),
@@ -146,7 +146,7 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
146146
return nil
147147
}
148148
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "conn", "exec")
149-
l.Log(ctx, "ydb sql exec starting...",
149+
l.Log(ctx, "ydb database/sql exec starting...",
150150
appendFieldByCondition(l.logQuery,
151151
kv.String("query", info.Query),
152152
)...,
@@ -157,12 +157,12 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
157157

158158
return func(info trace.DatabaseSQLConnExecDoneInfo) {
159159
if info.Error == nil {
160-
l.Log(ctx, "ydb sql exec done",
160+
l.Log(ctx, "ydb database/sql exec done",
161161
kv.Latency(start),
162162
)
163163
} else {
164164
m := retry.Check(info.Error)
165-
l.Log(WithLevel(ctx, ERROR), "ydb sql exec failed",
165+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql exec failed",
166166
appendFieldByCondition(l.logQuery,
167167
kv.String("query", query),
168168
kv.Bool("retryable", m.MustRetry(idempotent)),
@@ -181,7 +181,7 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
181181
return nil
182182
}
183183
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "conn", "query")
184-
l.Log(ctx, "ydb sql query starting...",
184+
l.Log(ctx, "ydb database/sql query starting...",
185185
appendFieldByCondition(l.logQuery,
186186
kv.String("query", info.Query),
187187
)...,
@@ -192,12 +192,12 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
192192

193193
return func(info trace.DatabaseSQLConnQueryDoneInfo) {
194194
if info.Error == nil {
195-
l.Log(ctx, "ydb sql query done",
195+
l.Log(ctx, "ydb database/sql query done",
196196
kv.Latency(start),
197197
)
198198
} else {
199199
m := retry.Check(info.Error)
200-
l.Log(WithLevel(ctx, ERROR), "ydb sql query failed",
200+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql query failed",
201201
appendFieldByCondition(l.logQuery,
202202
kv.String("query", query),
203203
kv.Bool("retryable", m.MustRetry(idempotent)),
@@ -216,16 +216,16 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
216216
return nil
217217
}
218218
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "tx", "commit")
219-
l.Log(ctx, "ydb sql tx commit starting")
219+
l.Log(ctx, "ydb database/sql tx commit starting")
220220
start := time.Now()
221221

222222
return func(info trace.DatabaseSQLTxCommitDoneInfo) {
223223
if info.Error == nil {
224-
l.Log(ctx, "ydb sql tx commit done",
224+
l.Log(ctx, "ydb database/sql tx commit done",
225225
kv.Latency(start),
226226
)
227227
} else {
228-
l.Log(WithLevel(ctx, ERROR), "ydb sql tx commit failed",
228+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql tx commit failed",
229229
kv.Error(info.Error),
230230
kv.Latency(start),
231231
kv.Version(),
@@ -238,16 +238,16 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
238238
return nil
239239
}
240240
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "tx", "rollback")
241-
l.Log(ctx, "ydb sql tx rollback starting...")
241+
l.Log(ctx, "ydb database/sql tx rollback starting...")
242242
start := time.Now()
243243

244244
return func(info trace.DatabaseSQLTxRollbackDoneInfo) {
245245
if info.Error == nil {
246-
l.Log(ctx, "ydb sql tx rollback done",
246+
l.Log(ctx, "ydb database/sql tx rollback done",
247247
kv.Latency(start),
248248
)
249249
} else {
250-
l.Log(WithLevel(ctx, WARN), "ydb sql tx rollback failed",
250+
l.Log(WithLevel(ctx, WARN), "ydb database/sql tx rollback failed",
251251
kv.Error(info.Error),
252252
kv.Latency(start),
253253
kv.Version(),
@@ -260,16 +260,16 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
260260
return nil
261261
}
262262
ctx := with(context.Background(), TRACE, "ydb", "database", "sql", "stmt", "close")
263-
l.Log(ctx, "ydb sql statement close starting...")
263+
l.Log(ctx, "ydb database/sql statement close starting...")
264264
start := time.Now()
265265

266266
return func(info trace.DatabaseSQLStmtCloseDoneInfo) {
267267
if info.Error == nil {
268-
l.Log(ctx, "ydb sql statement close done",
268+
l.Log(ctx, "ydb database/sql statement close done",
269269
kv.Latency(start),
270270
)
271271
} else {
272-
l.Log(WithLevel(ctx, ERROR), "ydb sql statement close failed",
272+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql statement close failed",
273273
kv.Error(info.Error),
274274
kv.Latency(start),
275275
kv.Version(),
@@ -282,7 +282,7 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
282282
return nil
283283
}
284284
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "stmt", "exec")
285-
l.Log(ctx, "ydb sql statement exec starting...",
285+
l.Log(ctx, "ydb database/sql statement exec starting...",
286286
appendFieldByCondition(l.logQuery,
287287
kv.String("query", info.Query),
288288
)...,
@@ -292,12 +292,12 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
292292

293293
return func(info trace.DatabaseSQLStmtExecDoneInfo) {
294294
if info.Error == nil {
295-
l.Log(ctx, "ydb sql statement exec done",
295+
l.Log(ctx, "ydb database/sql statement exec done",
296296
kv.Error(info.Error),
297297
kv.Latency(start),
298298
)
299299
} else {
300-
l.Log(WithLevel(ctx, ERROR), "ydb sql statement exec failed",
300+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql statement exec failed",
301301
appendFieldByCondition(l.logQuery,
302302
kv.String("query", query),
303303
kv.Error(info.Error),
@@ -313,7 +313,7 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
313313
return nil
314314
}
315315
ctx := with(*info.Context, TRACE, "ydb", "database", "sql", "stmt", "query")
316-
l.Log(ctx, "ydb sql statement query starting...",
316+
l.Log(ctx, "ydb database/sql statement query starting...",
317317
appendFieldByCondition(l.logQuery,
318318
kv.String("query", info.Query),
319319
)...,
@@ -323,11 +323,11 @@ func internalDatabaseSQL(l *wrapper, d trace.Detailer) (t trace.DatabaseSQL) {
323323

324324
return func(info trace.DatabaseSQLStmtQueryDoneInfo) {
325325
if info.Error == nil {
326-
l.Log(ctx, "ydb sql statement query done",
326+
l.Log(ctx, "ydb database/sql statement query done",
327327
kv.Latency(start),
328328
)
329329
} else {
330-
l.Log(WithLevel(ctx, ERROR), "ydb sql statement query failed",
330+
l.Log(WithLevel(ctx, ERROR), "ydb database/sql statement query failed",
331331
appendFieldByCondition(l.logQuery,
332332
kv.String("query", query),
333333
kv.Error(info.Error),

0 commit comments

Comments
 (0)