1 回答

TA貢獻1796條經驗 獲得超7個贊
您編寫的代碼存在一些問題。避免連接泄漏問題的直接答案是關閉迭代rows
器,如文檔中所述。調用它的正常方法是在defer
聲明中:
? ? rows, err := db.Query(
? ? ? ? "select 1 from things where id = $1",
? ? ? ? thing,
? ? )
? ? if err != nil {
? ? ? ? return nil, fmt.Errorf("can't select thing (%d): %w", thing, err)
? ? }
? ? defer rows.Close()
? ? found := false
? ? for rows.Next() {
? ? ? ? found = true
? ? ? ? break
? ? }
其次,由于您關心的只是單個結果,因此根本沒有理由獲取多行結果集,這也將隱式解決連接泄漏問題。如果我們在這里進行調整:
?row, err := db.QueryRow(
? ? ? ? "select EXISTS(SELECT 1 from things where id = $1)",
? ? ? ? thing,
? ? )
? ? if err != nil {
? ? ? ? return nil, fmt.Errorf("can't select thing (%d): %w", thing, err)
? ? }
? ? var found bool
? ? if err := row.Scan(&found); err != nil {
? ? ? ? return nil, fmt.Errorf("Failed to scan result: %w", err)
? ? }
- 1 回答
- 0 關注
- 147 瀏覽
添加回答
舉報