5.4 使用PostgreSQL数据库

    PostgreSQL和MySQL比较，它更加庞大一点，因为它是用来替代Oracle而设计的。所以在企业应用中采用PostgreSQL是一个明智的选择。

    MySQL被Oracle收购之后正在逐步的封闭（自MySQL 5.5.31以后的所有版本将不再遵循GPL协议），鉴于此，将来我们也许会选择PostgreSQL而不是MySQL作为项目的后端数据库。

    在下面的示例中我采用了第一个驱动，因为它目前使用的人最多，在github上也比较活跃。

    数据库建表语句：

    2. package main
    4. import (
    5.     "database/sql"
    6.     "fmt"
    8.     _ "github.com/lib/pq"
    9. )
    11. func main() {
    12.     db, err := sql.Open("postgres", "user=astaxie password=astaxie dbname=test sslmode=disable")
    13.     checkErr(err)
    15.     //插入数据
    16.     stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")
    17.     checkErr(err)
    19.     res, err := stmt.Exec("astaxie", "研发部门", "2012-12-09")
    20.     checkErr(err)
    22.     //pg不支持这个函数，因为他没有类似MySQL的自增ID
    23.     // id, err := res.LastInsertId()
    24.     // fmt.Println(id)
    26.     var lastInsertId int
    27.     err = db.QueryRow("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) returning uid;", "astaxie", "研发部门", "2012-12-09").Scan(&lastInsertId)
    29.     fmt.Println("最后插入id =", lastInsertId)
    32.     //更新数据
    33.     stmt, err = db.Prepare("update userinfo set username=$1 where uid=$2")
    34.     checkErr(err)
    36.     res, err = stmt.Exec("astaxieupdate", 1)
    37.     checkErr(err)
    39.     affect, err := res.RowsAffected()
    40.     checkErr(err)
    42.     fmt.Println(affect)
    44.     //查询数据
    45.     rows, err := db.Query("SELECT * FROM userinfo")
    46.     checkErr(err)
    48.     for rows.Next() {
    49.         var uid int
    50.         var username string
    51.         var department string
    52.         var created string
    53.         checkErr(err)
    54.         fmt.Println(uid)
    56.         fmt.Println(department)
    57.         fmt.Println(created)
    58.     }
    60.     //删除数据
    61.     stmt, err = db.Prepare("delete from userinfo where uid=$1")
    62.     checkErr(err)
    64.     res, err = stmt.Exec(1)
    65.     checkErr(err)
    67.     affect, err = res.RowsAffected()
    68.     checkErr(err)
    70.     fmt.Println(affect)
    72.     db.Close()
    74. }
    76. func checkErr(err error) {
    77.     if err != nil {
    78.         panic(err)
    79.     }
    80. }

    从上面的代码我们可以看到，PostgreSQL是通过$1,$2这种方式来指定要传递的参数，而不是MySQL中的，另外在sql.Open中的dsn信息的格式也与MySQL的驱动中的dsn格式不一样，所以在使用时请注意它们的差异。

    还有pg不支持LastInsertId函数，因为PostgreSQL内部没有实现类似MySQL的自增ID返回，其他的代码几乎是一模一样。

    • 上一节: