上一节主要实现了使用 从图片网站 抓取数据。主要抓取图片的data-original、width、height、alt、type 五项数据。因此需要先创建数据库和相应的表，在mac上我使用 Sequel Pro 数据库管理软件，连接之后创建新的数据库indiepic,然后创建表gratisography:

CREATE TABLE `gratisography` (  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,  `img_url` varchar(255) DEFAULT NULL,  `type_name` varchar(50) DEFAULT NULL,  `title` varchar(255) DEFAULT NULL,  `width` int(11) DEFAULT NULL,  `height` int(11) DEFAULT NULL,  `create_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP,  PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=388 DEFAULT CHARSET=utf8;

创建完数据库之后，就开始使用GO来实现连接数据库等操作了。在GO中使用 is a lightweight and fast MySQL-Driver for Go's (golang) database/sql package

文档：

在使用之前需要先使用以下命令获取该包：

go get github.com/go-sql-driver/mysql

然后在database.go中引入：

package crawldataimport (    "database/sql"    _ "github.com/go-sql-driver/mysql")

然后写一个打开数据库的方法OpenDatabase:

package crawldataimport (    "database/sql"    _ "github.com/go-sql-driver/mysql")func OpenDatabase() (*sql.DB, error) {    // 连接数据库    db, err := sql.Open("mysql", "root:mysql@tcp(xxx.xx.xx.xxx:3306)/databaseName?charset=utf8")    if err != nil {        return nil, err    }    return db, nil}

上一节已在crawldata.go中写了InsertData(&imageDatas)方法，但是是注释的，先在就需要在该文件中实现该方法。

package crawldataimport (    "database/sql"    "fmt"    _ "github.com/go-sql-driver/mysql"    "strconv"    s "strings")func OpenDatabase() (*sql.DB, error) {    // 连接数据库    db, err := sql.Open("mysql", "root:mysql@tcp(xxx.xx.xx.xxx:3306)/databaseName?charset=utf8")    if err != nil {        return nil, err    }    return db, nil}/*   该函数将获取的数据存储到数据库*/func InsertData(datas *ImageDatas) {    imageDatas := *datas    // 连接数据库    db, err := OpenDatabase()    if err != nil {        fmt.Printf(s.Join([]string{"连接数据库失败", err.Error()}, "-->"))    }    defer db.Close()    for i := 0; i < len(imageDatas); i++ {        imageData := imageDatas[i]        // Prepare statement for inserting data        imgIns, err := db.Prepare("INSERT INTO gratisography (img_url, type_name, title, width, height) VALUES( ?, ?, ?, ?, ? )") // ? = placeholder        if err != nil {            fmt.Println(s.Join([]string{"拼装数据格式", err.Error()}, "-->"))        }        defer imgIns.Close() // Close the statement when we leave main()        img, err := imgIns.Exec(s.Join([]string{"http://www.gratisography.com", imageData.Src}, "/"), imageData.Tp, imageData.Title, imageData.Width, imageData.Height)        if err != nil {            fmt.Println(s.Join([]string{"插入数据失败", err.Error()}, "-->"))        } else {            success, _ := img.LastInsertId()            // 数字变成字符串,success是int64型的值，需要转为int，网上说的Itoa64()在strconv包里不存在            insertId := strconv.Itoa(int(success))            fmt.Println(s.Join([]string{"成功插入数据：", insertId}, "\t-->\t"))        }    }}

到此已经完成了数据抓取并存入数据库，在命令行中切换到$GOPATH/src/indiepic目录下，然后运行：

go run indiepic.go

随后就可以看到数据被存入数据库了。