主頁 > 後端開發 > Go 語言連接資料庫實作增刪改查

Go 語言連接資料庫實作增刪改查

2023-06-12 07:35:18 後端開發

Go 連接 MySQL實作增刪改查

一、初始化連接

創建專案

配置 Environment

https://goproxy.cn,direct

MySQL 資料庫驅動

MySQL驅動https://github.com/go-sql-driver/mysql

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

main.go 檔案 初始化連接

package main

import (
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

func main() {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	db, err := sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		panic(err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	defer db.Close()
	fmt.Println("connect to database") // 列印這句話并不能表示資料庫已經連上了
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go mod tidy   
go: finding module for package github.com/go-sql-driver/mysql
go: found github.com/go-sql-driver/mysql in github.com/go-sql-driver/mysql v1.7.1

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go 
connect to database

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
?

sql.Open 原始碼

// Open may just validate its arguments without creating a connection
// to the database. To verify that the data source name is valid, call
// Ping.
// Open 可能只驗證其引數，而不創建與資料庫的連接，若要驗證資料源名稱是否有效，請呼叫 Ping，
//
// The returned DB is safe for concurrent use by multiple goroutines
// and maintains its own pool of idle connections. Thus, the Open
// function should be called just once. It is rarely necessary to
// close a DB.
// 回傳的資料庫可以安全地由多個 goroutines 并發使用，并維護自己的空閑連接池，因此，Open 函式應該只呼叫一次，很少需要關閉資料庫，
func Open(driverName, dataSourceName string) (*DB, error) {
	driversMu.RLock()
	driveri, ok := drivers[driverName]
	driversMu.RUnlock()
	if !ok {
		return nil, fmt.Errorf("sql: unknown driver %q (forgotten import?)", driverName)
	}

	if driverCtx, ok := driveri.(driver.DriverContext); ok {
		connector, err := driverCtx.OpenConnector(dataSourceName)
		if err != nil {
			return nil, err
		}
		return OpenDB(connector), nil
	}

	return OpenDB(dsnConnector{dsn: dataSourceName, driver: driveri}), nil
}

初始化連接 驗證資料源名稱是否有效，呼叫 Ping

package main

import (
	"database/sql"
	"fmt"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

func main() {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	db, err := sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		panic(err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	defer db.Close()

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return
	}
	fmt.Println("connect to database success") // 
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go
connect to database success

Code/go/mysql_demo via ?? v1.20.3 via ?? base took 2.5s 
?

db.Ping() 原始碼

// PingContext verifies a connection to the database is still alive,
// establishing a connection if necessary.
// PingContext 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
func (db *DB) PingContext(ctx context.Context) error {
	var dc *driverConn
	var err error

	err = db.retry(func(strategy connReuseStrategy) error {
		dc, err = db.conn(ctx, strategy)
		return err
	})

	if err != nil {
		return err
	}

	return db.pingDC(ctx, dc, dc.releaseConn)
}

// Ping verifies a connection to the database is still alive,
// establishing a connection if necessary.
// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
//
// Ping uses context.Background internally; to specify the context, use
// PingContext.
func (db *DB) Ping() error {
	return db.PingContext(context.Background())
}

優化之后初始化連接完整代碼：

package main

import (
	"database/sql"
	"fmt"
	"time"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

var db *sql.DB

func initMySQL() (err error) {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	// 注意：要初始化全域的 db 物件，不要新宣告一個 db 變數
	db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		return err
	}

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return err
	}
	// 數值需要根據業務具體情況來確定
	db.SetConnMaxLifetime(time.Second * 10) // 設定可以重用連接的最長時間
	db.SetConnMaxIdleTime(time.Second * 5)  // 設定連接可能處于空閑狀態的最長時間
	db.SetMaxOpenConns(200)                 // 設定與資料庫的最大打開連接數
	db.SetMaxIdleConns(10)                  //  設定空閑連接池中的最大連接數
	return nil
}

func main() {
	if err := initMySQL(); err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	defer db.Close()

	fmt.Println("connect to database success")
	// db.xx() 去使用資料庫操作...
}

SetMaxIdleConns 和 SetMaxOpenConns 原始碼

// SetMaxIdleConns sets the maximum number of connections in the idle
// connection pool.
//
// If MaxOpenConns is greater than 0 but less than the new MaxIdleConns,
// then the new MaxIdleConns will be reduced to match the MaxOpenConns limit.
//
// If n <= 0, no idle connections are retained.
//
// The default max idle connections is currently 2. This may change in
// a future release.
func (db *DB) SetMaxIdleConns(n int) {
	db.mu.Lock()
	if n > 0 {
		db.maxIdleCount = n
	} else {
		// No idle connections.
		db.maxIdleCount = -1
	}
	// Make sure maxIdle doesn't exceed maxOpen
	if db.maxOpen > 0 && db.maxIdleConnsLocked() > db.maxOpen {
		db.maxIdleCount = db.maxOpen
	}
	var closing []*driverConn
	idleCount := len(db.freeConn)
	maxIdle := db.maxIdleConnsLocked()
	if idleCount > maxIdle {
		closing = db.freeConn[maxIdle:]
		db.freeConn = db.freeConn[:maxIdle]
	}
	db.maxIdleClosed += int64(len(closing))
	db.mu.Unlock()
	for _, c := range closing {
		c.Close()
	}
}

// SetMaxOpenConns sets the maximum number of open connections to the database.
//
// If MaxIdleConns is greater than 0 and the new MaxOpenConns is less than
// MaxIdleConns, then MaxIdleConns will be reduced to match the new
// MaxOpenConns limit.
//
// If n <= 0, then there is no limit on the number of open connections.
// The default is 0 (unlimited).
func (db *DB) SetMaxOpenConns(n int) {
	db.mu.Lock()
	db.maxOpen = n
	if n < 0 {
		db.maxOpen = 0
	}
	syncMaxIdle := db.maxOpen > 0 && db.maxIdleConnsLocked() > db.maxOpen
	db.mu.Unlock()
	if syncMaxIdle {
		db.SetMaxIdleConns(n)
	}
}

Database 與 MySQL 注冊驅動

二、Database SQL CRUD 增刪改查

創建資料庫后建表并插入資料

~ via ?? base
? mysql -uroot -p
Enter password:
Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 451
Server version: 8.0.32 Homebrew

Copyright (c) 2000, 2023, Oracle and/or its affiliates.

Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| mysql_test         |
| performance_schema |
| sql_test           |
| sys                |
+--------------------+
11 rows in set (0.02 sec)

mysql> use sql_test;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A

Database changed
mysql> show tables;
+--------------------+
| Tables_in_sql_test |
+--------------------+
| user               |
+--------------------+
1 row in set (0.00 sec)

mysql> desc user;
+-------+-------------+------+-----+---------+----------------+
| Field | Type        | Null | Key | Default | Extra          |
+-------+-------------+------+-----+---------+----------------+
| id    | bigint      | NO   | PRI | NULL    | auto_increment |
| name  | varchar(20) | YES  |     |         |                |
| age   | int         | YES  |     | 0       |                |
+-------+-------------+------+-----+---------+----------------+
3 rows in set (0.00 sec)

mysql> show create table user \G;
*************************** 1. row ***************************
       Table: user
Create Table: CREATE TABLE `user` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `name` varchar(20) DEFAULT '',
  `age` int DEFAULT '0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci
1 row in set (0.00 sec)

ERROR:
No query specified

mysql> select * from user;
+----+--------+------+
| id | name   | age  |
+----+--------+------+
|  1 | 小喬   |   16 |
|  2 | 小喬   |   12 |
+----+--------+------+
2 rows in set (0.00 sec)

mysql>

單行查詢

package main

import (
	"database/sql"
	"fmt"
	"time"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

var db *sql.DB

func initMySQL() (err error) {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	// 注意：要初始化全域的 db 物件，不要新宣告一個 db 變數
	db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		return err
	}

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return err
	}
	// 數值需要根據業務具體情況來確定
	db.SetConnMaxLifetime(time.Second * 10) // 設定可以重用連接的最長時間
	db.SetConnMaxIdleTime(time.Second * 5)  // 設定連接可能處于空閑狀態的最長時間
	db.SetMaxOpenConns(200)                 // 設定與資料庫的最大打開連接數
	db.SetMaxIdleConns(10)                  //  設定空閑連接池中的最大連接數
	return nil
}

type user struct {
	id   int
	age  int
	name string
}

// 查詢單條資料
func queryRowDemo(id int) (user, error) {
	sqlStr := "SELECT id, name, age FROM user WHERE id = ?"
	var u user
	// QueryRow 執行預期最多回傳一行的查詢，
	// QueryRow 始侄訓傳一個非 nil 值，錯誤將延遲到呼叫 row 的 Scan 方法，
	// Scan 將匹配行中的列復制到 dest 指向的值中
	// 如果多行與查詢匹配，Scan 將使用第一行并丟棄其余行，
	// 如果沒有與查詢匹配的行，Scan 將回傳 ErrNoRows，
  // QueryRow 之后要呼叫 Scan 方法，否則資料庫連接不會被釋放
	// Scan 原始碼：defer r.rows.Close() 
	err := db.QueryRow(sqlStr, id).Scan(&u.id, &u.name, &u.age)
	if err != nil {
		fmt.Printf("scan failed, err: %v\n", err)
		return u, err
	}
	return u, nil

}

func main() {
	if err := initMySQL(); err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	defer db.Close()

	fmt.Println("connect to database success")
	// db.xx() 去使用資料庫操作...
	u, err := queryRowDemo(1)
	if err != nil {
		fmt.Printf("query row failed, err: %v", err)
	}
	fmt.Printf("id: %d name: %s age: %d\n", u.id, u.name, u.age)
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go
connect to database success
id: 1 name: 小喬 age: 16

多行查詢

package main

import (
	"database/sql"
	"fmt"
	"time"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

var db *sql.DB

func initMySQL() (err error) {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	// 注意：要初始化全域的 db 物件，不要新宣告一個 db 變數
	db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		return err
	}

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return err
	}
	// 數值需要根據業務具體情況來確定
	db.SetConnMaxLifetime(time.Second * 10) // 設定可以重用連接的最長時間
	db.SetConnMaxIdleTime(time.Second * 5)  // 設定連接可能處于空閑狀態的最長時間
	db.SetMaxOpenConns(200)                 // 設定與資料庫的最大打開連接數
	db.SetMaxIdleConns(10)                  //  設定空閑連接池中的最大連接數
	return nil
}

type user struct {
	id   int
	age  int
	name string
}

// 查詢單條資料
func queryRowDemo(id int) (user, error) {
	sqlStr := "SELECT id, name, age FROM user WHERE id = ?"
	var u user
	// QueryRow 執行預期最多回傳一行的查詢，
	// QueryRow 始侄訓傳一個非 nil 值，錯誤將延遲到呼叫 row 的 Scan 方法，
	// Scan 將匹配行中的列復制到 dest 指向的值中
	// 如果多行與查詢匹配，Scan 將使用第一行并丟棄其余行，
	// 如果沒有與查詢匹配的行，Scan 將回傳 ErrNoRows，
	// QueryRow 之后要呼叫 Scan 方法，否則資料庫連接不會被釋放
	// Scan 原始碼：defer r.rows.Close()
	err := db.QueryRow(sqlStr, id).Scan(&u.id, &u.name, &u.age)
	if err != nil {
		fmt.Printf("scan failed, err: %v\n", err)
		return u, err
	}
	return u, nil

}

// 查詢多條資料
func queryMultiRowDemo(id int) {
	sqlStr := "SELECT id, name, age FROM user WHERE id > ?"
	rows, err := db.Query(sqlStr, id)
	if err != nil {
		fmt.Printf("query failed, err: %v\n", err)
		return
	}
	// 關閉 rows 釋放持有的資料庫鏈接
	// Close 關閉行，防止進一步列舉，
	// 如果呼叫 Next 并回傳 false 并且沒有其他結果集，
	// 則行將自動關閉，檢查 Err. 的結果就足夠了， 關閉是冪等的，不會影響 Err 的結果，
	// 因為不能保證 for rows.Next() 一定可以執行完，有可能會 panic 或其他情況，
	// 故需要在此 defer 關閉連接
	defer rows.Close()

	// 回圈讀取結果集中的資料
	// Next 準備下一個結果行，以便使用 Scan 方法讀取，
	// 成功時回傳 true，如果沒有下一個結果行或在準備時發生錯誤，則回傳 false，
	for rows.Next() {
		var u user
		err := rows.Scan(&u.id, &u.name, &u.age)
		if err != nil {
			fmt.Printf("scan failed, err:%v\n", err)
			return
		}
		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
	}
}

func main() {
	if err := initMySQL(); err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	// Close 將關閉資料庫并阻止啟動新查詢，關閉，然后等待服務器上已開始處理的所有查詢完成，
	defer db.Close()

	fmt.Println("connect to database success")
	// db.xx() 去使用資料庫操作...
	// 查詢單行資料
	//u, err := queryRowDemo(1)
	//if err != nil {
	//	fmt.Printf("query row failed, err: %v", err)
	//}
	//fmt.Printf("id: %d name: %s age: %d\n", u.id, u.name, u.age)
	// 查詢多行資料
	queryMultiRowDemo(0)
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go
connect to database success
id:1 name:小喬 age:16
id:2 name:小喬 age:12

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
?

插入資料

package main

import (
	"database/sql"
	"fmt"
	"time"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

var db *sql.DB

func initMySQL() (err error) {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	// 注意：要初始化全域的 db 物件，不要新宣告一個 db 變數
	db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		return err
	}

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return err
	}
	// 數值需要根據業務具體情況來確定
	db.SetConnMaxLifetime(time.Second * 10) // 設定可以重用連接的最長時間
	db.SetConnMaxIdleTime(time.Second * 5)  // 設定連接可能處于空閑狀態的最長時間
	db.SetMaxOpenConns(200)                 // 設定與資料庫的最大打開連接數
	db.SetMaxIdleConns(10)                  //  設定空閑連接池中的最大連接數
	return nil
}

type user struct {
	id   int
	age  int
	name string
}

// 查詢單條資料
func queryRowDemo(id int) (user, error) {
	sqlStr := "SELECT id, name, age FROM user WHERE id = ?"
	var u user
	// QueryRow 執行預期最多回傳一行的查詢，
	// QueryRow 始侄訓傳一個非 nil 值，錯誤將延遲到呼叫 row 的 Scan 方法，
	// Scan 將匹配行中的列復制到 dest 指向的值中
	// 如果多行與查詢匹配，Scan 將使用第一行并丟棄其余行，
	// 如果沒有與查詢匹配的行，Scan 將回傳 ErrNoRows，
	// QueryRow 之后要呼叫 Scan 方法，否則資料庫連接不會被釋放
	// Scan 原始碼：defer r.rows.Close()
	err := db.QueryRow(sqlStr, id).Scan(&u.id, &u.name, &u.age)
	if err != nil {
		fmt.Printf("scan failed, err: %v\n", err)
		return u, err
	}
	return u, nil

}

// 查詢多條資料
func queryMultiRowDemo(id int) {
	sqlStr := "SELECT id, name, age FROM user WHERE id > ?"
	rows, err := db.Query(sqlStr, id)
	if err != nil {
		fmt.Printf("query failed, err: %v\n", err)
		return
	}
	// 關閉 rows 釋放持有的資料庫鏈接
	// Close 關閉行，防止進一步列舉，
	// 如果呼叫 Next 并回傳 false 并且沒有其他結果集，
	// 則行將自動關閉，檢查 Err. 的結果就足夠了， 關閉是冪等的，不會影響 Err 的結果，
	// 因為不能保證 for rows.Next() 一定可以執行完，有可能會 panic 或其他情況，
	// 故需要在此 defer 關閉連接
	defer rows.Close()

	// 回圈讀取結果集中的資料
	// Next 準備下一個結果行，以便使用 Scan 方法讀取，
	// 成功時回傳 true，如果沒有下一個結果行或在準備時發生錯誤，則回傳 false，
	for rows.Next() {
		var u user
		err := rows.Scan(&u.id, &u.name, &u.age)
		if err != nil {
			fmt.Printf("scan failed, err:%v\n", err)
			return
		}
		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
	}
}

// 插入資料
func insertRowDemo(name string, age int) (int64, error) {
	sqlStr := "INSERT INTO user (name, age) VALUES (?,?)"
	result, err := db.Exec(sqlStr, name, age)
	if err != nil {
		fmt.Printf("insert failed, err: %v\n", err)
		return 0, err
	}
	// LastInsertId 回傳資料庫為回應命令而生成的整數，
	// 通常，這將來自插入新行時的“自動增量”列，
	// 并非所有資料庫都支持此功能，并且此類陳述句的語法各不相同，
	var newID int64
	newID, err = result.LastInsertId() // 新插入資料的id
	if err != nil {
		fmt.Printf("get lastinsert ID failed, err: %v\n", err)
		return 0, err
	}
	return newID, nil
}

func main() {
	if err := initMySQL(); err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	// Close 將關閉資料庫并阻止啟動新查詢，關閉，然后等待服務器上已開始處理的所有查詢完成，
	defer db.Close()

	fmt.Println("connect to database success")
	// db.xx() 去使用資料庫操作...
	// 查詢單行資料
	//u, err := queryRowDemo(1)
	//if err != nil {
	//	fmt.Printf("query row failed, err: %v", err)
	//}
	//fmt.Printf("id: %d name: %s age: %d\n", u.id, u.name, u.age)
	// 查詢多行資料
	//queryMultiRowDemo(0)
	// 插入資料
	newID, err := insertRowDemo("小跟班", 12)
	if err != nil {
		fmt.Printf("insert row failed, err: %v", err)
	}
	fmt.Printf("insert success, the id is %d.\n", newID)
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go
connect to database success
insert success, the id is 4.

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
?

SQL 查詢 插入結果

mysql> select * from user;
+----+-----------+------+
| id | name      | age  |
+----+-----------+------+
|  1 | 小喬      |   16 |
|  2 | 小喬      |   12 |
|  4 | 小跟班    |   12 |
+----+-----------+------+
3 rows in set (0.00 sec)

mysql>

更新資料

package main

import (
	"database/sql"
	"fmt"
	"time"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

var db *sql.DB

func initMySQL() (err error) {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	// 注意：要初始化全域的 db 物件，不要新宣告一個 db 變數
	db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		return err
	}

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return err
	}
	// 數值需要根據業務具體情況來確定
	db.SetConnMaxLifetime(time.Second * 10) // 設定可以重用連接的最長時間
	db.SetConnMaxIdleTime(time.Second * 5)  // 設定連接可能處于空閑狀態的最長時間
	db.SetMaxOpenConns(200)                 // 設定與資料庫的最大打開連接數
	db.SetMaxIdleConns(10)                  //  設定空閑連接池中的最大連接數
	return nil
}

type user struct {
	id   int
	age  int
	name string
}

// 查詢單條資料
func queryRowDemo(id int) (user, error) {
	sqlStr := "SELECT id, name, age FROM user WHERE id = ?"
	var u user
	// QueryRow 執行預期最多回傳一行的查詢，
	// QueryRow 始侄訓傳一個非 nil 值，錯誤將延遲到呼叫 row 的 Scan 方法，
	// Scan 將匹配行中的列復制到 dest 指向的值中
	// 如果多行與查詢匹配，Scan 將使用第一行并丟棄其余行，
	// 如果沒有與查詢匹配的行，Scan 將回傳 ErrNoRows，
	// QueryRow 之后要呼叫 Scan 方法，否則資料庫連接不會被釋放
	// Scan 原始碼：defer r.rows.Close()
	err := db.QueryRow(sqlStr, id).Scan(&u.id, &u.name, &u.age)
	if err != nil {
		fmt.Printf("scan failed, err: %v\n", err)
		return u, err
	}
	return u, nil

}

// 查詢多條資料
func queryMultiRowDemo(id int) {
	sqlStr := "SELECT id, name, age FROM user WHERE id > ?"
	rows, err := db.Query(sqlStr, id)
	if err != nil {
		fmt.Printf("query failed, err: %v\n", err)
		return
	}
	// 關閉 rows 釋放持有的資料庫鏈接
	// Close 關閉行，防止進一步列舉，
	// 如果呼叫 Next 并回傳 false 并且沒有其他結果集，
	// 則行將自動關閉，檢查 Err. 的結果就足夠了， 關閉是冪等的，不會影響 Err 的結果，
	// 因為不能保證 for rows.Next() 一定可以執行完，有可能會 panic 或其他情況，
	// 故需要在此 defer 關閉連接
	defer rows.Close()

	// 回圈讀取結果集中的資料
	// Next 準備下一個結果行，以便使用 Scan 方法讀取，
	// 成功時回傳 true，如果沒有下一個結果行或在準備時發生錯誤，則回傳 false，
	for rows.Next() {
		var u user
		err := rows.Scan(&u.id, &u.name, &u.age)
		if err != nil {
			fmt.Printf("scan failed, err:%v\n", err)
			return
		}
		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
	}
}

// 插入資料
func insertRowDemo(name string, age int) (int64, error) {
	sqlStr := "INSERT INTO user (name, age) VALUES (?,?)"
	result, err := db.Exec(sqlStr, name, age)
	if err != nil {
		fmt.Printf("insert failed, err: %v\n", err)
		return 0, err
	}
	// LastInsertId 回傳資料庫為回應命令而生成的整數，
	// 通常，這將來自插入新行時的“自動增量”列，
	// 并非所有資料庫都支持此功能，并且此類陳述句的語法各不相同，
	var newID int64
	newID, err = result.LastInsertId() // 新插入資料的id
	if err != nil {
		fmt.Printf("get lastinsert ID failed, err: %v\n", err)
		return 0, err
	}
	return newID, nil
}

// 更新資料
func updateRowDemo(age, id int) (int64, error) {
	sqlStr := "UPDATE user SET age=? WHERE id = ?"
	ret, err := db.Exec(sqlStr, age, id)
	if err != nil {
		fmt.Printf("update failed, err: %v\n", err)
		return 0, err
	}
	// 回傳受更新、插入或洗掉影響的行數，并非每個資料庫或資料庫驅動程式都支持此功能，
	var n int64
	n, err = ret.RowsAffected() // 操作影響的行數
	if err != nil {
		fmt.Printf("get RowsAffected failed, err: %v\n", err)
		return 0, err
	}
	return n, nil
}

func main() {
	if err := initMySQL(); err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	// Close 將關閉資料庫并阻止啟動新查詢，關閉，然后等待服務器上已開始處理的所有查詢完成，
	defer db.Close()

	fmt.Println("connect to database success")
	// db.xx() 去使用資料庫操作...
	// 查詢單行資料
	//u, err := queryRowDemo(1)
	//if err != nil {
	//	fmt.Printf("query row failed, err: %v", err)
	//}
	//fmt.Printf("id: %d name: %s age: %d\n", u.id, u.name, u.age)
	// 查詢多行資料
	//queryMultiRowDemo(0)
	// 插入資料
	//newID, err := insertRowDemo("小跟班", 12)
	//if err != nil {
	//	fmt.Printf("insert row failed, err: %v", err)
	//}
	//fmt.Printf("insert success, the id is %d.\n", newID)
	// 更新資料
	n, err := updateRowDemo(88, 4)
	if err != nil {
		fmt.Printf("update row failed with err: %v", err)
	}
	fmt.Printf("update success, affected rows:%d\n", n)
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go
connect to database success
update success, affected rows:1

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
?

SQL 查詢更新結果

mysql> select * from user;
+----+-----------+------+
| id | name      | age  |
+----+-----------+------+
|  1 | 小喬      |   16 |
|  2 | 小喬      |   12 |
|  4 | 小跟班    |   88 |
+----+-----------+------+
3 rows in set (0.00 sec)

mysql>

洗掉資料

package main

import (
	"database/sql"
	"fmt"
	"time"

	_ "github.com/go-sql-driver/mysql" // 匿名匯入 自動執行 init()
)

var db *sql.DB

func initMySQL() (err error) {
	//DSN (Data Source Name)
	dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
	// 注意：要初始化全域的 db 物件，不要新宣告一個 db 變數
	db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接資料庫
	if err != nil {
		return err
	}

	// Ping 驗證與資料庫的連接是否仍處于活動狀態，并在必要時建立連接，
	err = db.Ping()
	if err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
		return err
	}
	// 數值需要根據業務具體情況來確定
	db.SetConnMaxLifetime(time.Second * 10) // 設定可以重用連接的最長時間
	db.SetConnMaxIdleTime(time.Second * 5)  // 設定連接可能處于空閑狀態的最長時間
	db.SetMaxOpenConns(200)                 // 設定與資料庫的最大打開連接數
	db.SetMaxIdleConns(10)                  //  設定空閑連接池中的最大連接數
	return nil
}

type user struct {
	id   int
	age  int
	name string
}

// 查詢單條資料
func queryRowDemo(id int) (user, error) {
	sqlStr := "SELECT id, name, age FROM user WHERE id = ?"
	var u user
	// QueryRow 執行預期最多回傳一行的查詢，
	// QueryRow 始侄訓傳一個非 nil 值，錯誤將延遲到呼叫 row 的 Scan 方法，
	// Scan 將匹配行中的列復制到 dest 指向的值中
	// 如果多行與查詢匹配，Scan 將使用第一行并丟棄其余行，
	// 如果沒有與查詢匹配的行，Scan 將回傳 ErrNoRows，
	// QueryRow 之后要呼叫 Scan 方法，否則資料庫連接不會被釋放
	// Scan 原始碼：defer r.rows.Close()
	err := db.QueryRow(sqlStr, id).Scan(&u.id, &u.name, &u.age)
	if err != nil {
		fmt.Printf("scan failed, err: %v\n", err)
		return u, err
	}
	return u, nil

}

// 查詢多條資料
func queryMultiRowDemo(id int) {
	sqlStr := "SELECT id, name, age FROM user WHERE id > ?"
	rows, err := db.Query(sqlStr, id)
	if err != nil {
		fmt.Printf("query failed, err: %v\n", err)
		return
	}
	// 關閉 rows 釋放持有的資料庫鏈接
	// Close 關閉行，防止進一步列舉，
	// 如果呼叫 Next 并回傳 false 并且沒有其他結果集，
	// 則行將自動關閉，檢查 Err. 的結果就足夠了， 關閉是冪等的，不會影響 Err 的結果，
	// 因為不能保證 for rows.Next() 一定可以執行完，有可能會 panic 或其他情況，
	// 故需要在此 defer 關閉連接
	defer rows.Close()

	// 回圈讀取結果集中的資料
	// Next 準備下一個結果行，以便使用 Scan 方法讀取，
	// 成功時回傳 true，如果沒有下一個結果行或在準備時發生錯誤，則回傳 false，
	for rows.Next() {
		var u user
		err := rows.Scan(&u.id, &u.name, &u.age)
		if err != nil {
			fmt.Printf("scan failed, err:%v\n", err)
			return
		}
		fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
	}
}

// 插入資料
func insertRowDemo(name string, age int) (int64, error) {
	sqlStr := "INSERT INTO user (name, age) VALUES (?,?)"
	result, err := db.Exec(sqlStr, name, age)
	if err != nil {
		fmt.Printf("insert failed, err: %v\n", err)
		return 0, err
	}
	// LastInsertId 回傳資料庫為回應命令而生成的整數，
	// 通常，這將來自插入新行時的“自動增量”列，
	// 并非所有資料庫都支持此功能，并且此類陳述句的語法各不相同，
	var newID int64
	newID, err = result.LastInsertId() // 新插入資料的id
	if err != nil {
		fmt.Printf("get lastinsert ID failed, err: %v\n", err)
		return 0, err
	}
	return newID, nil
}

// 更新資料
func updateRowDemo(age, id int) (int64, error) {
	sqlStr := "UPDATE user SET age=? WHERE id = ?"
	ret, err := db.Exec(sqlStr, age, id)
	if err != nil {
		fmt.Printf("update failed, err: %v\n", err)
		return 0, err
	}
	// 回傳受更新、插入或洗掉影響的行數，并非每個資料庫或資料庫驅動程式都支持此功能，
	var n int64
	n, err = ret.RowsAffected() // 操作影響的行數
	if err != nil {
		fmt.Printf("get RowsAffected failed, err: %v\n", err)
		return 0, err
	}
	return n, nil
}

// 洗掉資料
func deleteRowDemo(id int) (int64, error) {
	sqlStr := "DELETE FROM user WHERE id = ?"
	ret, err := db.Exec(sqlStr, id)
	if err != nil {
		fmt.Printf("delete failed, err: %v\n", err)
		return 0, err
	}
	// RowsAffected returns the number of rows affected by an
	// update, insert, or delete. Not every database or database
	// driver may support this.
	var n int64
	n, err = ret.RowsAffected() // 操作影響的行數
	if err != nil {
		fmt.Printf("get RowsAffected failed, err: %v\n", err)
		return 0, err
	}
	return n, nil
}

func main() {
	if err := initMySQL(); err != nil {
		fmt.Printf("connect to db failed, err: %v\n", err)
	}
	// 檢查完錯誤之后執行，確保 db 不為 nil
	// Close() 用來釋放資料庫連接相關的資源
	// Close 將關閉資料庫并阻止啟動新查詢，關閉，然后等待服務器上已開始處理的所有查詢完成，
	defer db.Close()

	fmt.Println("connect to database success")
	// db.xx() 去使用資料庫操作...
	// 查詢單行資料
	//u, err := queryRowDemo(1)
	//if err != nil {
	//	fmt.Printf("query row failed, err: %v", err)
	//}
	//fmt.Printf("id: %d name: %s age: %d\n", u.id, u.name, u.age)
	// 查詢多行資料
	//queryMultiRowDemo(0)
	// 插入資料
	//newID, err := insertRowDemo("小跟班", 12)
	//if err != nil {
	//	fmt.Printf("insert row failed, err: %v", err)
	//}
	//fmt.Printf("insert success, the id is %d.\n", newID)
	// 更新資料
	//n, err := updateRowDemo(88, 4)
	//if err != nil {
	//	fmt.Printf("update row failed with err: %v", err)
	//}
	//fmt.Printf("update success, affected rows: %d\n", n)
	// 洗掉資料
	n, err := deleteRowDemo(4)
	if err != nil {
		fmt.Printf("delete row failed with err: %v", err)
	}
	fmt.Printf("delete success, affected rows:%d\n", n)
}

運行

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
? go run main.go
connect to database success
delete success, affected rows:1

Code/go/mysql_demo via ?? v1.20.3 via ?? base 
?

SQL 查詢洗掉結果

mysql> select * from user;
+----+--------+------+
| id | name   | age  |
+----+--------+------+
|  1 | 小喬   |   16 |
|  2 | 小喬   |   12 |
+----+--------+------+
2 rows in set (0.00 sec)

mysql>

本文來自博客園，作者：尋月隱君，轉載請注明原文鏈接：https://www.cnblogs.com/QiaoPengjun/p/17472974.html

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/554893.html

標籤：其他

上一篇：Maven常用命令及其作用

下一篇：返回列表

標籤雲
其他(160782) Python(38219) JavaScript(25492) Java(18216) C(15237) 區塊鏈(8270) C＃(7972) AI(7469) 爪哇(7425) MySQL(7246) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5873) 数组(5741) R(5409) Linux(5347) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4589) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2435) ASP.NET(2404) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) .NET技术(1984) 功能(1967) HtmlCss(1961) Web開發(1951) C++(1933) python-3.x(1918) 弹簧靴(1913) xml(1889) PostgreSQL(1881) .NETCore(1863) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 【C++】Microsoft C++、C 和匯編程式檔案

    ......

    uj5u.com 2020-09-10 00:57:23 more
  • 例外宣告

    相比于斷言適用于排除邏輯上不可能存在的狀態，例外通常是用于邏輯上可能發生的錯誤。 例外宣告 Item 1：當函式不可能拋出例外或不能接受拋出例外時，使用noexcept 理由 如果不打算拋出例外的話，程式就會認為無法處理這種錯誤，并且應當盡早終止，如此可以有效地阻止例外的傳播與擴散。 示例 //不可 ......

    uj5u.com 2020-09-10 00:57:27 more
  • Codeforces 1400E Clear the Multiset(貪心 + 分治)

    鏈接：https://codeforces.com/problemset/problem/1400/E 來源：Codeforces 思路：給你一個陣列，現在你可以進行兩種操作，操作1：將一段沒有 0 的區間進行減一的操作，操作2：將 i 位置上的元素歸零。最終問：將這個陣列的全部元素歸零后操作的最少 ......

    uj5u.com 2020-09-10 00:57:30 more
  • UVA11610 【Reverse Prime】

    本人看到此題沒有翻譯，就附帶了一個自己的翻譯版本 思考 這一題，它的第一個要求是找出所有 $7$ 位反向質數及其質因數的個數。 我們應該需要質數篩篩選1~$10^{7}$的所有數，這里就不慢慢介紹了。但是，重讀題，我們突然發現反向質數都是 $7$ 位，而將它反過來后的數字卻是 $6$ 位數，這就說明 ......

    uj5u.com 2020-09-10 00:57:36 more
  • 統計區間素數數量

    1 #pragma GCC optimize(2) 2 #include <bits/stdc++.h> 3 using namespace std; 4 bool isprime[1000000010]; 5 vector<int> prime; 6 inline int getlist(int ......

    uj5u.com 2020-09-10 00:57:47 more
  • C/C++編程筆記：C++中的 const 變數詳解，教你正確認識const用法

    1、C中的const 1、區域const變數存放在堆疊區中，會分配記憶體（也就是說可以通過地址間接修改變數的值）。測驗代碼如下： 運行結果： 2、全域const變數存放在只讀資料段（不能通過地址修改，會發生寫入錯誤）， 默認為外部聯編，可以給其他源檔案使用（需要用extern關鍵字修飾） 運行結果： ......

    uj5u.com 2020-09-10 00:58:04 more
  • 【C++犯錯記錄】VS2019 MFC添加資源不懂如何修改資源宏ID

    1. 首先在資源視圖中，添加資源 2. 點擊新添加的資源，復制自動生成的ID 3. 在解決方案資源管理器中找到Resource.h檔案，編輯，使用整個專案搜索和替換的方式快速替換 宏宣告 4. Ctrl+Shift+F 全域搜索，點擊查找全部，然后逐個替換 5. 為什么使用搜索替換而不使用屬性視窗直 ......

    uj5u.com 2020-09-10 00:59:11 more
  • 【C++犯錯記錄】VS2019 MFC不懂的批量添加資源

    1. 打開資源頭檔案Resource.h，在其中預先定義好宏 ID（不清楚其實ID值應該設定多少，可以先新建一個相同的資源項，再在這個資源的ID值的基礎上遞增即可） 2. 在資源視圖中選中專案資源，按F7編輯資源檔案，按 ID 型別 相對路徑的形式添加 資源。（別忘了先把檔案拷貝到專案中的res檔案 ......

    uj5u.com 2020-09-10 01:00:19 more
  • C/C++編程筆記：關于C++的參考型別，專供新手入門使用

    今天要講的是C++中我最喜歡的一個用法——參考，也叫別名。 參考就是給一個變數名取一個變數名，方便我們間接地使用這個變數。我們可以給一個變數創建N個參考，這N + 1個變數共享了同一塊記憶體區域。(參考型別的變數會占用記憶體空間，占用的記憶體空間的大小和指標型別的大小是相同的。雖然參考是一個物件的別名，但 ......

    uj5u.com 2020-09-10 01:00:22 more
  • 【C/C++編程筆記】從頭開始學習C ++：初學者完整指南

    眾所周知，C ++的學習曲線陡峭，但是花時間學習這種語言將為您的職業帶來奇跡，并使您與其他開發人員區分開。您會更輕松地學習新語言，形成真正的解決問題的技能，并在編程的基礎上打下堅實的基礎。 C ++將幫助您養成良好的編程習慣（即清晰一致的編碼風格，在撰寫代碼時注釋代碼，并限制類內部的可見性），并且由 ......

    uj5u.com 2020-09-10 01:00:41 more
最新发布
  • Go 語言連接資料庫實作增刪改查

    title: "Go 語言連接資料庫實作增刪改查" date: 2023-06-10T18:55:16+08:00 draft: true tags: ["Go"] categories: ["Go"] # Go 連接 MySQL實作增刪改查 ## 一、初始化連接 ### 創建專案 ![](http ......

    uj5u.com 2023-06-12 07:35:18 more
  • Maven常用命令及其作用

    一、Maven常用命令及其作用 Maven的生命周期包括：clean、validate、compile、test、package、verify、install、site、deploy，其中需要注意的是：執行后面的命令時，前面的命令自動得到執行,(其中，也可以跳過其中的步驟，如：test,在mvn i ......

    uj5u.com 2023-06-12 07:35:10 more
  • 【技識訓累】Python中的Pandas庫【三】

    博客推行版本更新，成果積累制度，已經寫過的博客還會再次更新，不斷地琢磨，高質量高數量都是要追求的，工匠精神是學習必不可少的精神。因此，大家有何建議歡迎在評論區踴躍發言，你們的支持是我最大的動力，你們敢投，我就敢肝 ......

    uj5u.com 2023-06-12 07:34:50 more
  • C++ 指標

    # 一、C++ 指標的算術運算 ## 遞增一個指標 我們喜歡在程式中使用指標代替陣列，因為變數指標可以遞增，而陣列不能遞增，因為陣列是一個常量指標。下面的程式遞增變數指標，以便順序訪問陣列中的每一個元素： ``` 實體 #include using namespace std; const int ......

    uj5u.com 2023-06-11 07:17:06 more
  • ImageIO的應用 （AWT和Swing初接觸）

    # ImageIO的應用 # 一、關于IO流 在講imageio之前，我們先來復習一下IO流的使用。 這里我建立一個Java類，用來實作讀取檔案中的內容，并且能夠識別換行，話不多說，上代碼： ```java package com.Evan.demo; import java.io.Buffered ......

    uj5u.com 2023-06-10 07:56:56 more
  • C++面試八股文：了解sizeof運算子嗎？

    某日二師兄參加XXX科技公司的C++工程師開發崗位第10面： > 面試官：了解`sizeof`運算子嗎？ > > 二師兄：略微了解（不就是求大小的嘛。。） > > 面試官：請講以下如何使用`sizeof`？ > > 二師兄：`sizeof`主要是求變數或者型別的大小。直接使用`sizeof(type ......

    uj5u.com 2023-06-10 07:56:48 more
  • Rust - 介面設計建議之靈活（flexible）

    # Rust - 介面設計建議之靈活（flexible） ## 靈活（flexible） ### 代碼的契約（Contract） - 你寫的代碼包含契約 - 契約： - 要求：代碼使用的限制 - 承諾：代碼使用的保證 - 設計介面時（經驗法則）： - 避免施加不必要的限制，只做能夠兌現的承諾 - 增 ......

    uj5u.com 2023-06-10 07:56:43 more
  • C語言回圈列印空心正方形代碼實作

    ```c #include int main() { int w, i, j; printf("輸入正方形邊長\n"); scanf_s("%d", &w); if (w <= 0) { printf("正方形邊長要大于0\n"); return 0; } // 外層回圈控制行數 for (i = ......

    uj5u.com 2023-06-10 07:56:38 more
  • JavaWeb準備作業和部分環境配置

    # JavaWeb ## 基本概念 web開發: - web：網頁的意思 - 靜態web：提供的資料資源不會發生改變 - 動態web：資料是不斷變化的，現代網站幾乎都是動態網站技術堆疊： Servlet/JSP：基于java，主推B/S架構，可以 ? 承載高并發，語法類似ASP ? ASP：微軟，國內 ......

    uj5u.com 2023-06-10 07:56:00 more
  • 切片比陣列好用在哪

    # 1. 引言 在Go語言中，陣列和切片都是常見的資料結構，它們經常被用于存盤資料，可以相互替換。本文將介紹Go語言中陣列和切片的基本概念，同時詳細探討切片的優勢。從而能夠充分的理解切片相對于陣列的優點，更好得對切片進行使用。 # 2. 基本介紹 ### 2.1 陣列 陣列是一種固定長度、具有相同類 ......

    uj5u.com 2023-06-10 07:55:41 more

Copyright © 2010-2020 有解無憂