使用Go驅動包Go-MySQL-Driver串連MySQL資料庫

package main

import (
    // 引入Go語言的 database/sql 包，它提供了通用的SQL介面
    "database/sql"
    // 引入fmt包，它是Go語言標準庫中用于格式化輸入輸出的包
    "fmt"
    // 該驅動可在Go語言中串連和操作MySQL資料庫
    "github.com/go-sql-driver/mysql"
    // 引入了Go語言的time包，用於處理時間相關的操作
    "time"
)

func main() {
    //建立一個資料庫連接
    cfg := mysql.NewConfig()
    cfg.User = "****"                                                   /*使用者名稱*/
    cfg.Passwd = "****"                                                 /*密碼*/
    cfg.Net = "tcp"                                                     /*連線類型*/
    cfg.Addr = "rm-2ze1vw17v542q6b****.mysql.pre.rds.aliyuncs.com:3306" /*串連地址*/
    cfg.DBName = "****"                                                 /*資料庫名稱*/
    cfg.Timeout = 3 * time.Second                                       /*串連到資料庫的逾時時間，您可按需指定為毫秒（ms）、秒（s）或分鐘（m）*/
    cfg.ReadTimeout = 60 * time.Second                                  /*I/O讀取的逾時時間，您可按需指定為毫秒（ms）、秒（s）或分鐘（m）*/
    cfg.WriteTimeout = 60 * time.Second                                 /*I/O寫入的逾時時間，您可按需指定為毫秒（ms）、秒（s）或分鐘（m）*/

    conn, err := mysql.NewConnector(cfg)
    if err != nil {
        panic(err.Error())
    }

    db := sql.OpenDB(conn)
    defer func(db *sql.DB) {
        err := db.Close()
        if err != nil {
            fmt.Printf("Error closing database connection: %v\n", err)
        }
    }(db)

    // 設定串連池參數
    db.SetMaxOpenConns(100)                 /*設定串連池中最大開啟的串連數*/
    db.SetMaxIdleConns(20)                  /*設定串連池中最大閒置串連數*/
    db.SetConnMaxIdleTime(10 * time.Minute) /*設定串連在串連池中的最長的空閑時間*/
    db.SetConnMaxLifetime(8 * time.Hour)    /*設定串連的最大生命週期*/

    // 建立一個名為 userinfo 的表
    _, err = db.Exec("create table  if not exists userinfo( uid int auto_increment, username varchar(20) not null default '', departname varchar(20) not null default '', created varchar(10) not null default '', primary key(uid) );")
    if err != nil {
        fmt.Println("create table error ", err)
        return
    }

    // 直接寫入資料
    stmt, err := db.Prepare("INSERT userinfo SET username=?,departname=?,created=?")
    res, err := stmt.Exec("James", "Research", "2016-06-17")
    id, err := res.LastInsertId()
    if err != nil {
        panic(err)
    }
    fmt.Println(id)

    // 通過綁定參數的方式寫入資料
    result, err := db.Exec("INSERT INTO userinfo (username, departname, created) VALUES (?, ?, ?)", "Linda", "Testing", "2016-06-21")
    if err != nil {
        panic(err)
    }
    ids, err := result.LastInsertId()
    fmt.Println(ids)

    // 更新資料
    stmtUpdate, err := db.Prepare("UPDATE userinfo SET username=?, departname=?, created=? WHERE username=?")
    if err != nil {
        fmt.Println("Prepare update statement error:", err)
        return
    }
    resUpdate, err := stmtUpdate.Exec("Robert", "Sales", "2024-09-23", "Linda")
    if err != nil {
        fmt.Println(err)
    }
    rowCnt, _ := resUpdate.RowsAffected()
    fmt.Println(rowCnt)

    // 直接查詢資料
    rows, err := db.Query("SELECT username,departname,created FROM userinfo WHERE username=?", "Robert")
    if err != nil {
        panic(err)
    }
    for rows.Next() {
        var username, departname, created string
        if err := rows.Scan(&username, &departname, &created); err != nil {
            fmt.Println(err)
        }
        fmt.Println("username:", username, "departname:", departname, "created:", created)
    }
    defer func(rows *sql.Rows) {
        err := rows.Close()
        if err != nil {
            fmt.Println(err)
        }
    }(rows)

    // 通過綁定參數的方式執行參數化查詢
    stmtQuery, err := db.Prepare("SELECT username,departname,created FROM userinfo WHERE username=?")
    if err != nil {
        fmt.Println("prepare error", err)
        return
    }
    rowData, err := stmtQuery.Query("Robert")
    if err != nil {
        fmt.Println("query data error", err)
        return
    }
    for rowData.Next() {
        var username, departname, created string
        if err := rowData.Scan(&username, &departname, &created); err != nil {
            fmt.Println(err)
        }
        fmt.Println("username:", username, "departname:", departname, "created:", created)
    }
    defer func(rows *sql.Rows) {
        err := rows.Close()
        if err != nil {
            fmt.Println(err)
        }
    }(rowData)

    // 刪除資料
    delStmt, _ := db.Prepare("DELETE FROM userinfo WHERE username=?")
    resultDel, err := delStmt.Exec("James")
    if err != nil {
        panic(err)
    }
    rowAffect, _ := resultDel.RowsAffected()
    fmt.Println("Data deletion completed.", rowAffect)
}