golang を mysql データベースに接続する方法

golang 操作 mysql

インストール

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

データベース接続

var Db *sqlx.DB
db, err := sqlx.Open("mysql","username:password@tcp(ip:port)/database?charset=utf8")
Db = db

接続 2

package main
import (
	"database/sql"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
)
var db *sql.DB  //全局对象db

func initDB() (err error) {
  db, err = sql.Open("mysql","root:admin123@tcp(127.0.0.1:3306)/dududu?charset=utf8")
  if err!=nil{
    return err
  }
  err = db.Ping()  //校验数据库连接
  if err!=nil{
    return err
  }
  return nil
}

type beautiful struct {
	spu_id string
	title string
	price string
}

func queryRowDemo()  {
	sqlStr :="select spu_id,title,price from dududu_shops where id = ?"
	var u beautiful
	err:=db.QueryRow(sqlStr,101).Scan(&u.spu_id,&u.title,&u.price)
	if err!=nil{
		fmt.Println("2",err)
	}
	fmt.Println(u)
}


func main()  {
	err:=initDB()
	if err!=nil{
		fmt.Println("1",err)
		return
	}
	queryRowDemo()
}

ハンドル タイプ

SQLX の設計とデータベース/SQL の使用方法は同じです。 4 つの主要なハンドル タイプが含まれます。

• sqlx.DB - sql.DB と同様、データベースを表します。

• sqlx.Tx - sql.Tx と同様に、物事を表します。

• sqlx.Stmt - sql.Stmt と同様に、準備されたステートメントを表します。

• sqlx.NamedStmt - 準備されたステートメントを表します (名前付きパラメーターをサポート)

すべてのハンドラー タイプはデータベース/SQL との互換性を提供します。これは、次の場合を意味します。 sqlx.DB.Query を呼び出すと、それを sql.DB.Query に直接置き換えることができるため、sqlx を既存のデータベース プロジェクトに簡単に追加できます。

さらに、sqlx には 2 つのカーソル タイプがあります。

• sqlx.Rows - sql.Rows と同様に、Queryx は戻ります。

• sqlx.Row - sql.Row と同様に、QueryRowx は返します。

データベース/SQL メソッドと比較すると、新しい構文があり、取得したデータを構造体に直接変換できます。

• #Get(宛先インターフェイス{}, …) エラー

• Select(宛先インターフェイス{}, …) エラー

テーブルの作成

#以下のすべての例では、操作の基礎として次のテーブル構造を使用します。

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 は接続プールから接続を取り出し、対応するクエリ操作を実行します。アドホック クエリの実行をサポートしていないドライバーの場合、準備されたステートメントは操作の実行の背後で作成されます。この接続は、結果が返される前に接続プールに返されます。

データベースの種類が異なれば、使用するプレースホルダーも異なることに注意してください。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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?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 (?, ?, ?,?)","wd","123","it","wd@163.com")
    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 = ?","jack",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 プリペアド ステートメント

ほとんどのデータベースでは、クエリが実行されるときに、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

行の結果は、database/ の Rows を使用して取得されます。 SQLで取得します。クエリは sql.Rows オブジェクトとエラー オブジェクトを返します。

これを使用する場合、行は一連の結果ではなくカーソルとして扱われる必要があります。データベース ドライバーのキャッシュ方法は異なりますが、Next() の繰り返しを通じて毎回 1 列の結果が取得されるため、クエリ結果が非常に大きい場合にメモリ使用量を効果的に制限できます。Scan() は SQL の各列をマップするためにリフレクトを使用します。文字列、[]byte などの言語データ型。すべての行の結果を反復処理しない場合は、接続を接続プールに返す前に必ず rows.Close() を呼び出してください。

Query によって返されるエラーは、サーバーがクエリを準備しているときに発生することも、クエリ ステートメントの実行時に発生することもあります。たとえば、データベースが使用可能な接続の検索または作成を 10 回試行したとしても、接続プールから不正な接続が取得される可能性があります。通常、エラーは主に SQL ステートメントのエラー、同様の一致エラー、ドメイン名またはテーブル名のエラーから発生します。

ほとんどの場合、Rows.Scan() は、ドライバーがキャッシュをどのように使用するかに関係なく、ドライバーから取得したデータのコピーを作成します。特殊な型 sql.RawBytes を使用すると、ドライバーから返されたデータからゼロコピー スライス バイトを取得できます。次回 Next が呼び出されるとき、値が指すメモリはドライバーによって他のデータで上書きされているため、値は無効になります。

Query で使用される接続は、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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?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)
    }
    
}
//wd 123 wd@163.com
//jack 1222 jack@165.com

Queryxx

Queryx は Query とよく似た動作をしますが、sqlx.Rows オブジェクトを返し、拡張スキャン動作をサポートし、データを構造化できます。 。

例:

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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?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： wd 123
//stuct data： jack 1222

QueryRow と QueryRowx

QueryRow と QueryRowx は両方ともデータベースからデータを取得しますが、QueryRowx は結果を直接変換できるスキャン拡張機能を提供します。構造。

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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?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:[wd:123:wd@163.com]
//this is QueryRowx res:{jack 1222  jack@165.com}

Get and Select (非常に一般的に使用されます)

Get and Select は、結果を構造体に直接割り当てることができ、変換のために StructScan を内部的にカプセル化することができる、非常に時間を節約する拡張機能です。 Get メソッドを使用して 1 つの結果を取得し、次に 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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?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:[{wd 123  wd@163.com} {jack 1222  jack@165.com}]
//this is GET res:{jack 1222  jack@165.com}

トランザクション

トランザクション操作は 3 つのメソッドによって実装されます:

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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?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方法来设定最大的空闲连接数。

注意：该设置方法golang版本至少为1.2

• DB.SetMaxIdleConns(n int) 设置最大空闲连接数

• DB.SetMaxOpenConns(n int) 设置最大打开的连接数

• DB.SetConnMaxIdleTime(time.Second*10) 间隔时间

示例：

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", "stu:1234qwer@tcp(10.0.0.241:3307)/test?charset=utf8")
    if err != nil {
        fmt.Println("open mysql failed,", err)
        return
    }
    Db = db
    Db.SetMaxOpenConns(30)
    Db.SetMaxIdleConns(15)

}

案例使用

var Db *sqlx.DB
db, err := sqlx.Open("mysql","root:admin123@tcp(127.0.0.1:3306)/dududu?charset=utf8")
Db = db

rows, err := Db.Query("SELECT spu_id,title,price FROM dududu_shops")

if err != nil{
  fmt.Println("query failed,error： ", err)
  return
}
for rows.Next() {  //循环结果
  var spu_id,title,price string
  err = rows.Scan(&spu_id, &title, &price)
  println(spu_id,title,price)
}

以上がgolang を mysql データベースに接続する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。