PostgreSQL 是一個自由的對象-關系資料庫伺服器(資料庫管理系統),它在靈活的 BSD-風格許可證下發行。它提供了相對其他開放源代碼資料庫系統(比如 MySQL 和 Firebird),和對專有系統比如 Oracle、Sybase、IBM 的 DB2 和 Microsoft SQL Server的一種選擇。
PostgreSQL和MySQL比較,它更加龐大一點,因為它是用來替代Oracle而設計的。是以在企業應用中采用PostgreSQL是一個明智的選擇。
MySQL被Oracle收購之後正在逐漸的封閉(自MySQL 5.5.31以後的所有版本将不再遵循GPL協定),鑒于此,将來我們也許會選擇PostgreSQL而不是MySQL作為項目的後端資料庫。
驅動
Go實作的支援PostgreSQL的驅動也很多,因為國外很多人在開發中使用了這個資料庫。
- https://github.com/lib/pq 支援database/sql驅動,純Go寫的
- https://github.com/jbarham/gopgsqldriver 支援database/sql驅動,純Go寫的
- https://github.com/lxn/go-pgsql 支援database/sql驅動,純Go寫的
在下面的示例中我采用了第一個驅動,因為它目前使用的人最多,在github上也比較活躍。
執行個體代碼
資料庫建表語句:
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);
看下面這個Go如何操作資料庫表資料:增删改查
import (
"database/sql"
"fmt"
_ "https://github.com/lib/pq"
)
func main() {
db, err := sql.Open("postgres", "user=astaxie password=astaxie dbname=test sslmode=disable")
checkErr(err)
//插入資料
stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")
checkErr(err)
res, err := stmt.Exec("astaxie", "研發部門", "2012-12-09")
checkErr(err)
//pg不支援這個函數,因為他沒有類似MySQL的自增ID
id, err := res.LastInsertId()
checkErr(err)
fmt.Println(id)
//更新資料
stmt, err = db.Prepare("update userinfo set username=$1 where uid=$2")
checkErr(err)
res, err = stmt.Exec("astaxieupdate", 1)
checkErr(err)
affect, err := res.RowsAffected()
checkErr(err)
fmt.Println(affect)
//查詢資料
rows, err := db.Query("SELECT * FROM userinfo")
checkErr(err)
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)
fmt.Println(username)
fmt.Println(department)
fmt.Println(created)
}
//删除資料
stmt, err = db.Prepare("delete from userinfo where uid=$1")
checkErr(err)
res, err = stmt.Exec(1)
checkErr(err)
affect, err = res.RowsAffected()
checkErr(err)
fmt.Println(affect)
db.Close()
}
func checkErr(err error) {
if err != nil {
panic(err)
}
}