首页 > 代码库 > Go 连接PostgreSQL数据库

Go 连接PostgreSQL数据库

2024-09-08 06:33:10   215人阅读

 

先在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 mainimport (	"database/sql"	"fmt"	_ "github.com/lib/pq")var db *sql.DBfunc 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 uid=$1")	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 uid=$2")	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 ，谢谢！ 

Go 连接PostgreSQL数据库


联系
我们