Go語言是一個開源的程式語言,它能讓建構簡單、可靠且有效率的軟體變得容易。 go語言教學欄位就來為大家介紹一下go語言中操作MySQL資料庫的方法。
Go語言操作MySQL資料庫:
安裝go操作MySQL的驅動程式
go get -u -v github.com/go-sql-driver/mysql
go操作MySQL資料庫
導包
import _ "github.com/go-sql-driver/mysql"
程式在操作資料庫的時候只需要用到database/sql,而不需要直接使用資料庫驅動,所以程式在導入資料庫驅動的時候將這個包的名字設定成底線。
連接資料庫,用sql.Open()方法,open()方法的第一個參數是驅動名稱,第二個參數是連接字串,格式為:使用者名稱:密碼@tcp(ip :port)/資料庫名稱?編碼方式,傳回值是連接物件和錯誤訊息,例如:
conn,err := sql.Open("mysql","root:123456@tcp(127.0.0.1:3306)/test?charset=utf8") defer conn.Close()//随手关闭数据库是个好习惯
執行資料庫操作。
資料庫的主要方法有:
Query 執行資料庫的查詢操作,例如一個Select語句,傳回資料類型為*Rows
QueryRow 執行資料庫至多傳回一條數據,傳回資料型別為*Row
Exec 執行數不傳回任何rows的據庫語句,例如delete操作
PrePare 準備一個資料庫query操作,傳回一個*Stmt,用於後續query或Exec。這個Stmt可以被多次執行,或是並發執行
建立表格
#exec函數如下:
func (db *DB) Exec(query string, args ...interface{}) (Result, error)
建立表格的方法也是Exec() ,參數是SQL語句,傳回值是結果集和錯誤訊息.
其中result包含的內容有:
type Result interface { LastInsertId() (int64, error) RowsAffected() (int64, error) }
RowsAffected() 函數,可以獲得成功執行SQL後對資料庫所影響的行數。
res ,err:= conn.Exec("create table user(name VARCHAR(40),pwd VARCHAR(40))") beego.Info("create table result=",res.,err)
增刪改操作
執行增刪改操作語句的是Exec(),參數是SQL語句,傳回值是結果集和錯誤訊息,透過對結果集的判斷,得到執行結果的資訊。以插入資料為例程式碼如下:
res,_:=stmt.Exec("insert user(name,pwd) values (?,?)","tony","tony") count,_:=res.RowsAffected() this.Ctx.WriteString(strconv.Itoa(int(count)))
查詢操作
#使用的函數是Query()和QueryRow.
func (db *DB) QueryRow(query string, args ...interface{}) *Row func (db *DB) Query(query string, args ...interface{}) (*Rows, error)
利用QueryRow實作單行查詢,能確定該SQL語句的查詢結果為一筆記錄。將結果中的欄位值使用Scan()函數依序擷取。
利用Query實作多行資料查詢,傳回值為查詢結果集和錯誤訊息。透過next和Scan函數一起取出資料
程式碼如下:
單行查詢:
row:= conn.QueryRow(`select * from user where userName = "wyj"`) var name,pwd string row.Scan(&name,&pwd) beego.Info(name,"------",pwd)
多行查詢:
data ,err :=conn.Query("SELECT name from user") var userName string if err == nil{ for data.Next(){ data.Scan(&userName) beego.Info(userName) } }
全部程式碼
//连接数据库 conn,err := sql.Open("mysql","root:123456@tcp(127.0.0.1:3306)/testtest?charset=utf8") if err != nil{ beego.Info("链接失败") } defer conn.Close() //建表 res ,err:= conn.Exec("create table user(userName VARCHAR(40),passwd VARCHAR(40))") beego.Info("create table result=",res,err) //插入数据 res,err =conn.Exec("insert user(userName,passwd) values(?,?)","itcast","heima") beego.Info(res,err) //单行查询 row:= conn.QueryRow(`select * from user where userName = "wyj"`) var name,pwd string row.Scan(&name,&pwd) beego.Info(name,"------",pwd) //多行查询 data ,err :=conn.Query("SELECT userName from user") var userName string if err == nil{ for data.Next(){ data.Scan(&userName) beego.Error(userName) } }
更多go語言知識請關注php中文網go語言教學欄位。
以上是Go語言中操作MySQL資料庫的方法的詳細內容。更多資訊請關注PHP中文網其他相關文章!