pgwire 0.38.3

Postgresql wire protocol implemented as a library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

package main

import (
    "log"
    "database/sql"
    _ "github.com/lib/pq"
)

type result struct {
    id int
    name string
    date string
    isOk bool
}

func main() {
    conninfo := "host=127.0.0.1 port=5432 user=tom password=pencil dbname=localdb"
    db, err := sql.Open("postgres", conninfo)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    _, err = db.Exec("INSERT INTO testtable VALUES (1)")
    if err != nil {
        log.Fatal(err)
    }

    rows, err := db.Query("SELECT * FROM testtable")
    if err != nil {
        log.Fatal(err)
    }

    for rows.Next() {
        var r result
        rows.Scan( & r.id, & r.name, & r.date, & r.isOk)
        log.Printf("%#v", r)
    }

    rows, err = db.Query("SELECT * FROM testtable where id = ?", 1)
    if err != nil {
        log.Fatal(err)
    }

    for rows.Next() {
        var r result
        rows.Scan( & r.id, & r.name, & r.date, & r.isOk)
        log.Printf("%#v", r)
    }
}