我读到你不应该关闭*sql.DB变量
http://go-database-sql.org/accessing.html它还说我应该:"在需要的时候传递它,或者让它在全球范围内可用,但要保持开放。"
但是这篇文章说我不应该使用全局变量,而应该使用闭包:https://medium.com/@benbjohnson structuring-applications-in-go-3b04be4ff091
我在这里找到了一个闭包的例子:https://gist.github.com/tsenart/5fc18c659814c078378d
我的问题是:我应该如何传递这个变量到不同的包?
例如,如果我有一个名为User的包:
package user
import "errors"
var userNotFound = errors.New("User was not found.")
// Should I have a pointer to sql.DB as a property of the User type?
type User struct {
// db *sql.DB
Id int
Email string
Username string
}
// Should I pass in *sql.DB as parameter in the function?
func FindById(id int) (*User, error) {
// Access *sql.DB somehow
// Do query and look if user with id is found
// Should I return an error if the user is not found?
return &User{}, nil
}
我应该有一个指针到sql.DB作为用户类型的属性吗?还是应该在findById方法中传递指向它的指针?
如果我想通过它的id找到一个用户,我应该如何从下面的主函数做这一切?
func getUserById(db *sql.DB) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
fmt.Fprint(w, ps.ByName("id"))
// I will create a new(User) here, how should I use the *sql.DB in the user package?
}
}
func main() {
dsn := fmt.Sprintf("%s:%s@%s(%s:%s)/%s?charset=utf8",
cfg.DbUser, cfg.DbPass, cfg.DbProtocol, cfg.DbAddress, cfg.DbPort, cfg.DbName)
db, err := sql.Open("mysql", dsn)
err = db.Ping()
if err != nil {
log.Fatal(err)
}
router := httprouter.New()
router.GET("/api/user/:id", getUserById(db))
router.NotFound = &DefaultHandler{}
log.Fatal(http.ListenAndServe(":8080", router))
}
我该怎么做?什么是一种好的首选方式,或者一种最佳实践?
超级简单?全局var db *sql.DB
对象。*sql.DB
是线程安全的,因此可以并发访问。
或者,您可以在包装*sql.DB
的类型上定义查询方法。这是我的意见,func (u *User) FindByID(id string) (*User, error)
没有使整个很多的意义-你接受一个用户指针,但返回一个新的指针给用户?
作为一个简化的例子,您可以将代码更改为如下所示:
type DB struct {
*sql.DB
}
func NewDB(host, port string) (*DB, error) {
db, err := sql.Open(...)
if err != nil {
return nil, err
}
return &DB{db}, nil
}
func (db *DB) UserByID(id string) (*User, error) {
res, err := db.Query(...)
// etc.
}
func (db *DB) UsersList(limit int) ([]*User, error) {
res, err := db.Query(...)
// etc.
}
为了从处理程序中调用这些函数,您可以:
- 使用闭包(就像你现在做的那样)
- 定义一个"环境"或"服务"结构,包含你的
DB
类型或只是香草*sql.DB
作为一个字段,并创建你的处理程序作为方法。这也可以是全局的(注意任何成员都必须是线程安全的)。 - 定义一个自定义处理程序类型(我的方法),你调用
router.GET("/user/:id", GetUserByID(env)
而不是使用闭包。
附加阅读:
- http://www.alexedwards.net/blog/organising-database-access(涵盖多种方法-最全面的文章之一)
- https://robots.thoughtbot.com/interface-with-your-database-in-go
- https://medium.com/@benbjohnson structuring-applications-in-go-3b04be4ff091
- http://elithrar.github.io/article/http-handler-error-handling-revisited/有点不同