golang에서 mysql을 쿼리하는 방법

인터넷의 발달로 인해 데이터 처리 및 관리는 다양한 산업 분야에서 필수적인 부분이 되었습니다. 데이터베이스 관리 시스템(DBMS)은 많은 기업이 일상적인 운영 및 관리에 사용하는 데이터베이스를 관리하고 액세스하기 위한 소프트웨어 시스템입니다. MySQL은 일반적으로 사용되는 관계형 데이터베이스 관리 시스템 중 하나입니다. 개발 중에는 MySQL을 연결하고 운영하기 위해 프로그래밍 언어를 사용해야 할 수도 있습니다. 이 기사에서는 Go 언어를 사용하여 MySQL 데이터베이스를 쿼리하는 방법을 소개합니다.

1. MySQL 드라이버 설치

go 언어 공식 웹사이트에서는 MySQL 데이터베이스 드라이버를 제공하며 다양한 MySQL 버전을 지원합니다. MySQL 드라이버를 설치하려면 시스템에 Go 언어 개발 환경과 MySQL 데이터베이스가 있어야 합니다.

1. 명령줄을 열고 다음 명령을 사용하여 MySQL 드라이버를 설치합니다.

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

go-sql-driver 패키지는 이제 MySQL 쿼리를 수행하는 데 사용할 수 있습니다.

2. 데이터베이스 연결 설정

go 언어를 사용하여 MySQL 쿼리를 수행하기 전에 MySQL 데이터베이스에 대한 연결을 설정해야 합니다. MySQL 데이터베이스에 연결하려면 사용자 이름, 비밀번호, 데이터베이스 이름, 호스트 주소 및 기타 정보를 지정해야 합니다.

1. go 언어 편집기(예: VSCode)를 열고 db.go라는 새 파일을 만듭니다.
2. 파일에 다음 코드를 입력하세요:

package main

import (
    "database/sql"
    "fmt"
    "log"

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

func main() {

    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/databaseName")

    if err != nil {
        log.Fatal(err)
    }

    defer db.Close()

    err = db.Ping()

    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Successful database connection")
}

위 코드에서는 sql.Open() 함수를 사용하여 MySQL 데이터베이스 연결을 열 때 드라이버 이름과 데이터베이스 연결 문자열을 지정해야 합니다. 연결 문자열은 사용자 이름과 비밀번호는 물론 MySQL 호스트 주소와 포트 번호를 지정합니다. MySQL에 연결할 때 MySQL 드라이버는 연결 응답을 처리합니다. 이 데이터베이스에 대한 연결이 성공하면 데이터베이스 개체에 대한 포인터가 반환됩니다. 모든 문제가 해결된 후에는 연결 누수로 인해 데이터베이스 리소스가 과도하게 소모되지 않도록 db.Close()를 사용하여 연결을 닫아야 합니다.

3. 쿼리문 실행

SQL 데이터베이스 연결이 완료되면 쿼리 및 연산문 실행을 시작할 수 있습니다. 다음은 간단한 쿼리문의 명령 예입니다.

rows, err := db.Query("SELECT id, name, age FROM user")

위 쿼리문은 user라는 테이블의 id, name, age 필드를 쿼리할 수 있습니다. db.Query() 메서드를 사용하면 쿼리가 실행되고 쿼리 결과의 행 개체(rows)와 가능한 오류(err)가 반환됩니다. 쿼리의 결과 데이터는 행 개체(행)로 래핑됩니다.

물론, 실행해야 하는 SQL 문에 일부 매개변수가 포함되어 있으면 자리 표시자를 사용해야 합니다. 예는 다음과 같습니다.

rows, err := db.Query("SELECT id, name, age FROM user WHERE name = ? AND age = ?", "John", 30)

쿼리하기 전에 자리 표시자가 올바른 SQL 형식으로 자동 변환되고 쿼리에 필요한 매개 변수가 SQL 드라이버에 전달됩니다. 이 접근 방식은 SQL 삽입 공격을 방지하고 쿼리 문을 안전하게 유지합니다.

4. 쿼리 결과 처리

MySQL 데이터베이스를 쿼리한 후 Rows 개체를 사용하여 결과 집합에서 데이터를 읽을 수 있습니다. Rows 개체는 쿼리 결과 데이터를 조작하기 위한 메서드 집합을 제공합니다. 예를 들어, Scan() 메서드를 사용하여 결과 집합의 각 행에 있는 각 열을 추출할 수 있습니다.

for rows.Next() {
    var id int
    var name string
    var age int
    err := rows.Scan(&id, &name, &age)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("ID:%d, Name:%s, Age:%d", id, name, age)
}

위 코드에서 행.Next() 및 행.Scan() 메서드를 사용하여 각 열을 추출합니다. 행의 데이터를 콘솔에 출력합니다. 행.Next() 메서드가 다음 행을 가리키는 경우 행.Scan() 메서드를 사용하여 해당 행의 행 데이터를 추출할 수 있습니다. Scan() 메서드의 매개 변수는 각 데이터 열의 주소입니다.

5. 전체 코드 예제

다음은 db.go 파일로 저장할 수 있는 go 언어를 사용하여 MySQL을 쿼리하기 위한 전체 예제 프로그램입니다.

package main

import (
    "database/sql"
    "fmt"
    "log"

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

func main() {

    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/databaseName")

    if err != nil {
        log.Fatal(err)
    }

    defer db.Close()

    err = db.Ping()

    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Successful database connection")

    rows, err := db.Query("SELECT id, name, age FROM user")

    if err != nil {
        log.Fatal(err)
    }

    defer rows.Close()

    for rows.Next() {
        var id int
        var name string
        var age int
        err := rows.Scan(&id, &name, &age)
        if err != nil {
            log.Fatal(err)
        }
        fmt.Printf("ID:%d, Name:%s, Age:%d
", id, name, age)
    }

    err = rows.Err()

    if err != nil {
        log.Fatal(err)
    }

}

Summary

이 문서에서 쿼리하는 방법을 배웠습니다. 언어 MySQL 데이터베이스로 이동하세요. 먼저 MySQL 드라이버를 설치한 다음 MySQL 데이터베이스에 대한 연결을 설정해야 합니다. 데이터베이스 연결을 얻은 후 쿼리 및 작업 문을 실행하고 Rows 개체를 사용하여 결과 집합에서 데이터를 읽을 수 있습니다. 마지막으로 MySQL 데이터베이스를 연결하고, 쿼리하고, 읽는 방법을 보여주는 완전한 Go 언어 프로그램 예제를 제공합니다.

위 내용은 golang에서 mysql을 쿼리하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!