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 mainimport ("database/sql""fmt"_ "github.com/bmizerany/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的自增IDid, 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 intvar username stringvar department stringvar created stringerr = 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)}
}