Go 连接PostgreSQL数据库

先在PostgreSQL数据库中建一个表，可以使用PostgreSQL官方的pgAdmin来完成：

CREATE TABLE userinfo
(
    uid serial NOT NULL,
    username character varying(100) NOT NULL,
    departname character varying(500) NOT NULL,
    Created date,
    CONSTRAINT userinfo_pkey PRIMARY KEY (uid)
)
WITH (OIDS=FALSE);

CREATE TABLE userdeatail
(
    uid integer,
    intro character varying(100),
    profile character varying(100)
)
WITH(OIDS=FALSE);

然后运行以下代码，实现连接数据库和增删查改，请自行更改参数配置部分：

package main

import (
        "database/sql"
        "fmt"

        _ "github.com/lib/pq"
)

var db *sql.DB

func sqlOpen() {
        var err error
        db, err = sql.Open("postgres", "port=5433 user=postgres password=123456 dbname=ficow sslmode=disable")
        //port是数据库的端口号，默认是5432，如果改了，这里一定要自定义；
        //user就是你数据库的登录帐号;
        //dbname就是你在数据库里面建立的数据库的名字;
        //sslmode就是安全验证模式;

        //还可以是这种方式打开
        //db, err := sql.Open("postgres", "postgres://pqgotest:password@localhost/pqgotest?sslmode=verify-full")
        checkErr(err)
}
func sqlInsert() {
        //插入数据
        stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")
        checkErr(err)

        res, err := stmt.Exec("ficow", "软件开发部门", "2017-03-09")
        //这里的三个参数就是对应上面的$1,$2,$3了

        checkErr(err)

        affect, err := res.RowsAffected()
        checkErr(err)

        fmt.Println("rows affect:", affect)
}
func sqlDelete() {
        //删除数据
        stmt, err := db.Prepare("delete from userinfo where u)
        checkErr(err)

        res, err := stmt.Exec(1)
        checkErr(err)

        affect, err := res.RowsAffected()
        checkErr(err)

        fmt.Println("rows affect:", affect)
}
func sqlSelect() {
        //查询数据
        rows, err := db.Query("SELECT * FROM userinfo")
        checkErr(err)

        println("-----------")
        for rows.Next() {
                var uid int
                var username string
                var department string
                var created string
                err = rows.Scan(&uid, &username, &department, &created)
                checkErr(err)
                fmt.Println("uid = ", uid, "\nname = ", username, "\ndep = ", department, "\ncreated = ", created, "\n-----------")
        }
}
func sqlUpdate() {
        //更新数据
        stmt, err := db.Prepare("update userinfo set username=$1 where u)
        checkErr(err)

        res, err := stmt.Exec("ficow", 1)
        checkErr(err)

        affect, err := res.RowsAffected()
        checkErr(err)

        fmt.Println("rows affect:", affect)
}
func sqlClose() {
        db.Close()
}
func checkErr(err error) {
        if err != nil {
                panic(err)
        }
}

func sqlTest() {

        sep := "----------\n"
        sqlOpen()
        println(sep, "*sqlOpen")

        sqlSelect()
        println(sep, "*sqlSelect")

        sqlInsert()
        sqlSelect()
        println(sep, "*sqlInsert")

        sqlUpdate()
        sqlSelect()
        println(sep, "*sqlUpdate")

        sqlDelete()
        sqlSelect()
        println(sep, "*sqlDelete")

        sqlClose()
        println(sep, "*sqlClose")
}

func main() {

        sqlTest()
}

相关链接：

可以查看这个驱动库的文档进行学习： https://godoc.org/github.com/lib/pq

另外，还要感谢这位作者的教程： http://www.cnblogs.com/songxingzhu/p/5024517.html

转载请注明出处：http://www.cnblogs.com/ficow/p/6537238.html ，谢谢！