(ctx context.Context, conn *sql.Conn)
| 599 | } |
| 600 | |
| 601 | func getConnectionID(ctx context.Context, conn *sql.Conn) (string, error) { |
| 602 | var id string |
| 603 | if err := conn.QueryRowContext(ctx, `SELECT CONNECTION_ID();`).Scan(&id); err != nil { |
| 604 | return "", err |
| 605 | } |
| 606 | return id, nil |
| 607 | } |