diff --git a/5.1.md b/5.1.md index 69f8a5e3..24c84b24 100644 --- a/5.1.md +++ b/5.1.md @@ -35,16 +35,22 @@ Go和PHP不同的地方是,他没有官方提供数据库驱动,而是为开 >新手都会被这个`_`所迷惑,其实这个就是Go设计的巧妙之处,我们在变量赋值的时候经常看到这个,它是用来忽略变量的占位符,那么这个包引入也是,这儿的意思是引入此包而不直接使用这个包中定义的函数,变量等资源,我们在2.3流程和函数里面介绍过init函数的初始化过程,包在引入的时候会去调用包的init函数以完成对包的初始化,因此我们引入上面的数据库驱动包之后会去调用init函数,然后在init函数里面注册了这个数据库驱动,这样我们就可以在接下来的代码中直接使用这个数据库驱动了。 ##driver.Driver -数据库驱动是一个接口定义,他定义了一个method: Open(name string),这个方法返回一个数据库的Conn接口,这个Conn只能用来进行一次goroutine的操作。 +Driver是一个数据库驱动的接口,他定义了一个method: Open(name string),这个方法返回一个数据库的Conn接口。 type Driver interface { Open(name string) (Conn, error) } -每个驱动都会定义这个函数,它会解析name参数来获取相关数据库的连接信息,解析完成后,它将使用此信息来初始化一个Conn并返回它。 +返回的Conn只能用来进行一次goroutine的操作,也就是说不能把这个Conn应用于Go的多个goroutine里面。如下代码会出现错误 + + go dosomething(Conn) + +上面这样的代码会引发数据查询数据混乱,导致不知道是那个goroutine做的事情。会把goroutine A里面执行的查询返回给goroutine B执行的插入结果。 + +第三方驱动都会定义这个函数,它会解析name参数来获取相关数据库的连接信息,解析完成后,它将使用此信息来初始化一个Conn并返回它。 ##driver.Conn -数据库连接是一个接口定义,他定义了一系列方法,这个Conn只能应用在一个goroutine里面,不能使用在多个goroutine里面。 +Conn是一个数据库连接的接口定义,他定义了一系列方法,这个Conn只能应用在一个goroutine里面,不能使用在多个goroutine里面,详情请参考上面的说明。 type Conn interface { Prepare(query string) (Stmt, error) diff --git a/5.2.md b/5.2.md index 0e99da79..72dc54cb 100644 --- a/5.2.md +++ b/5.2.md @@ -1,4 +1,131 @@ #5.2使用MySQL数据库 +目前Internet上流行的网站构架方式是LAMP,MySQL数据库是其中的标配之一,MySQL作为数据库,它是免费的、开源的、而且使用起来非常的方便。所以目前很多的Web开发都采用MySQL作为后端的数据库存储。 + +##MySQL驱动 +Go中支持MySQL的驱动目前比较多,有如下几种,有些是支持database/sql标准,而有些是采用了自己的实现接口。 + +- http://code.google.com/p/go-mysql-driver/ 支持database/sql,全部采用go写。 +- https://github.com/ziutek/mymysql 支持database/sql,也支持自定义的接口,全部采用go写。 +- https://github.com/Philio/GoMySQL 不支持database/sql,自定义接口,全部采用go写。 + +上面三个数据库驱动是目前使用率最高的库,我接下来的例子主要采用第一个为主(我目前项目中也是采用第一个驱动来写),也推荐大家采用第一个驱动,主要理由: + +- 目前这个驱动比较新,维护的比较好 +- 完全支持database/sql接口 +- 支持keepalive,保持长连接,虽然星星fork了mymysql也支持keepalive,但是不是线程安全的,这个从底层就支持了keepalive。 + +##示例代码 +接下来的几个小节里面我们都采用同一个数据库表结构,我们新建一个数据库test,新建用户表userinfo,关联用户信息表userdetail。 + + 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`) + ) + +看下面这个Go如何操作数据库表数据:增删改查 + + package main + + import ( + _ "code.google.com/p/go-mysql-driver/mysql" + "database/sql" + "fmt" + //"time" + ) + + func main() { + db, err := sql.Open("mysql", "astaxie:astaxie@/test?charset=utf8") + checkErr(err) + + //插入数据 + stmt, errs := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?") + checkErr(errs) + + res, errres := stmt.Exec("astaxie", "研发部门", "2012-12-09") + checkErr(errres) + + id, errid := res.LastInsertId() + checkErr(errid) + + fmt.Println(id) + //更新数据 + stmt, errs = db.Prepare("update userinfo set username=? where uid=?") + checkErr(errs) + + res, errres = stmt.Exec("astaxieupdate", id) + checkErr(errres) + + affect, erraff := res.RowsAffected() + checkErr(erraff) + + fmt.Println(affect) + + //查询数据 + rows, errrow := db.Query("SELECT * FROM userinfo") + checkErr(errrow) + + 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) + } + + //删除数据 + stmt, errrow = db.Prepare("delete from userinfo where uid=?") + checkErr(errrow) + + res, errres = stmt.Exec(id) + checkErr(errres) + + affect, erraff = res.RowsAffected() + checkErr(erraff) + + fmt.Println(affect) + + } + + func checkErr(err error) { + if err != nil { + panic(err) + } + } + +通过上面的代码我们可以看出,Go操作Mysql数据库是很方便的。 + +关键的几个函数我解释一下: + +sql.Open()函数用来打开一个注册过的数据库驱动,go-mysql-driver中注册了mysql这个数据库驱动,第二个参数是DNS(Data Source Name),它是go-mysql-drivev定义的一些数据库链接和配置信息。它支持如下格式: + + user@unix(/path/to/socket)/dbname?charset=utf8 + user:password@tcp(localhost:5555)/dbname?charset=utf8&keepalive=1 + user:password@/dbname + user:password@tcp([de:ad:be:ef::ca:fe]:80)/dbname + +db.Prepare()函数用来返回准备要执行的sql操作,然后返回准备完毕的执行状态。 + +db.Query()函数用来直接执行Sql返回Rows结果。 + +stmt.Exec()函数用来执行stmt准备好的SQL语句 + +我们可以看到我们传入的参数都是=?对应的数据,这样做的方式可以一定程度上防止SQL注入。 + ## links