使用SQL数据库驱动程序

huangapple
go评论150阅读模式
英文:

Using sql database driver

问题

请问一个终端用户（开发或生产）能否推荐一个最好使用“database/sql”包的Sql驱动程序包。我对Postgres、ODBC、MySql（可能还有其他一些，但不是Sqlite）感兴趣，最好能在Windows和/或Linux上使用（最好两者都可以）。对我来说，它可能需要最近更新/维护，并且必须与最新的Go版本配合使用。效率（吞吐量）显然很重要。欢迎提供任何相关评论。

英文:

Could an end-user (development or production) please recommend an Sql driver package that preferably uses the "database/sql" package. I'm interested in Postgres, ODBC, MySql (and possibly something else but for high-volume - ie. not Sqlite) that can preferably be used on Windows and/or Linux (preferably both). To be of interest to me it likely needs to have recently been updated /maintained and must work with latest Go release. Efficiency (throughput) is obviously important. Any relevant comments are welcome.

答案1

得分: 9

GO-SQL-Driver（MySQL）：

> https://github.com/Go-SQL-Driver/MySQL

示例表格：

  1. CREATE TABLE `userinfo` (
  2.     `uid` INT(10) NOT NULL AUTO_INCREMENT,
  3.     `username` VARCHAR(64) NULL DEFAULT NULL,
  4.     `departname` VARCHAR(64) NULL DEFAULT NULL,
  5.     `created` DATE NULL DEFAULT NULL,
  6.     PRIMARY KEY (`uid`)
  7. )
  9. CREATE TABLE `userdetail` (
  10.     `uid` INT(10) NOT NULL DEFAULT '0',
  11.     `intro` TEXT NULL,
  12.     `profile` TEXT NULL,
  13.     PRIMARY KEY (`uid`)
  14. )

示例代码：

  1. package main
  3. import (
  4.     _ "github.com/Go-SQL-Driver/MySQL"
  5.     "database/sql"
  6.     "fmt"
  7. )
  9. func main() {
  10.     db, err := sql.Open("mysql", "reckhou:reckhou@/test?charset=utf8")
  11.     checkErr(err)
  13.     //插入
  14.     stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
  15.     checkErr(err)
  17.     res, err := stmt.Exec("reckhou", "IT", "2010-10-02")
  18.     checkErr(err)
  20.     id, err := res.LastInsertId()
  21.     checkErr(err)
  23.     fmt.Println(id)
  24.     
  25.     // 更新
  26.     stmt, err = db.Prepare("update userinfo set username=? where uid=?")
  27.     checkErr(err)
  29.     res, err = stmt.Exec("update", id)
  30.     checkErr(err)
  32.     affect, err := res.RowsAffected()
  33.     checkErr(err)
  35.     fmt.Println(affect)
  37.     //查询
  38.     rows, err := db.Query("SELECT * FROM userinfo")
  39.     checkErr(err)
  41.     for rows.Next() {
  42.         var uid int
  43.         var username string
  44.         var department string
  45.         var created string
  46.         err = rows.Scan(&uid, &username, &department, &created)
  47.         checkErr(err)
  48.         fmt.Println(uid)
  49.         fmt.Println(username)
  50.         fmt.Println(department)
  51.         fmt.Println(created)
  52.     }
  54.     //删除
  55.     stmt, err = db.Prepare("delete from userinfo where uid=?")
  56.     checkErr(err)
  58.     res, err = stmt.Exec(id)
  59.     checkErr(err)
  61.     affect, err = res.RowsAffected()
  62.     checkErr(err)
  64.     fmt.Println(affect)
  66.     db.Close()
  68. }
  70. func checkErr(err error) {
  71.     if err != nil {
  72.         panic(err)
  73.     }
  74. }

PostgreSQL：

> https://github.com/bmizerany/pq

示例表格：

  1. CREATE TABLE userinfo
  2. (
  3.     uid serial NOT NULL,
  4.     username character varying(100) NOT NULL,
  5.     departname character varying(500) NOT NULL,
  6.     Created date,
  7.     CONSTRAINT userinfo_pkey PRIMARY KEY (uid)
  8. )
  9. WITH (OIDS=FALSE);
  11. CREATE TABLE userdeatail
  12. (
  13.     uid integer,
  14.     intro character varying(100),
  15.     profile character varying(100)
  16. )
  17. WITH(OIDS=FALSE);

示例代码：

  1. import (
  2.     "database/sql"
  3.     "fmt"
  4.     _ "github.com/bmizerany/pq"
  5. )
  7. func main() {
  8.     db, err := sql.Open("postgres", "user=reckhou password=reckhou dbname=test sslmode=disable")
  9.     checkErr(err)
  11.     //插入
  12.     stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")
  13.     checkErr(err)
  15.     res, err := stmt.Exec("reckhou", "IT", "2010-10-01")
  16.     checkErr(err)
  18.     id, err := res.LastInsertId()
  19.     checkErr(err)
  21.     fmt.Println(id)
  23.     // 更新
  24.     stmt, err = db.Prepare("update userinfo set username=$1 where uid=$2")
  25.     checkErr(err)
  27.     res, err = stmt.Exec("update", 1)
  28.     checkErr(err)
  30.     affect, err := res.RowsAffected()
  31.     checkErr(err)
  33.     fmt.Println(affect)
  35.     // 查询
  36.     rows, err := db.Query("SELECT * FROM userinfo")
  37.     checkErr(err)
  39.     for rows.Next() {
  40.         var uid int
  41.         var username string
  42.         var department string
  43.         var created string
  44.         err = rows.Scan(&uid, &username, &department, &created)
  45.         checkErr(err)
  46.         fmt.Println(uid)
  47.         fmt.Println(username)
  48.         fmt.Println(department)
  49.         fmt.Println(created)
  50.     }
  52.     // 删除
  53.     stmt, err = db.Prepare("delete from userinfo where uid=$1")
  54.     checkErr(err)
  56.     res, err = stmt.Exec(1)
  57.     checkErr(err)
  59.     affect, err = res.RowsAffected()
  60.     checkErr(err)
  62.     fmt.Println(affect)
  64.     db.Close()
  66. }
  68. func checkErr(err error) {
  69.     if err != nil {
  70.         panic(err)
  71.     }
  72. }
英文:

GO-SQL-Driver(MySQL):

> https://github.com/Go-SQL-Driver/MySQL

Sample table:

  1. CREATE TABLE `userinfo` (
  2.     `uid` INT(10) NOT NULL AUTO_INCREMENT,
  3.     `username` VARCHAR(64) NULL DEFAULT NULL,
  4.     `departname` VARCHAR(64) NULL DEFAULT NULL,
  5.     `created` DATE NULL DEFAULT NULL,
  6.     PRIMARY KEY (`uid`)
  7. )
  9. CREATE TABLE `userdetail` (
  10.     `uid` INT(10) NOT NULL DEFAULT '0',
  11.     `intro` TEXT NULL,
  12.     `profile` TEXT NULL,
  13.     PRIMARY KEY (`uid`)
  14. )

Sample code:

  1. package main
  3. import (
  4.     _ "github.com/Go-SQL-Driver/MySQL"
  5.     "database/sql"
  6.     "fmt"
  7. )
  9. func main() {
  10.     db, err := sql.Open("mysql", "reckhou:reckhou@/test?charset=utf8")
  11.     checkErr(err)
  13.     //Insert
  14.     stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
  15.     checkErr(err)
  17.     res, err := stmt.Exec("reckhou", "IT", "2010-10-02")
  18.     checkErr(err)
  20.     id, err := res.LastInsertId()
  21.     checkErr(err)
  23.     fmt.Println(id)
  24.     
  25.     // Update
  26.     stmt, err = db.Prepare("update userinfo set username=? where uid=?")
  27.     checkErr(err)
  29.     res, err = stmt.Exec("update", id)
  30.     checkErr(err)
  32.     affect, err := res.RowsAffected()
  33.     checkErr(err)
  35.     fmt.Println(affect)
  37.     //Query
  38.     rows, err := db.Query("SELECT * FROM userinfo")
  39.     checkErr(err)
  41.     for rows.Next() {
  42.         var uid int
  43.         var username string
  44.         var department string
  45.         var created string
  46.         err = rows.Scan(&uid, &username, &department, &created)
  47.         checkErr(err)
  48.         fmt.Println(uid)
  49.         fmt.Println(username)
  50.         fmt.Println(department)
  51.         fmt.Println(created)
  52.     }
  54.     //Delete
  55.     stmt, err = db.Prepare("delete from userinfo where uid=?")
  56.     checkErr(err)
  58.     res, err = stmt.Exec(id)
  59.     checkErr(err)
  61.     affect, err = res.RowsAffected()
  62.     checkErr(err)
  64.     fmt.Println(affect)
  66.     db.Close()
  68. }
  70. func checkErr(err error) {
  71.     if err != nil {
  72.         panic(err)
  73.     }
  74. }

PostgreSQL:

> https://github.com/bmizerany/pq

Sample table:

  1. CREATE TABLE userinfo
  2. (
  3.     uid serial NOT NULL,
  4.     username character varying(100) NOT NULL,
  5.     departname character varying(500) NOT NULL,
  6.     Created date,
  7.     CONSTRAINT userinfo_pkey PRIMARY KEY (uid)
  8. )
  9. WITH (OIDS=FALSE);
  11. CREATE TABLE userdeatail
  12. (
  13.     uid integer,
  14.     intro character varying(100),
  15.     profile character varying(100)
  16. )
  17. WITH(OIDS=FALSE);

Sample code:

  1. import (
  2.     "database/sql"
  3.     "fmt"
  4.     _ "github.com/bmizerany/pq"
  5. )
  7. func main() {
  8.     db, err := sql.Open("postgres", "user=reckhou password=reckhou dbname=test sslmode=disable")
  9.     checkErr(err)
  11.     //Insert
  12.     stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")
  13.     checkErr(err)
  15.     res, err := stmt.Exec("reckhou", "IT", "2010-10-01")
  16.     checkErr(err)
  18.     id, err := res.LastInsertId()
  19.     checkErr(err)
  21.     fmt.Println(id)
  23.     // Update
  24.     stmt, err = db.Prepare("update userinfo set username=$1 where uid=$2")
  25.     checkErr(err)
  27.     res, err = stmt.Exec("update", 1)
  28.     checkErr(err)
  30.     affect, err := res.RowsAffected()
  31.     checkErr(err)
  33.     fmt.Println(affect)
  35.     // Query
  36.     rows, err := db.Query("SELECT * FROM userinfo")
  37.     checkErr(err)
  39.     for rows.Next() {
  40.         var uid int
  41.         var username string
  42.         var department string
  43.         var created string
  44.         err = rows.Scan(&uid, &username, &department, &created)
  45.         checkErr(err)
  46.         fmt.Println(uid)
  47.         fmt.Println(username)
  48.         fmt.Println(department)
  49.         fmt.Println(created)
  50.     }
  52.     // Delete
  53.     stmt, err = db.Prepare("delete from userinfo where uid=$1")
  54.     checkErr(err)
  56.     res, err = stmt.Exec(1)
  57.     checkErr(err)
  59.     affect, err = res.RowsAffected()
  60.     checkErr(err)
  62.     fmt.Println(affect)
  64.     db.Close()
  66. }
  68. func checkErr(err error) {
  69.     if err != nil {
  70.         panic(err)
  71.     }
  72. }

huangapple
  • 本文由 发表于 2013年4月17日 15:42:46
  • 转载请务必保留本文链接：https://go.coder-hub.com/16054317.html
  • go
  • sql
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定