Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "os"
- "fmt"
- pg "gopkg.in/pg.v4"
- )
- func main() {
- db := pg.Connect(&pg.Options{
- Addr: "192.168.56.100:5432",
- Database: "mydb",
- User: "myuser",
- Password: "mypass",
- SSL: false,
- // DisableRateLimiting: true,
- })
- for i := 0; i < 1000; i++ {
- // This is OK:
- // _, err := db.Query(&model, `SELECT 1 AS x`)
- // if err != nil {
- // fmt.Fprintf(os.Stderr, "%v", err)
- // }
- // This crashes after 34 iterations with error:
- // pg: you open connections too fast
- _, err := db.CopyTo(os.Stdout, `COPY mytable TO STDOUT`)
- if err != nil {
- fmt.Fprintf(os.Stderr, "%v\n", err)
- os.Exit(1)
- }
- fmt.Printf("i=%v\n", i)
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement