Skip to content

arbitrarystone/dbpool

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

6 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

数据库连接池

Usage

mongo连接池Usage

func main() {
	p, err := dbpool.NewPool("mongo", "mongodb://localhost:27017", 1, 10, pool.PoolGetModeStrict)
	if err != nil {
		panic(err)
	}
    defer p.Close()
	client, err := dbpool.GetMongoClient(p, 1*time.Second)
    defer client.Close()
	if err != nil {
        fmt.Printf("get mongo client failed:%v",err)
        return
	}
	_, err = client.GetCount("FilmDB", "area")
	if err != nil {
		fmt.Printf("get count error:%v", err)
		return
	}
}

About

mongo数据库连接池

Resources

Stars

Watchers

Forks

Packages

 
 
 

Contributors

Languages