匯入所需的包,然後準備一個與資料庫中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()
}
我只是一個普通的部落客。如果還有太多不足之處還請見諒。
免責聲明: 提供的所有資源部分來自互聯網,如果有侵犯您的版權或其他權益,請說明詳細緣由並提供版權或權益證明然後發到郵箱:[email protected] 我們會在第一時間內為您處理。
Copyright© 2022 湘ICP备2022001581号-3