pg_hit_ratelimit.go

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)
	}
}