5.2小节完成

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)

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