從Mysql伺服器讀取數據

匯入所需的包，然後準備一個與資料庫中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中文網其他相關文章！