biuaxia

go get -u github.com/go-sql-driver/mysql  

func Open(driverName, dataSourceName string) (*DB, error)  

import (  
	"database/sql"  

	_ "github.com/go-sql-driver/mysql"  
)  

func main() {  
   // DSN:データソース名  
	dsn := "user:password@tcp(127.0.0.1:3306)/dbname"  
	db, err := sql.Open("mysql", dsn)  
	if err != nil {  
		panic(err)  
	}  
	defer db.Close()  // この行は上のerrチェックの下に書く必要があります  
}  

// グローバルオブジェクトdbを定義  
var db *sql.DB  

// データベースを初期化する関数を定義  
func initDB() (err error) {  
	// DSN:データソース名  
	dsn := "user:password@tcp(127.0.0.1:3306)/sql_test?charset=utf8mb4&parseTime=True"  
	// アカウントとパスワードの正しさは確認しません  
	// 注意！！！ここで:=を使用しないでください。グローバル変数に値を割り当て、main関数でグローバル変数dbを使用します  
	db, err = sql.Open("mysql", dsn)  
	if err != nil {  
		return err  
	}  
	// データベースとの接続を試みる（dsnが正しいか確認）  
	err = db.Ping()  
	if err != nil {  
		return err  
	}  
	return nil  
}  

func main() {  
	err := initDB() // データベース初期化関数を呼び出す  
	if err != nil {  
		fmt.Printf("データベースの初期化に失敗しました, err:%v\n", err)  
		return  
	}  
}  

func (db *DB) SetMaxOpenConns(n int)  

func (db *DB) SetMaxIdleConns(n int)  

CREATE DATABASE sql_test;  

use sql_test;  

CREATE TABLE `user` (  
    `id` BIGINT(20) NOT NULL AUTO_INCREMENT,  
    `name` VARCHAR(20) DEFAULT '',  
    `age` INT(11) DEFAULT '0',  
    PRIMARY KEY(`id`)  
)ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4;  

type user struct {  
	id   int  
	age  int  
	name string  
}  

func (db *DB) QueryRow(query string, args ...interface{}) *Row  

// 単一データのクエリ例  
func queryRowDemo() {  
	sqlStr := "select id, name, age from user where id=?"  
	var u user  
	// 非常に重要：QueryRowの後にScanメソッドを呼び出すことを確認してください。そうしないと、保持しているデータベース接続が解放されません  
	err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name, &u.age)  
	if err != nil {  
		fmt.Printf("スキャンに失敗しました, err:%v\n", err)  
		return  
	}  
	fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)  
}  

func (db *DB) Query(query string, args ...interface{}) (*Rows, error)  

// 複数データのクエリ例  
func queryMultiRowDemo() {  
	sqlStr := "select id, name, age from user where id > ?"  
	rows, err := db.Query(sqlStr, 0)  
	if err != nil {  
		fmt.Printf("クエリに失敗しました, err:%v\n", err)  
		return  
	}  
	// 非常に重要：rowsを閉じて保持しているデータベース接続を解放します  
	defer rows.Close()  

	// 結果セット内のデータをループして読み取ります  
	for rows.Next() {  
		var u user  
		err := rows.Scan(&u.id, &u.name, &u.age)  
		if err != nil {  
			fmt.Printf("スキャンに失敗しました, err:%v\n", err)  
			return  
		}  
		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)  
	}  
}  

func (db *DB) Exec(query string, args ...interface{}) (Result, error)  

// データの挿入  
func insertRowDemo() {  
	sqlStr := "insert into user(name, age) values (?,?)"  
	ret, err := db.Exec(sqlStr, "王五", 38)  
	if err != nil {  
		fmt.Printf("挿入に失敗しました, err:%v\n", err)  
		return  
	}  
	theID, err := ret.LastInsertId() // 新しく挿入されたデータのid  
	if err != nil {  
		fmt.Printf("最後の挿入IDの取得に失敗しました, err:%v\n", err)  
		return  
	}  
	fmt.Printf("挿入成功, idは%dです。\n", theID)  
}  

// データの更新  
func updateRowDemo() {  
	sqlStr := "update user set age=? where id = ?"  
	ret, err := db.Exec(sqlStr, 39, 3)  
	if err != nil {  
		fmt.Printf("更新に失敗しました, err:%v\n", err)  
		return  
	}  
	n, err := ret.RowsAffected() // 操作に影響を与えた行数  
	if err != nil {  
		fmt.Printf("RowsAffectedの取得に失敗しました, err:%v\n", err)  
		return  
	}  
	fmt.Printf("更新成功, 影響を受けた行数:%d\n", n)  
}  

// データの削除  
func deleteRowDemo() {  
	sqlStr := "delete from user where id = ?"  
	ret, err := db.Exec(sqlStr, 3)  
	if err != nil {  
		fmt.Printf("削除に失敗しました, err:%v\n", err)  
		return  
	}  
	n, err := ret.RowsAffected() // 操作に影響を与えた行数  
	if err != nil {  
		fmt.Printf("RowsAffectedの取得に失敗しました, err:%v\n", err)  
		return  
	}  
	fmt.Printf("削除成功, 影響を受けた行数:%d\n", n)  
}  

func (db *DB) Prepare(query string) (*Stmt, error)  

// プリペアドクエリの例  
func prepareQueryDemo() {  
	sqlStr := "select id, name, age from user where id > ?"  
	stmt, err := db.Prepare(sqlStr)  
	if err != nil {  
		fmt.Printf("準備に失敗しました, err:%v\n", err)  
		return  
	}  
	defer stmt.Close()  
	rows, err := stmt.Query(0)  
	if err != nil {  
		fmt.Printf("クエリに失敗しました, err:%v\n", err)  
		return  
	}  
	defer rows.Close()  
	// 結果セット内のデータをループして読み取ります  
	for rows.Next() {  
		var u user  
		err := rows.Scan(&u.id, &u.name, &u.age)  
		if err != nil {  
			fmt.Printf("スキャンに失敗しました, err:%v\n", err)  
			return  
		}  
		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)  
	}  
}  

// プリペアド挿入の例  
func prepareInsertDemo() {  
	sqlStr := "insert into user(name, age) values (?,?)"  
	stmt, err := db.Prepare(sqlStr)  
	if err != nil {  
		fmt.Printf("準備に失敗しました, err:%v\n", err)  
		return  
	}  
	defer stmt.Close()  
	_, err = stmt.Exec("小王子", 18)  
	if err != nil {  
		fmt.Printf("挿入に失敗しました, err:%v\n", err)  
		return  
	}  
	_, err = stmt.Exec("沙河娜扎", 18)  
	if err != nil {  
		fmt.Printf("挿入に失敗しました, err:%v\n", err)  
		return  
	}  
	fmt.Println("挿入成功です。")  
}  

// SQLインジェクションの例  
func sqlInjectDemo(name string) {  
	sqlStr := fmt.Sprintf("select id, name, age from user where name='%s'", name)  
	fmt.Printf("SQL:%s\n", sqlStr)  
	var u user  
	err := db.QueryRow(sqlStr).Scan(&u.id, &u.name, &u.age)  
	if err != nil {  
		fmt.Printf("実行に失敗しました, err:%v\n", err)  
		return  
	}  
	fmt.Printf("user:%#v\n", u)  
}  

sqlInjectDemo("xxx' or 1=1#")  
sqlInjectDemo("xxx' union select * from user #")  
sqlInjectDemo("xxx' and (select count(*) from user) <10 #")  

func (db *DB) Begin() (*Tx, error)  

func (tx *Tx) Commit() error  

func (tx *Tx) Rollback() error  

// トランザクション操作の例  
func transactionDemo() {  
	tx, err := db.Begin() // トランザクションを開始  
	if err != nil {  
		if tx != nil {  
			tx.Rollback() // ロールバック  
		}  
		fmt.Printf("トランザクション開始に失敗しました, err:%v\n", err)  
		return  
	}  
	sqlStr1 := "Update user set age=30 where id=?"  
	ret1, err := tx.Exec(sqlStr1, 2)  
	if err != nil {  
		tx.Rollback() // ロールバック  
		fmt.Printf("sql1の実行に失敗しました, err:%v\n", err)  
		return  
	}  
	affRow1, err := ret1.RowsAffected()  
	if err != nil {  
		tx.Rollback() // ロールバック  
		fmt.Printf("ret1.RowsAffected()の実行に失敗しました, err:%v\n", err)  
		return  
	}  

	sqlStr2 := "Update user set age=40 where id=?"  
	ret2, err := tx.Exec(sqlStr2, 3)  
	if err != nil {  
		tx.Rollback() // ロールバック  
		fmt.Printf("sql2の実行に失敗しました, err:%v\n", err)  
		return  
	}  
	affRow2, err := ret2.RowsAffected()  
	if err != nil {  
		tx.Rollback() // ロールバック  
		fmt.Printf("ret1.RowsAffected()の実行に失敗しました, err:%v\n", err)  
		return  
	}  

	fmt.Println(affRow1, affRow2)  
	if affRow1 == 1 && affRow2 == 1 {  
		fmt.Println("トランザクションをコミットします...")  
		tx.Commit() // トランザクションをコミット  
	} else {  
		tx.Rollback()  
		fmt.Println("トランザクションをロールバックします...")  
	}  

	fmt.Println("トランザクションの実行に成功しました！")  
}