我讀到你不應該關閉 *sql.DB 變量。http://go-database-sql.org/accessing.html它還說我應該：“根據(jù)需要傳遞它，或者以某種方式在全球范圍內(nèi)提供它，但保持開放。”但是這篇文章說我不應該使用全局變量而應該使用閉包：https : //medium.com/@benbjohnson/structuring-applications-in-go-3b04be4ff091我在這里找到了一個關閉的例子：https : //gist.github.com/tsenart/5fc18c659814c078378d我的問題是：我應該如何將此變量傳遞給不同的包？例如，如果我有一個名為 User 的包，如下所示：package userimport "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 的指針作為 User 類型的屬性嗎？或者我應該在 findById 方法中傳遞一個指向它的指針嗎？如果我想通過 id 查找用戶，我應該如何從如下所示的主函數(shù)中完成所有這些操作？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))}我該怎么辦？什么是好的首選方式或最佳實踐？
1 回答
慕哥6287543
TA貢獻1831條經(jīng)驗 獲得超10個贊
超級簡單？一個全局var db *sql.DB對象。*sql.DB是線程安全的，因此可以并發(fā)訪問。
或者，您可以在包裝*sql.DB. 我的觀點是func (u *User) FindByID(id string) (*User, error)沒有多大意義——你接受一個用戶指針，但返回一個指向用戶的新指針？
作為一個簡化的示例，您可以將代碼更改為類似于以下內(nèi)容：
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.
}
為了從您的處理程序調用這些函數(shù)，您可以：
使用閉包（就像你現(xiàn)在所做的那樣）
定義一個“環(huán)境”或“服務”結構，其中包含您的
DB類型或只是 vanilla*sql.DB作為字段，并在此基礎上創(chuàng)建您的處理程序作為方法。這也可以是全局的（注意任何成員都必須是線程安全的）。定義一個自定義處理程序類型（我的方法），您可以在其中調用
router.GET("/user/:id", GetUserByID(env)而不是使用閉包。
- 1 回答
- 0 關注
- 279 瀏覽
添加回答
舉報
0/150
提交
取消