」工欲善其事,必先利其器。「—孔子《論語.錄靈公》
首頁 > 程式設計 > 從Mysql伺服器讀取數據

從Mysql伺服器讀取數據

發佈於2024-07-30
瀏覽:849

Reading data from Mysql server

匯入所需的包,然後準備一個與資料庫中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() 方法用於檢索正在迭代的記錄的值,並將其儲存在指標變數中。根據查詢中選擇的字段,用於儲存記錄字段的變數被順序寫入為可變參數。請參閱下面的比較以了解更多詳細資訊。 // 詢問
選擇身分證、姓名、年級...
// 掃描
rows.Scan(&each.id, &each.name, &each.grade ...
然後將所得的記錄資料透過語句
附加到結果切片中 結果 = 附加(結果,每個).
好的,現在只需在 main 中呼叫 sqlQuery() 函數,然後執行程式即可。

func main() {
sqlQuery()
}

我只是一個普通的部落客。如果還有太多不足之處還請見諒。

版本聲明 本文轉載於:https://dev.to/sukmarizki04/reading-data-from-mysql-server-2gcp?1如有侵犯,請聯絡[email protected]刪除
最新教學 更多>

免責聲明: 提供的所有資源部分來自互聯網,如果有侵犯您的版權或其他權益,請說明詳細緣由並提供版權或權益證明然後發到郵箱:[email protected] 我們會在第一時間內為您處理。

Copyright© 2022 湘ICP备2022001581号-3