Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- import (
- "database/sql"
- // "fmt"
- _ "github.com/go-sql-driver/mysql"
- "log"
- "net/http"
- "time"
- "os"
- )
- var db *sql.DB
- var err error
- func init() {
- db, err = sql.Open("mysql", "vagrant:vagrant@/paragram_dev")
- if err != nil {
- log.Fatal(err)
- os.Exit(0)
- }
- db.SetMaxIdleConns(0)
- db.SetMaxOpenConns(100)
- db.SetConnMaxLifetime(time.Minute * 5)
- }
- func insertData() {
- db.Exec("INSERT INTO ok(id) VALUES(?)", 1)
- }
- func longPoll(chs chan<- string) {
- time.Sleep(500 * time.Millisecond)
- chs <- "Successful result."
- }
- func handler(w http.ResponseWriter, r *http.Request) {
- // poll := make(chan string)
- // go longPoll(poll)
- // start := time.Now()
- // elapsed := time.Since(start)
- // select {
- // case hasil := <-poll:
- // fmt.Println(hasil, elapsed)
- insertData()
- // case <-time.After(time.Second * 10):
- // fmt.Fprint(w, "Server is busy.", elapsed)
- // <-poll
- // }
- // close(poll)
- }
- func main() {
- http.HandleFunc("/", handler)
- http.ListenAndServe("localhost:8090", nil)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement