Go 言語を使用してデータベースに接続する: アプリケーションのパフォーマンスと効率を向上させる

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

package main

import (
    "database/sql"
    "fmt"

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

func main() {
    // 数据库连接配置
    db, err := sql.Open("mysql", "用户名:密码@tcp(localhost:3306)/数据库名")
    if err != nil {
        panic(err)
    }
    
    defer db.Close()

    // 测试数据库连接
    err = db.Ping()
    if err != nil {
        panic(err)
    }

    fmt.Println("成功连接到数据库！")
}

package main

import (
    "database/sql"
    "fmt"

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

type User struct {
    ID   int
    Name string
    Age  int
}

func main() {
    // 建立数据库连接...

    // 查询所有数据
    rows, err := db.Query("SELECT * FROM users")
    if err != nil {
        panic(err)
    }

    defer rows.Close()

    users := []User{}

    // 遍历查询结果
    for rows.Next() {
        user := User{}
        err := rows.Scan(&user.ID, &user.Name, &user.Age)
        if err != nil {
            panic(err)
        }

        users = append(users, user)
    }

    // 输出查询结果
    for _, user := range users {
        fmt.Println(user)
    }
}

package main

import (
    "database/sql"
    "fmt"

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

func main() {
    // 建立数据库连接...

    // 插入数据
    result, err := db.Exec("INSERT INTO users(name, age) VALUES (?, ?)", "张三", 20)
    if err != nil {
        panic(err)
    }

    // 获取插入数据的ID
    lastInsertID, _ := result.LastInsertId()
    fmt.Println("插入成功，ID为", lastInsertID)
}

package main

import (
    "database/sql"
    "fmt"

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

func main() {
    // 建立数据库连接...

    // 更新数据
    result, err := db.Exec("UPDATE users SET age=? WHERE name=?", 30, "张三")
    if err != nil {
        panic(err)
    }

    // 获取更新的行数
    rowCount, _ := result.RowsAffected()
    fmt.Println("更新成功，影响行数为", rowCount)
}

package main

import (
    "database/sql"
    "fmt"

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

func main() {
    // 建立数据库连接...

    // 删除数据
    result, err := db.Exec("DELETE FROM users WHERE name=?", "张三")
    if err != nil {
        panic(err)
    }

    // 获取删除的行数
    rowCount, _ := result.RowsAffected()
    fmt.Println("删除成功，影响行数为", rowCount)
}