将数据库连接和查询操作分离

本文探讨了如何将数据库连接和查询操作分离。在示例代码中，作者尝试将这两个操作分开，但遇到问题。本文给出了正确的解决方案，其中使用 `openDatabaseConnection()` 函数打开数据库连接，并使用 `printIds()` 函数执行查询。该解决方案避免了每次需要新查询时打开数据库连接的错误做法，提供了更清晰和可维护的代码结构。

我一直在尝试使用 http://www.github.com/go-sql-driver/mysql 执行查询，并一直在遵循本教程：https://tutorialedge.net/golang/golang-mysql-tutorial /

现在，本教程在 1 个自定义函数中完成了所有操作，但我尝试在单独的函数中分开打开数据库连接和查询本身。我的做法是这样的：

package main

import (
    "fmt"
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

type sqlresult struct {
  id int
}

var db *sql.db

func main() {
  dbconnection:= opendatabaseconnection();
  getid(dbconnection);

}

func opendatabaseconnection() *sql.db {
  db,err:= sql.open("mysql","username:password@tcp(127.0.0.1:3306)/test");

  if err != nil {
    panic(err.error())
  }

  defer db.close()
  return db
}

func getid(db *sql.db) {
  results,err:= db.query("select id from test")
  for results.next() {
    var result sqlresult
    err=results.scan(&result.id)
    if err != nil {
      panic(err.error())
    }
    fmt.print(result.id)
  }
}

这不会打印出任何内容，但也不会给出错误。

现在，当我将代码放入 1 个函数中时，如下所示：

package main

import (
    "fmt"
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

type SqlResult struct {
  id int
}

var db *sql.DB

func main() {
  openDatabaseConnection();
}

func openDatabaseConnection() *sql.DB {
  db,err:= sql.Open("mysql","username:password@tcp(127.0.0.1:3306)/test");

  if err != nil {
    panic(err.Error())
  }

  results,err:= db.Query("SELECT id FROM test")
  for results.Next() {
    var result SqlResult
    err=results.Scan(&result.id)
    if err != nil {
      panic(err.Error())
    }
    fmt.Print(result.id)
  }

  defer db.Close()
  return db
}

这会返回所有 id，但我想将功能分开。每次需要新查询时打开数据库连接似乎并不是正确的解决方案。

有谁知道我在第一个示例中做错了什么，如果是这样，我想要的正确方式是什么？

解决方案

“我想要的正确方式是什么？”

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
)

var db *sql.DB

func main() {
    db = openDatabaseConnection()
    defer db.Close()
    
    printIds(db)
}

func openDatabaseConnection() *sql.DB {
    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/test")
    if err != nil {
        panic(err)
    } else if err := db.Ping(); err != nil {
        panic(err)
    }
    return db
}

func printIds(db *sql.DB) {
    rows, err := db.Query("SELECT id FROM test")
    if err != nil {
        panic(err)
    }
    defer rows.Close()
    
    for rows.Next() {
        var id int
        if err := rows.Scan(&id); err != nil {
            panic(err)
        }
        fmt.Println(id)
    }
    if err := rows.Err(); err != nil {
        panic(err)
    }
}

今天关于《将数据库连接和查询操作分离》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！