Golang은 단순히 mysql을 구현합니다.-Golang-php.cn

Golang은 단순히 mysql을 구현합니다.

WBOY

풀어 주다： 2023-05-15 11:45:07

원래의

781명이 탐색했습니다.

Golang을 사용하여 데이터베이스를 운영하는 프로그램을 작성하는 것은 매우 쉽습니다. 이는 MySQL 데이터베이스에서도 예외는 아닙니다. 다음은 Golang에서 MySQL 작업을 간단하게 구현하는 방법을 소개합니다.

먼저 Golang과 MySQL을 올바르게 설치했는지 확인하고 Go용 MySQL 드라이버도 설치해야 합니다. 이는 다음 명령을 사용하여 쉽게 수행할 수 있습니다.

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

로그인 후 복사

Go 프로그램을 만들기 전에 데이터베이스 작업에 Golang을 사용하는 방법을 보여주기 위해 MySQL 데이터베이스와 테이블도 만들어야 합니다.

"test_db"라는 데이터베이스를 생성했고 여기에 "users"라는 테이블이 포함되어 있다고 가정합니다. 테이블의 구조는 다음과 같습니다:

CREATE TABLE IF NOT EXISTS `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `email` varchar(50) NOT NULL,
  `age` smallint(6) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

로그인 후 복사

다음으로 Golang 프로그램 작성을 시작할 수 있습니다. 다음은 Golang 드라이버를 사용하여 MySQL 데이터베이스에 연결하고 몇 가지 기본 쿼리 작업을 수행하는 방법을 보여주는 간단한 프로그램 예제입니다.

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    // 连接 MySQL 数据库
    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/test_db?charset=utf8mb4")
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    // 执行查询操作
    rows, err := db.Query("SELECT * FROM users")
    if err != nil {
        panic(err.Error())
    }
    defer rows.Close()

    // 遍历查询结果
    for rows.Next() {
        var id int
        var name string
        var email string
        var age int
        err := rows.Scan(&id, &name, &email, &age)
        if err != nil {
            panic(err.Error())
        }
        fmt.Println(id, name, email, age)
    }

    // 检查是否存在错误
    err = rows.Err()
    if err != nil {
        panic(err.Error())
    }
}

로그인 후 복사

위 프로그램을 실행하면 MySQL 데이터베이스에 성공적으로 연결하고 " SELECT" 문 "users" 테이블의 모든 레코드를 확인하고 결과를 출력합니다.

쿼리 외에도 Golang 드라이버를 사용하여 삽입, 업데이트 및 삭제와 같은 다른 일반적인 MySQL 작업을 수행할 수도 있습니다. 다음은 간단한 프로그램 예입니다.

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    // 连接 MySQL 数据库
    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/test_db?charset=utf8mb4")
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    // 插入一条记录
    stmt, err := db.Prepare("INSERT INTO users(name, email, age) VALUES(?, ?, ?)")
    if err != nil {
        panic(err.Error())
    }
    defer stmt.Close()

    result, err := stmt.Exec("Tom", "tom@email.com", 30)
    if err != nil {
        panic(err.Error())
    }
    lastInsertId, _ := result.LastInsertId()
    fmt.Println("新增记录的 ID：", lastInsertId)

    // 更新一条记录
    stmt, err = db.Prepare("UPDATE users SET name=?, age=? WHERE id=?")
    if err != nil {
        panic(err.Error())
    }
    defer stmt.Close()

    result, err = stmt.Exec("Jerry", 25, 1)
    if err != nil {
        panic(err.Error())
    }
    affectRow, _ := result.RowsAffected()
    fmt.Println("受影响的行数：", affectRow)

    // 删除一条记录
    stmt, err = db.Prepare("DELETE FROM users WHERE id=?")
    if err != nil {
        panic(err.Error())
    }
    defer stmt.Close()

    result, err = stmt.Exec(1)
    if err != nil {
        panic(err.Error())
    }
    affectRow, _ = result.RowsAffected()
    fmt.Println("受影响的行数：", affectRow)
}

로그인 후 복사

위의 프로그램 예를 사용하면 삽입, 업데이트, 삭제와 같은 일반적인 MySQL 작업을 성공적으로 수행할 수 있습니다.

전반적으로 Golang 드라이버를 사용하여 MySQL 데이터베이스 작업을 구현하는 것은 매우 간단합니다. 쿼리, 삽입, 업데이트, 삭제 등 다양한 작업을 Golang 드라이버를 통해 쉽게 구현할 수 있습니다.

위 내용은 Golang은 단순히 mysql을 구현합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!