匯入所需的包，然後準備一個與資料庫中tb_student表的範例具有相同模式的結構體，稍後該結構體將用作查詢結果的容器資料類型。
package main
import "fmt"
import "database/sql"
import _ "github.com/go-sql-driver/mysql"
type student struct {
id string,
name string,
age int,
grade int,
}
使用的資料庫驅動程式需要使用_符號導入，因為儘管database/sql包需要它，但我們不會直接與驅動程式互動。
接下來，建立一個連接資料庫的函數。
func connect() (*sql.DB, error) {
db, err := sql.Open("mysql","root:@tcp(127.0.0.1:3306)/db_learn_go")
if err != nil {
return nil, err
}
return db, nil
}
我們使用的mysql 驅動程式的連接字串方案非常獨特，下面的root@tcp(127.0.0.1:3306)/db_learn_go 是可以在go MYSQL Driver 驅動程式上使用的連接字串方案，如果您使用另一個mysql，根據所使用的驅動程序，連接方案可能會有所不同。
user:password@tcp(host:port)/dbname user@tcp(host:port)/dbname
下面是對 connect() 函數中使用的連接字串的解釋。
root@tcp(127.0.0.1:3306)/db_learn_go // user => root // password => // host => 127.0.0.1 atau localhost // port => 3306 // dbname => db_learn_go
連接資料庫的函數建立完成後，就可以練習從資料庫伺服器讀取資料的過程了。準備函數
sqlQuery() 使用下列程式碼。
func sqlQuery() {
db, err := connect()
if err != nil {
fmt.Println(err.Error())
return
}
defer db.Close()
var age = 27
rows, err := db.Query("select id, name, grade from tb_student where age = ?
if err != nil {
fmt.Println(err.Error())
return
}
defer rows.Close()
var result []student
for rows.Next() {
var each = student{}
var err = rows.Scan(&each.id, &each.name, &each.grade)
if err != nil {
fmt.Println(err.Error())
return
}
result = append(result, each)
}
if err = rows.Err(); err != nil {
fmt.Println(err.Error())
return
}
for _, each := range result {
fmt.Println(each.name)
}
}
每次建立新連線時，不要忘記始終關閉連線實例。您可以使用 defer 關鍵字，如上面的程式碼所示，defer
db.Close() .
db.Query()函數用於執行sql查詢。此函數的第二個參數是可變參數，因此可以留空。在上面的程式碼中，您可以看到其中一個 where 子句的值為問號 (?)。
該符號將被其後面的參數中的值（年齡變數的值）取代。強烈推薦這種類型的查詢編寫技術，以防止 SQL 注入。此函數產生一個 sql.*Rows 類型的實例，當不再使用時也需要將其關閉（ defer rows.Close() ）。接下來，準備一個元素類型為 struct Student 且名稱為 result 的陣列。稍後查詢結果將儲存在變數中。然後執行循環，條件引用為 rows.Next() 。此循環執行的次數與記錄總數相同，從第一筆記錄到最後一筆記錄依序執行。 sql.Rows 的 Scan() 方法用於檢索正在迭代的記錄的值，並將其儲存在指標變數中。根據查詢中選擇的字段，用於儲存記錄字段的變數被順序寫入為可變參數。請參閱下面的比較以了解更多詳細資訊。 // 查詢
選擇 ID、姓名、年級...
// 掃描
rows.Scan(&each.id, &each.name, &each.grade ...
然後將所得的記錄資料透過語句
附加到結果切片中
結果=附加（結果，每個）。
好的，現在只需在 main 中呼叫 sqlQuery() 函數，然後執行程式即可。
func main() {
sqlQuery()
}
我只是一個普通的部落客。如果還有太多不足之處還請見諒。
以上是從Mysql伺服器讀取數據的詳細內容。更多資訊請關注PHP中文網其他相關文章！
