2. 程式人生 > >golang mysql資料庫基本操作筆記

golang mysql資料庫基本操作筆記

阿新 • • 發佈：2018-12-18

mysql目前來說是使用最為流行的關係型資料庫，在程式設計過程中得到廣泛應用。golang操作mysql使用最多的包go-sql-driver/mysql。sqlx包是作為database/sql包的一個額外擴充套件包，在原有的database/sql加了很多擴充套件，如直接將查詢的資料轉為結構體，大大簡化了程式碼書寫，當然database/sql包中的方法同樣起作用。

github地址：

https://github.com/go-sql-driver/mysql
https://github.com/jmoiron/sqlx

golang sql使用：

database/sql documentation 
go-database-sql tutorial

安裝

go get "github.com/go-sql-driver/mysql"
go get "github.com/jmoiron/sqlx"

連線資料庫

var Db *sqlx.DB
db, err := sqlx.Open("mysql","username:[email protected](ip:port)/database?charset=utf8")
Db = db

處理型別（Handle Types)

sqlx設計和database/sql使用方法是一樣的。包含有4中主要的handle types：

sqlx.DB - 和sql.DB相似，表示資料庫。 
sqlx.Tx - 和sql.Tx相似，表示事物。 
sqlx.Stmt - 和sql.Stmt相似，表示prepared statement。 
sqlx.NamedStmt - 表示prepared statement（支援named parameters）

所有的handler types都提供了對database/sql的相容，意味著當你呼叫sqlx.DB.Query時，可以直接替換為sql.DB.Query.這就使得sqlx可以很容易的加入到已有的資料庫專案中。

此外，sqlx還有兩個cursor型別：

sqlx.Rows - 和sql.Rows類似，Queryx返回。 
sqlx.Row - 和sql.Row類似，QueryRowx返回。

相比database/sql方法還多了新語法，也就是實現將獲取的資料直接轉換結構體實現。

 Get(dest interface{}, …) error
    Select(dest interface{}, …) error

建表

以下所有示例均已以下表結構作為操作基礎。

CREATE TABLE `userinfo` (
    `uid` INT(10) NOT NULL AUTO_INCREMENT,
    `username` VARCHAR(64)  DEFAULT NULL,
    `password` VARCHAR(32)  DEFAULT NULL,
    `department` VARCHAR(64)  DEFAULT NULL,
    `email` varchar(64) DEFAULT NULL,
    PRIMARY KEY (`uid`)
)ENGINE=InnoDB DEFAULT CHARSET=utf8

Exec使用

Exec和MustExec從連線池中獲取一個連線然後只想對應的query操作。對於不支援ad-hoc query execution的驅動 ，在操作執行的背後會建立一個prepared statement。在結果返回前這個connection會返回到連線池中。

需要注意的是不同的資料庫型別使用的佔位符不同，mysql採用？作為佔位符號。

MySQL 使用？ 
PostgreSQL 使用1,1,2等等 
SQLite 使用？或$1 
Oracle 使用:name

Exec增刪改示例

查詢語法使用Query後續會提到

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

func init()  {
    db,err:=sqlx.Open("mysql","username:[email protected](ip:port)/database?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
}

func main()  {
    result, err := Db.Exec("INSERT INTO userinfo (username, password,department,email) VALUES (?, ?,?,?)","TigerwolfC","666666","it","[email protected]")
    if err != nil{
        fmt.Println("insert failed,error： ", err)
        return
    }
    id,_ := result.LastInsertId()
    fmt.Println("insert id is :",id)
    _, err1 := Db.Exec("update userinfo set username = ? where uid = ?","chen_peggy",1)
    if err1 != nil{
        fmt.Println("update failed error:",err1)
    } else {
        fmt.Println("update success!")
    }
    _, err2 := Db.Exec("delete from userinfo where uid = ? ", 1)
    if err2 != nil{

        fmt.Println("delete error:",err2)
    }else{
        fmt.Println("delete success")
    }

}
//insert id is : 1
//update success!
//delete success

sql預宣告（Prepared Statements）

對於大部分的資料庫來說，當一個query執行的時候，在sql語句資料庫內部宣告已經宣告過了，其宣告是在資料庫中，我們可以提前進行宣告，以便在其他地方重用。

stmt, err := db.Prepare(`SELECT * FROM place WHERE telcode=?`)
row = stmt.QueryRow(65)
 
tx, err := db.Begin()
txStmt, err := tx.Prepare(`SELECT * FROM place WHERE telcode=?`)
row = txStmt.QueryRow(852)

當然sqlx還提供了Preparex()進行擴充套件，可直接用於結構體轉換

  stmt, err := db.Preparex(`SELECT * FROM place WHERE telcode=?`)
  var p Place
  err = stmt.Get(&p, 852)

Query

Query是database/sql中執行查詢主要使用的方法，該方法返回row結果。Query返回一個sql.Rows物件和一個error物件。

在使用的時候應該吧Rows當成一個遊標而不是一系列的結果。儘管資料庫驅動快取的方法不一樣，通過Next()迭代每次獲取一列結果，對於查詢結果非常巨大的情況下，可以有效的限制記憶體的使用，Scan()利用reflect把sql每一列結果對映到go語言的資料型別如string，[]byte等。如果你沒有遍歷完全部的rows結果，一定要記得在把connection返回到連線池之前呼叫rows.Close()。

Query返回的error有可能是在server準備查詢的時候發生的，也有可能是在執行查詢語句的時候發生的。例如可能從連線池中獲取一個壞的連級（儘管資料庫會嘗試10次去發現或建立一個工作連線）。一般來說，錯誤主要由錯誤的sql語句，錯誤的類似匹配，錯誤的域名或表名等。

在大部分情況下，Rows.Scan()會把從驅動獲取的資料進行拷貝，無論驅動如何使用快取。特殊型別sql.RawBytes可以用來從驅動返回的資料總獲取一個zero-copy的slice byte。當下一次呼叫Next的時候，這個值就不在有效了，因為它指向的記憶體已經被驅動重寫了別的資料。

Query使用的connection在所有的rows通過Next()遍歷完後或者呼叫rows.Close()後釋放。

示例：

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

func init()  {
    db, err := sqlx.Open("mysql", "user:[email protected](localhost:3306)/dbname?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
}

func main()  {
    rows, err := Db.Query("SELECT username,password,email FROM userinfo")
    if err != nil{
        fmt.Println("query failed,error： ", err)
        return
    }
    for rows.Next() {  //迴圈結果
        var username,password,email string
        err = rows.Scan(&username, &password, &email)
        println(username,password,email)
    }
    
}
//	TigerwolfC 666666 [email protected]
//  chen_peggy 888888 [email protected]

Queryx

Queryx和Query行為很相似，不過返回一個sqlx.Rows物件，支援擴充套件的scan行為,同時可將對資料進行結構體轉換。

示例：

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

type stu struct {
    Username string   `db:"username"`
    Password string      `db:"password"`
    Department string  `db:"department"`
    Email string        `db:"email"`
}

func init()  {
    db, err := sqlx.Open("mysql", "user:[email protected](localhost:3306)/dbname?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
}

func main()  {
    rows, err := Db.Queryx("SELECT username,password,email FROM userinfo")
    if err != nil{
        fmt.Println("Qeryx failed,error： ", err)
        return
    }
    for rows.Next() {  //迴圈結果
        var stu1 stu
        err = rows.StructScan(&stu1)// 轉換為結構體
        fmt.Println("stuct data：",stu1.Username,stu1.Password)
    }
}
//stuct data： TigerwolfC 666666
//stuct data： chen_peggy 888888

QueryRow和QueryRowx

QueryRow和QueryRowx都是從資料庫中獲取一條資料，但是QueryRowx提供scan擴充套件，可直接將結果轉換為結構體。

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

type stu struct {
    Username string   `db:"username"`
    Password string      `db:"password"`
    Department string  `db:"department"`
    Email string        `db:"email"`
}

func init()  {
    db, err := sqlx.Open("mysql", "user:[email protected](localhost:3306)/dbname?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
}

func main()  {
    row := Db.QueryRow("SELECT username,password,email FROM userinfo where uid = ?",1) // QueryRow返回錯誤，錯誤通過Scan返回
    var username,password,email string
    err :=row.Scan(&username,&password,&email)
    if err != nil{
        fmt.Println(err)
    }
    fmt.Printf("this is QueryRow res:[%s:%s:%s]\n",username,password,email)
    var s stu
    err1 := Db.QueryRowx("SELECT username,password,email FROM userinfo where uid = ?",2).StructScan(&s)
    if err1 != nil{
        fmt.Println("QueryRowx error :",err1)
    }else {
        fmt.Printf("this is QueryRowx res:%v",s)
    }
}
//this is QueryRow res:[TigerwolfC:666666:[email protected]]
//this is QueryRowx res:{chen_peggy 888888 [email protected]}

Get 和Select（非常常用）

Get和Select是一個非常省時的擴充套件，可直接將結果賦值給結構體，其內部封裝了StructScan進行轉化。Get用於獲取單個結果然後Scan，Select用來獲取結果切片。

示例：

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

type stu struct {
    Username string   `db:"username"`
    Password string      `db:"password"`
    Department string  `db:"department"`
    Email string        `db:"email"`
}

func init()  {
    db, err := sqlx.Open("mysql", "user:[email protected](localhost:3306)/dbname?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
}

func main()  {
    var stus []stu
    err := Db.Select(&stus,"SELECT username,password,email FROM userinfo")
    if err != nil{
        fmt.Println("Select error",err)
    }
    fmt.Printf("this is Select res:%v\n",stus)
    var s stu
    err1 := Db.Get(&s,"SELECT username,password,email FROM userinfo where uid = ?",2)
    if err1 != nil{
        fmt.Println("GET error :",err1)
    }else {
        fmt.Printf("this is GET res:%v",s)
    }
}
//this is Select res:[{TigerwolfC 666666  [email protected]} {chen_peggy 888888 [email protected]}]
//this is GET res:{chen_peggy 888888 [email protected]}

事務（Transactions）

事務操作是通過三個方法實現：

Begin()：開啟事務

Commit()：提交事務（執行sql)

Rollback()：回滾

使用流程：

tx, err := db.Begin()
err = tx.Exec(...)
err = tx.Commit()

//或者使用sqlx擴充套件的事務

tx := db.MustBegin()
tx.MustExec(...)
err = tx.Commit()

由於事務是一個一直連線的狀態，所以Tx物件必須繫結和控制單個連線。一個Tx會在整個生命週期中儲存一個連線，然後在呼叫commit或Rollback()的時候釋放掉。在呼叫這幾個函式的時候必須十分小心，否則連線會一直被佔用直到被垃圾回收。

使用示例：

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

func init()  {
    db, err := sqlx.Open("mysql", "user:[email protected](localhost:3306)/dbname?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
}

func main()  {
    tx, err := Db.Beginx()
    _, err = tx.Exec("insert into userinfo(username,password) values(?,?)", "Rose","2223")
    if err != nil {
        tx.Rollback()
    }
    _, err = tx.Exec("insert into userinfo(username,password) values(?,?)", "Mick",222)
    if err != nil {
        fmt.Println("exec sql error:",err)
        tx.Rollback()
    }
    err = tx.Commit()
    if err != nil {
        fmt.Println("commit error")
    }

}

連線池設定

預設情況下，連線池增長無限制，並且只要連線池中沒有可用的空閒連線，就會建立連線。我們可以使用DB.SetMaxOpenConns設定池的最大大小。未使用的連線標記為空閒，如果不需要則關閉。要避免建立和關閉大量連線，可以使用DB.SetMaxIdleConns設定最大空閒連線。

    DB.SetMaxIdleConns(n int)    設定最大空閒連線數
    DB.SetMaxOpenConns(n int)  設定最大開啟的連線數

示例：

package main

import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
)

var Db *sqlx.DB

func init()  {
    db, err := sqlx.Open("mysql", "user:[email protected](localhost:3306)/dbname?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
    Db.SetMaxOpenConns(30)
    Db.SetMaxIdleConns(15)
    Db.Ping()

}

如有不對歡迎指正，相互學習，共同進步。 參考連線

相關推薦

golang mysql資料庫基本操作筆記

mysql目前來說是使用最為流行的關係型資料庫，在程式設計過程中得到廣泛應用。golang操作mysql使用最多的包go-sql-driver/mysql。sqlx包是作為database/sql包的一個額外擴充套件包，在原有的database/sql加了很多擴

mysql資料庫基本操作注意點

對於一個初學資料庫的人來說，最主要的還是要掌握DQL資料庫查詢語言和DML資料操作語言。 這裡主要對DQL進行簡單的總結，實質就是學習的筆記。 資料查詢語言基本的語句結構為select * from table_name; 1. 條件語句where關建字，支援多種運算子 比較運

Mysql 資料庫基本操作（1）

1、庫的管理 1）庫的基本操作： ①檢視所有庫：show databases； ②建立庫（指定字符集）：create database 庫名 character

MySQL資料庫基本操作知識------入門第二天

第二天啦。 解決中文亂碼問題：(資料庫（伺服器）使用utf8字符集，命令列（客戶端）使用gbk字符集時，亂碼) set names gbk  一些小細節：如果想退出當前語句：（反斜槓+c) 跳出執行 一些常見的報錯： 錯誤一：   這個報錯是：主鍵重複了。 

mysql資料庫基本操作

1、資料庫（database）管理 1.1 create 建立資料庫 createdatabase firstDB; 1.2 show 檢視所有資料庫 mysql> show databases; +--------------------+ | Dat

Mysql資料庫基本操作(2)

-- 資料庫的操作 -- 連結資料庫 mysql -uroot -p mysql -uroot -pmysql -- 退出資料庫 exit/quit/ctrl+d -- sql語句最後需要有分號;結尾 -- 顯示資料庫版本

Mysql資料庫基本操作(3)

-- 資料的準備 -- 建立一個數據庫 create database python_test charset=utf8; -- 使用一個數據庫 use python_test; -- 顯示使用的當前資料是哪個? select database();

MYSQL資料庫基本操作和命令詳解

在學習MySQL資料庫之前我們要知道MySQL資料庫的操作語言的分類； DDL(資料定義語言) 表的定義、使用者的定義… create drop alter DML(資料操控語言) 對資料的增加、修改、刪除、查詢 insert update delete select

day39 mysql資料庫基本操作

什麼是資料庫 用來儲存資料的倉庫 資料庫可以在硬碟及記憶體中儲存資料 主要學習硬碟中儲存資料,因為記憶體中的資料總有一天會丟失 資料庫與檔案儲存資料區別 (公司的開發是綜合內容的) 資料庫本質也是通過檔案來儲存資料,資料庫的概念就是系統地管理儲存資料的檔案 對於表查詢 (重中之重) 資料庫的介紹 資

MySQL資料庫基本操作（DDL）

1.mysql -hlocalhost -uroot -p123   登陸 2.show databases;   檢視資料庫資訊 3.use XXX;    使用XXX資料庫 4.show tables;   檢視資料表 5.如何通過命令更改使用者資訊 use mysql

mysql資料庫基本操作（三）

資料表操作 基礎操作 1.建立表（類似於一個excel表） create table tab_name( field1 type[完整性約束條件], field2 type, ... field

mysql資料庫基本操作（四)

表紀錄操作        同樣，表紀錄也有增刪改查的操作，但是一般我們大概70%的操作都是在查資料，所以查的操作需要單獨說清楚，先簡單看看增刪改。 表紀錄的增、刪、改      1.增加一條紀錄的方式： insert ［into

mysql資料庫基本操作（五）

表紀錄之查(單表查詢)2        上一篇講了4類查詢的方式，現在接著上一篇繼續看還有哪些方式。 group by 分組查詢       顧名思義，分組查詢要分組，因為mysql5.7之後預設不支援group by語句，需要改配置

mysql資料庫基本操作（六）

  外來鍵約束 建立外來鍵        前面講的表單查詢都是一張表，但專案中表與表之間是有關聯的，比如我們建立的學生表，他們可能在不同班級，不同班級有不同的班主任，他們之間的關係大概是這樣的：每一個班主任會對應多個學生 , 而每個學生只能對應一個班主任。所以

02、MySQL—資料庫基本操作

資料庫是資料儲存的最外層（最大單元） 1、建立資料庫 基本語法：create database 資料庫名字 [庫選項]; 範例：使用create database 建立資料庫   庫選項：資料庫的相關屬性 字符集：charset 字符集，代表著當前資料庫下的所有表儲存的資料預設指定的字

學習筆記mysql常用基本操作

MySQL學習筆記給MySQL數據庫root賬號設定密碼[root@xiaomao2 ~]# mysqladmin -u root password ‘123456‘ 連接數據庫：可以使用命令:mysql –u root –p連接數據庫，但只是連接本地庫，很多時間需要連接網絡中的某臺主機的數據庫：備註：-u

Oracle操作筆記——資料庫基本操作及SQL命令

文章目錄 單表查詢 查詢結果拼接用|| 條件判斷用CASE WHEN 限制返回的行數用rownum 隨機返回用dbms_random.value() 模糊查詢用% _ \ 對結果排序用ORD

PostgreSQL學習筆記（二）：資料庫基本操作

文章目錄 1. 資料庫基本操作 1.1 登入控制檯 1.1.1 登入控制檯 1.1.2 退出控制檯 1.2 建立/刪除使用者 1.2.1 建立使用者

<資料庫>MySQL的基本操作

1.使用者管理 建立使用者: create user '使用者名稱'@'IP地址' identified by '密碼';(IP地址:%代表所有) 使用者登入: mysql -u 使用者名稱 -p(enter之後輸入

Django學習筆記（二）----簽到設計邏輯及資料庫基本操作API

1.釋出會簽到系統設計原理 簽到系統設計原理： 簽到功能頁面屬於某一場獨立釋出會。在釋出列表中，每一條釋出會都含有一個“簽到”連結，用來開啟對應簽到頁面。 簽到連結根據釋出會id來確認:/sig