溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
目前 Internet 上流行的網站構架方式是 LAMP/LNMP，其中的 M 即 MySQL, 作為數據庫，MySQL 以免費、開源、使用方便為優勢成為了很多Web開發的后端數據庫存儲引擎。
Go中支持MySQL的驅動目前比較多，有如下幾種，有些是支持database/sql標準，而有些是采用了自己的實現接口，常用的有如下幾種：
https://github.com/go-sql-driver/mysql 支持database/sql，全部采用go寫。
https://github.com/ziutek/mymysql 支持database/sql，也支持自定義的接口，全部采用go寫。
https://github.com/Philio/GoMySQL 不支持database/sql，自定義接口，全部采用go寫。
接下來的例子主要以第一個驅動為例，推薦主要理由是：
這個驅動比較新，維護的比較好；
完全支持database/sql接口；
支持keepalive，保持長連接。
接下來的幾個小節里面我們都將采用同一個數據庫表結構：數據庫test，用戶表userinfo，關聯用戶信息表userdetail。
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
);
8
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
)
如下示例將示范如何使用database/sql接口對數據庫表進行增刪改查操作：
1
// 示例代碼11-15
2
package
main
3
4
import
(
5
"database/sql"
6
"fmt"
7
//"time"
8
9
_
"github.com/go-sql-driver/mysql"
10
)
11
12
func
main
()
{
13
db, err := sql.Open(
"mysql"
,
"zuolan:zuolan@/test?charset=utf8"
)
14
checkErr(err)
15
16
//插入數據
17
stmt, err := db.Prepare(
"INSERT userinfo SET username=?,departname=?,created=?"
)
18
checkErr(err)
19
20
res, err := stmt.Exec(
"張三"
,
"研發部門"
,
"2017-09-09"
)
21
checkErr(err)
22
23
id, err := res.LastInsertId()
24
checkErr(err)
25
26
fmt.Println(id)
27
//更新數據
28
stmt, err = db.Prepare(
"update userinfo set username=? where uid=?"
)
29
checkErr(err)
30
31
res, err = stmt.Exec(
"zuolanupdate"
, id)
32
checkErr(err)
33
34
affect, err := res.RowsAffected()
35
checkErr(err)
36
37
fmt.Println(affect)
38
39
//查詢數據
40
rows, err := db.Query(
"SELECT * FROM userinfo"
)
41
checkErr(err)
42
43
for
rows.Next() {
44
var
uid
int
45
var
username
string
46
var
department
string
47
var
created
string
48
err = rows.Scan(&uid, &username, &department, &created)
49
checkErr(err)
50
fmt.Println(uid)
51
fmt.Println(username)
52
fmt.Println(department)
53
fmt.Println(created)
54
}
55
56
//刪除數據
57
stmt, err = db.Prepare(
"delete from userinfo where uid=?"
)
58
checkErr(err)
59
60
res, err = stmt.Exec(id)
61
checkErr(err)
62
63
affect, err = res.RowsAffected()
64
checkErr(err)
65
66
fmt.Println(affect)
67
68
db.Close()
69
70
}
71
72
func
checkErr
(err error)
{
73
if
err !=
nil
{
74
panic
(err)
75
}
76
}
通過上面的代碼我們可以看出，Go操作MySQL數據庫是很方便的。
sql.Open()函數用來打開一個注冊過的數據庫驅動，go-sql-driver中注冊了mysql這個數據庫驅動，第二個參數是DSN(Data Source Name)，它是go-sql-driver定義的一些數據庫鏈接和配置信息。它支持如下格式：
1
user
@
unix
(/
path
/
to
/
socket
)/
dbname
?
charset
=
utf8
2
user:password@tcp(localhost:
5555
)/dbname?charset=utf8
3
user:password@/dbname
4
user:password@tcp([de:ad:be:ef::ca:fe]:
80
)/dbname
db.Prepare()函數用來返回準備要執行的sql操作，然后返回準備完畢的執行狀態。
db.Query()函數用來直接執行Sql返回Rows結果。
stmt.Exec()函數用來執行stmt準備好的SQL語句
我們可以看到我們傳入的參數都是=?對應的數據，這樣做的方式可以一定程度上防止SQL注入。
SQLite是一個開源的嵌入式關系數據庫，實現自包容、零配置、支持事務的SQL數據庫引擎。其特點是高度便攜、使用方便、結構緊湊、高效、可靠。與其他數據庫管理系統不同，SQLite的安裝和運行非常簡單，在大多數情況下，只要確保SQLite的二進制文件存在即可開始創建、連接和使用數據庫。
如果您正在尋找一個嵌入式數據庫項目或解決方案，SQLite是絕對值得考慮。SQLite可以是說開源的Access。
Go支持sqlite的驅動也比較多，但是很多都不支持database/sql接口：
https://github.com/mattn/go-sqlite3 支持database/sql接口，基于cgo（關于cgo的知識請參看官方文檔）。
https://github.com/feyeleanor/gosqlite3 不支持database/sql接口，基于cgo。
https://github.com/phf/go-sqlite3 不支持database/sql接口，基于cgo。
目前支持database/sql的SQLite數據庫驅動比較少，采用標準接口有利于以后出現更好的驅動的時候做遷移，因此本節后面都采用第一個驅動。
示例的數據庫表結構如下所示，相應的建表SQL：
1
CREATE
TABLE
`userinfo`
(
2
`uid`
INTEGER
PRIMARY
KEY
AUTOINCREMENT,
3
`username`
VARCHAR
(
64
)
NULL
,
4
`departname`
VARCHAR
(
64
)
NULL
,
5
`created`
DATE
NULL
6
);
7
8
CREATE
TABLE
`userdeatail`
(
9
`uid`
INT
(
10
)
NULL
,
10
`intro`
TEXT
NULL
,
11
`profile`
TEXT
NULL
,
12
PRIMARY
KEY
(
`uid`
)
13
);
看下面Go程序是如何操作數據庫表，進行數據增刪改查的：
1
// 示例代碼11-16
2
package
main
3
4
import
(
5
"database/sql"
6
"fmt"
7
"time"
8
9
_
"github.com/mattn/go-sqlite3"
10
)
11
12
func
main
()
{
13
db, err := sql.Open(
"sqlite3"
,
"./demo.db"
)
14
checkErr(err)
15
16
//插入數據
17
stmt, err := db.Prepare(
"INSERT INTO userinfo(username, departname, created) values(?,?,?)"
)
18
checkErr(err)
19
20
res, err := stmt.Exec(
"張三"
,
"研發部門"
,
"2017-09-09"
)
21
checkErr(err)
22
23
id, err := res.LastInsertId()
24
checkErr(err)
25
26
fmt.Println(id)
27
//更新數據
28
stmt, err = db.Prepare(
"update userinfo set username=? where uid=?"
)
29
checkErr(err)
30
31
res, err = stmt.Exec(
"zuolanupdate"
, id)
32
checkErr(err)
33
34
affect, err := res.RowsAffected()
35
checkErr(err)
36
37
fmt.Println(affect)
38
39
//查詢數據
40
rows, err := db.Query(
"SELECT * FROM userinfo"
)
41
checkErr(err)
42
43
for
rows.Next() {
44
var
uid
int
45
var
username
string
46
var
department
string
47
var
created time.Time
48
err = rows.Scan(&uid, &username, &department, &created)
49
checkErr(err)
50
fmt.Println(uid)
51
fmt.Println(username)
52
fmt.Println(department)
53
fmt.Println(created)
54
}
55
56
//刪除數據
57
stmt, err = db.Prepare(
"delete from userinfo where uid=?"
)
58
checkErr(err)
59
60
res, err = stmt.Exec(id)
61
checkErr(err)
62
63
affect, err = res.RowsAffected()
64
checkErr(err)
65
66
fmt.Println(affect)
67
68
db.Close()
69
70
}
71
72
func
checkErr
(err error)
{
73
if
err !=
nil
{
74
panic
(err)
75
}
76
}
我們可以看到上面的代碼和MySQL例子里面的代碼幾乎是一模一樣的，唯一改變的就是導入的驅動改變了，然后調用sql.Open是采用了SQLite的方式打開。
PostgreSQL是一個自由的對象-關系數據庫服務器（數據庫管理系統），它在靈活的BSD風格許可證下發行。它提供了相對其他開放源代碼數據庫系統（比如MySQL和Firebird），和對專有系統比如Oracle、Sybase、IBM的DB2和Microsoft SQL Server的一種選擇。
PostgreSQL和MySQL比較，它更加龐大一點，因為它是用來替代Oracle而設計的。所以在企業應用中采用PostgreSQL是一個明智的選擇。
MySQL被Oracle收購之后正在逐步的封閉（自MySQL 5.5.31以后的所有版本將不再遵循GPL協議），鑒于此，將來我們也許會選擇PostgreSQL而不是MySQL作為項目的后端數據庫。
Go實現的支持PostgreSQL的驅動也很多，因為國外很多人在開發中使用了這個數據庫。
https://github.com/lib/pq 支持database/sql驅動，純Go寫的；
https://github.com/jbarham/gopgsqldriver 支持database/sql驅動，純Go寫的；
https://github.com/lxn/go-pgsql 支持database/sql驅動，純Go寫的。
在下面的示例中采用第一個驅動，因為它目前使用的人最多，在Github上也比較活躍。
數據庫建表語句：
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
);
10
11
CREATE
TABLE
userdeatail
12
(
13
uid
integer
,
14
intro
character
varying
(
100
),
15
profile
character
varying
(
100
)
16
)
17
WITH
(OIDS=
FALSE
);
看下面這個Go如何操作數據庫表，進行數據的增刪改查：
1
// 示例代碼11-17
2
package
main
3
4
import
(
5
"database/sql"
6
"fmt"
7
8
_
"github.com/lib/pq"
9
)
10
11
func
main
()
{
12
db, err := sql.Open(
"postgres"
,
"user=zuolan password=zuolan dbname=test sslmode=disable"
)
13
checkErr(err)
14
15
//插入數據
16
stmt, err := db.Prepare(
"INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) RETURNING uid"
)
17
checkErr(err)
18
19
res, err := stmt.Exec(
"張三"
,
"研發部門"
,
"2017-09-09"
)
20
checkErr(err)
21
22
// pg不支持這個函數，因為他沒有類似MySQL的自增ID
23
// id, err := res.LastInsertId()
24
// checkErr(err)
25
// fmt.Println(id)
26
27
var
lastInsertId
int
28
err = db.QueryRow(
"INSERT INTO userinfo(username,departname,created) VALUES($1,$2,$3) returning uid;"
,
"zuolan"
,
"研發部門"
,
"2017-09-09"
).Scan(&lastInsertId)
29
checkErr(err)
30
fmt.Println(
"最后插入id ="
, lastInsertId)
31
32
33
//更新數據
34
stmt, err = db.Prepare(
"update userinfo set username=$1 where uid=$2"
)
35
checkErr(err)
36
37
res, err = stmt.Exec(
"zuolanupdate"
,
1
)
38
checkErr(err)
39
40
affect, err := res.RowsAffected()
41
checkErr(err)
42
43
fmt.Println(affect)
44
45
//查詢數據
46
rows, err := db.Query(
"SELECT * FROM userinfo"
)
47
checkErr(err)
48
49
for
rows.Next() {
50
var
uid
int
51
var
username
string
52
var
department
string
53
var
created
string
54
err = rows.Scan(&uid, &username, &department, &created)
55
checkErr(err)
56
fmt.Println(uid)
57
fmt.Println(username)
58
fmt.Println(department)
59
fmt.Println(created)
60
}
61
62
//刪除數據
63
stmt, err = db.Prepare(
"delete from userinfo where uid=$1"
)
64
checkErr(err)
65
66
res, err = stmt.Exec(
1
)
67
checkErr(err)
68
69
affect, err = res.RowsAffected()
70
checkErr(err)
71
72
fmt.Println(affect)
73
74
db.Close()
75
76
}
77
78
func
checkErr
(err error)
{
79
if
err !=
nil
{
80
panic
(err)
81
}
82
}
從上面的代碼我們可以看到，PostgreSQL是通過 1, 2這種方式來指定要傳遞的參數，而不是MySQL中的?，另外在sql.Open中的dsn信息的格式也與MySQL的驅動中的dsn格式不一樣，所以在使用時請注意它們的差異。
還有pg不支持LastInsertId函數，因為PostgreSQL內部沒有實現類似MySQL的自增ID返回，其他的代碼幾乎是一模一樣。
NoSQL(Not Only SQL)，指的是非關系型的數據庫。隨著Web2.0的興起，傳統的關系數據庫在應付Web2.0網站，特別是超大規模和高并發的SNS類型的Web2.0純動態網站已經顯得力不從心，暴露了很多難以克服的問題，而非關系型的數據庫則由于其本身的特點得到了非常迅速的發展。
而Go語言作為21世紀的C語言，對NOSQL的支持也是很好，目前流行的NOSQL主要有redis、mongoDB、Cassandra和Membase等。這些數據庫都有高性能、高并發讀寫等特點，目前已經廣泛應用于各種應用中。
redis是一個key-value存儲系統。和Memcached類似，它支持存儲的value類型相對更多，包括string(字符串)、list(鏈表)、set(集合)和zset(有序集合)。
目前應用redis最廣泛的應該是新浪微博平臺，其次還有Facebook收購的圖片社交網站instagram。Go目前支持redis的驅動有如下：
https://github.com/garyburd/redigo
https://github.com/go-redis/redis
https://github.com/hoisie/redis
https://github.com/alphazero/Go-Redis
https://github.com/simonz05/godis
推薦使用第一個，用法上和上面驅動沒有太大區別，限于篇幅不再展開。
MongoDB是一個高性能，開源，無模式的文檔型數據庫，是一個介于關系數據庫和非關系數據庫之間的產品，是非關系數據庫當中功能最豐富，最像關系數據庫的。他支持的數據結構非常松散，采用的是類似json的bjson格式來存儲數據，因此可以存儲比較復雜的數據類型。Mongo最大的特點是他支持的查詢語言非常強大，其語法有點類似于面向對象的查詢語言，幾乎可以實現類似關系數據庫單表查詢的絕大部分功能，而且還支持對數據建立索引。
目前Go支持mongoDB最好的驅動就是mgo（http://labix.org/mgo），這個驅動目前最有可能成為官方的pkg。安裝mgo的命令為：
1go get gopkg.in/mgo.v2
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
