使用sql数据库驱动 [英] Using sql database driver
问题描述
GO-SQL-Driver(MySQL):
样本表:
`uid` INT(10)NOT NULL AUTO_INCREMENT,
`username` VARCHAR(64)NULL DEFAULT NULL,
`departname` VARCHAR(64) NULL DEFAULT NULL,
`created` DATE NULL DEFAULT NULL,
PRIMARY KEY(`uid`)
)
CREATE TABLE`userdetail`(
(uid`)INT(10)NOT NULL DEFAULT'0',
`intro` TEXT NULL,
`profile` TEXT NULL,
PRIMARY KEY(`uid`)
)
示例代码:
package main
import(
_github.com/Go-SQL-Driver/MySQL
database / sql
fmt
)
func main(){
db,err:= sq l.Open(mysql,reckhou:reckhou @ / test?charset = utf8)
checkErr(err)
//插入
stmt,err:= db (INSERT userinfo SET username = ?, departname =?,created =?)
checkErr(err)
$ b $ res,err:= stmt.Exec(reckhou, IT,2010-10-02)
checkErr(err)
$ b $ id,err:= res.LastInsertId()
checkErr(err)
fmt.Println(id)
//更新
stmt,err = db.Prepare(update userinfo set username =? )
checkErr(err)
res,err = stmt.Exec(update,id)
checkErr(err)
影响,err:= res.RowsAffected()
checkErr(err)
fmt.Println(影响)
//查询
行,err:= db.Query(SELECT * FROM userinfo)
checkErr(err)
for rows.Next(){
var uid int
var用户名字符串
var department字符串
var创建的字符串
err = rows.Scan(& uid,& username,& department,&创建)
checkErr(err)
fmt.Println(uid)
fmt.Println(用户名)
fmt.Println(部门)
fmt.Println(创建)
}
//删除
stmt,err = db.Prepare(从userinfo删除where uid =?)
checkErr(err)
res,err = stmt。 Exec(id)
checkErr(err)
影响,err = res.RowsAffected()
checkErr(err)
fmt.Println(影响)
db.Close()
}
func checkErr(错误错误){
if err! =无{
恐慌(错误)
}
}
PostgreSQL:
https://github.com/ bmizerany / pq
样本表:
CREATE TABLE userinfo
(
uid serial NOT NULL,
username username varying(100)NOT NULL,
departname字符变化(500)NOT NULL,
创建日期,
CONSTRAINT userinfo_pkey PRIMARY KEY(uid)
)
WITH(OIDS = FALSE);
CREATE TABLE userdeatail
(
uid整数,
介绍字符变化(100),
轮廓字符变化(100)
)
WITH(OIDS = FALSE);
示例代码:
import(
database / sql
fmt
_github.com/bmizerany/pq
)
$ func main(){
db,err:= sql.Open(postgres,user = reckhou password = reckhou 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(reckhou,IT,2010-10-01)
checkErr(err)
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(update,1)
checkErr(err)
影响,err:= res.RowsAffected()
checkErr(err)
fmt.Println(影响)
//查询
rows,err:= db.Query(SELECT * FROM userinfo)
checkErr(err)
$ b $ for rows.Next(){
var uid int
var用户名字符串
var部门字符串
var创建的字符串
err = rows.Scan(& uid,& username,& department,& amp; created)
checkErr(err)
fmt.Println(uid)
fmt.Println(用户名)
fmt.Println(部门)
fmt.Println(创建)
}
//删除
stmt,err = db.Prepare(从userinfo删除where uid = $ 1)
checkErr(err)
res ,err = stmt.Exec(1)
checkErr(err)
影响,err = res.RowsAffected()
checkErr(err)
fmt.Println(影响)
db.Close()
}
func checkErr(错误错误){
if err! =无{
恐慌(错误)
}
}
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.
GO-SQL-Driver(MySQL):
Sample table:
CREATE TABLE `userinfo` (
`uid` INT(10) NOT NULL AUTO_INCREMENT,
`username` VARCHAR(64) NULL DEFAULT NULL,
`departname` VARCHAR(64) NULL DEFAULT NULL,
`created` DATE NULL DEFAULT NULL,
PRIMARY KEY (`uid`)
)
CREATE TABLE `userdetail` (
`uid` INT(10) NOT NULL DEFAULT '0',
`intro` TEXT NULL,
`profile` TEXT NULL,
PRIMARY KEY (`uid`)
)
Sample code:
package main
import (
_ "github.com/Go-SQL-Driver/MySQL"
"database/sql"
"fmt"
)
func main() {
db, err := sql.Open("mysql", "reckhou:reckhou@/test?charset=utf8")
checkErr(err)
//Insert
stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
checkErr(err)
res, err := stmt.Exec("reckhou", "IT", "2010-10-02")
checkErr(err)
id, err := res.LastInsertId()
checkErr(err)
fmt.Println(id)
// Update
stmt, err = db.Prepare("update userinfo set username=? where uid=?")
checkErr(err)
res, err = stmt.Exec("update", id)
checkErr(err)
affect, err := res.RowsAffected()
checkErr(err)
fmt.Println(affect)
//Query
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)
}
//Delete
stmt, err = db.Prepare("delete from userinfo where uid=?")
checkErr(err)
res, err = stmt.Exec(id)
checkErr(err)
affect, err = res.RowsAffected()
checkErr(err)
fmt.Println(affect)
db.Close()
}
func checkErr(err error) {
if err != nil {
panic(err)
}
}
PostgreSQL:
Sample table:
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);
Sample code:
import (
"database/sql"
"fmt"
_ "github.com/bmizerany/pq"
)
func main() {
db, err := sql.Open("postgres", "user=reckhou password=reckhou dbname=test sslmode=disable")
checkErr(err)
//Insert
stmt, err := db.Prepare("INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid")
checkErr(err)
res, err := stmt.Exec("reckhou", "IT", "2010-10-01")
checkErr(err)
id, err := res.LastInsertId()
checkErr(err)
fmt.Println(id)
// Update
stmt, err = db.Prepare("update userinfo set username=$1 where uid=$2")
checkErr(err)
res, err = stmt.Exec("update", 1)
checkErr(err)
affect, err := res.RowsAffected()
checkErr(err)
fmt.Println(affect)
// Query
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)
}
// Delete
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)
}
}
这篇关于使用sql数据库驱动的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!