집 >백엔드 개발 >Golang >Go에서 데이터베이스를 어떻게 사용하나요?

Go에서 데이터베이스를 어떻게 사용하나요?

PHPz원래의: 2023-05-10 17:48:061437검색

인터넷에서 웹 애플리케이션과 기타 복잡한 애플리케이션이 널리 보급되면서 데이터베이스는 없어서는 안 될 부분이 되었습니다. Go는 웹 애플리케이션 및 기타 시스템 개발에 사용할 수 있는 인기 있는 프로그래밍 언어입니다. 이번 글에서는 Go에서 데이터베이스를 사용하는 방법을 살펴보겠습니다.

데이터베이스 선택

데이터베이스 사용을 시작하기 전에 먼저 애플리케이션에 적합한 데이터베이스를 선택해야 합니다. Go는 MySQL, PostgreSQL, MongoDB 등과 같은 널리 사용되는 많은 데이터베이스를 지원합니다. ORM(객체 관계형 매퍼) 라이브러리 또는 SQL 생성기 라이브러리를 사용하여 데이터베이스 상호 작용을 단순화할 수도 있습니다. ORM 라이브러리는 개체를 데이터베이스의 테이블에 매핑하는 라이브러리이고, SQL 생성기 라이브러리는 SQL 쿼리를 생성하고 쿼리하기 위한 라이브러리입니다. 데이터베이스 선택은 애플리케이션 요구 사항과 다양한 데이터베이스의 장점과 단점에 대한 이해를 바탕으로 이루어져야 합니다.

데이터베이스 드라이버 설치

데이터베이스를 선택했으면 다음 단계는 데이터베이스 드라이버를 설치하는 것입니다. Go에는 다양한 데이터베이스용 드라이버가 있습니다. Go의 표준 라이브러리 데이터베이스/sql 또는 더 높은 수준의 기능을 갖춘 외부 라이브러리의 드라이버를 사용할 수 있습니다. 데이터베이스의 공식 문서에서 드라이버에 대한 올바른 정보를 얻는 것이 중요합니다. 선택한 데이터베이스에 따라 요구 사항이 다르므로 설치 과정에서 주의해야 할 몇 가지 세부 사항을 숙지하시기 바랍니다.

연결 설정

데이터베이스를 사용하기 전에 데이터베이스에 대한 연결을 설정해야 합니다. Go에서는 다음 코드를 사용하여 MySQL 데이터베이스에 대한 연결을 생성할 수 있습니다.

package main

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

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/mydb")
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    err = db.Ping()
    if err != nil {
        panic(err.Error())
    }

    fmt.Println("Connection established")
}

이 예에서는 sql.Open() 함수를 사용하여 MySQL 데이터베이스 연결을 엽니다. Open() 함수에서는 MySQL 드라이버(이 경우 github.com/go-sql-driver/mysql)를 사용하여 Go에 데이터베이스 이름, 사용자 이름, 비밀번호 및 연결할 주소입니다. 그런 다음 db.Ping() 명령을 사용하여 데이터베이스 연결이 성공했는지 테스트하여 연결이 성공했는지 확인합니다. 마지막으로 defer db.Close()를 사용하여 프로그램이 종료되기 전에 데이터베이스 연결이 닫히도록 하세요. sql.Open()函数打开一个MySQL数据库连接。在Open()函数中，我们使用MySQL的驱动程序（在这种情况下是github.com/go-sql-driver/mysql），告诉Go我们要连接的数据库名称，用户名，密码和地址。然后，我们使用db.Ping()命令来测试是否成功连接到数据库，以确保连接成功。最后，使用defer db.Close()，以确保在程序退出之前关闭数据库连接。

执行查询

一旦与数据库建立了连接，您就可以开始使用它。要执行查询语句，您可以使用db.Query()或db.QueryRow()函数。 db.Query()函数用于执行返回多行的查询，而db.QueryRow()函数用于执行返回单行结果的查询。

下面是一个用于执行查询的示例：

package main

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

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/mydb")
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    rows, err := db.Query("SELECT * FROM mytable")
    if err != nil {
        panic(err.Error())
    }
    defer rows.Close()

    for rows.Next() {
        var id int
        var name string
        err = rows.Scan(&id, &name)
        if err != nil {
            panic(err.Error())
        }
        fmt.Println("id:", id, "name:", name)
    }

    err = rows.Err()
    if err != nil {
        panic(err.Error())
    }
}

在上述示例代码中，我们首先使用db.Query()执行SELECT语句，将结果存储在rows变量中。然后，我们使用rows.Close()函数关闭结果集。接下来，我们使用rows.Next()循环遍历结果集中的每一行，并使用rows.Scan()函数将结果和变量匹配。最后，我们使用rows.Err()函数处理任何潜在的错误。

执行插入，更新和删除操作

除了查询操作，数据库还支持插入，更新和删除操作。在Go中执行这些操作与查询操作类似，您需要使用不同的函数。

要执行插入操作，您可以使用以下代码：

res, err := db.Exec("INSERT INTO mytable (name) VALUES (?)", "John")
if err != nil {
    panic(err.Error())
}
lastInsertID, err := res.LastInsertId()
if err != nil {
    panic(err.Error())
}
fmt.Println("Last inserted ID:", lastInsertID)

要执行更新操作，您可以使用以下代码：

res, err = db.Exec("UPDATE mytable SET name = ? WHERE id = ?", "John Doe", 1)
if err != nil {
    panic(err.Error())
}
rowsAffected, err := res.RowsAffected()
if err != nil {
    panic(err.Error())
}
fmt.Println("Rows affected:", rowsAffected)

要执行删除操作，您可以使用以下代码：

res, err = db.Exec("DELETE FROM mytable WHERE id = ?", 1)
if err != nil {
    panic(err.Error())
}
rowsAffected, err = res.RowsAffected()
if err != nil {
    panic(err.Error())
}
fmt.Println("Rows affected:", rowsAffected)

使用事务

在进行任何更改时，使用数据库事务对于确保数据库的完整性非常重要。在Go中，您可以使用以下代码使用事务：

tx, err := db.Begin()

stmt, err := tx.Prepare("INSERT INTO mytable (name) VALUES (?)")
if err != nil {
    tx.Rollback()
    panic(err.Error())
}

_, err = stmt.Exec("John")
if err != nil {
    tx.Rollback()
    panic(err.Error())
}

stmt, err = tx.Prepare("UPDATE mytable SET name = ? WHERE id = ?")
if err != nil {
    tx.Rollback()
    panic(err.Error())
}

_, err = stmt.Exec("John Doe", 1)
if err != nil {
    tx.Rollback()
    panic(err.Error())
}

err = tx.Commit()
if err != nil {
    panic(err.Error())
}

在上述代码中，我们首先使用db.Begin()函数启动一个事务。然后，我们使用tx.Prepare()函数准备要执行的SQL语句。接下来，我们使用stmt.Exec()函数执行SQL语句。在执行所有操作之后，我们使用tx.Commit()函数提交事务。如果任何操作失败，我们使用tx.Rollback()

데이터베이스에 대한 연결이 설정되면 사용을 시작할 수 있습니다. 쿼리문을 실행하려면 db.Query() 또는 db.QueryRow() 함수를 사용하면 됩니다. db.Query() 함수는 여러 행을 반환하는 쿼리를 실행하는 데 사용되며, db.QueryRow() 함수는 단일 행을 반환하는 쿼리를 실행하는 데 사용됩니다. 결과.

다음은 쿼리 실행의 예입니다.

db.Query()

rows.Close()

rows.Next()

rows.Scan()

rows.Err()

쿼리 작업 외에도 데이터베이스는 삽입, 업데이트 및 삭제 작업도 지원합니다. Go에서 이러한 작업을 수행하는 것은 쿼리 작업과 유사하므로 다른 기능을 사용해야 합니다.
삽입 작업을 수행하려면 다음 코드를 사용할 수 있습니다.

업데이트 작업을 수행하려면 다음 코드를 사용할 수 있습니다. 🎜rrreee 🎜 삭제 작업을 수행하려면 다음 코드를 사용할 수 있습니다. 🎜rrreee🎜트랜잭션 사용🎜🎜🎜데이터베이스 트랜잭션을 사용하는 것은 변경 시 데이터베이스의 무결성을 보장하는 데 매우 중요합니다. Go에서는 다음 코드를 사용하여 트랜잭션을 사용할 수 있습니다. 🎜rrreee🎜 위 코드에서는 먼저 db.Begin() 함수를 사용하여 트랜잭션을 시작합니다. 그런 다음 tx.Prepare() 함수를 사용하여 실행할 SQL 문을 준비합니다. 다음으로 stmt.Exec() 함수를 사용하여 SQL 문을 실행합니다. 모든 작업이 수행된 후 tx.Commit() 함수를 사용하여 트랜잭션을 커밋합니다. 작업이 실패하면 tx.Rollback() 함수를 사용하여 모든 변경 사항을 롤백합니다. 🎜🎜🎜References🎜🎜🎜이 글에서는 Go에서 데이터베이스를 사용하는 방법을 다루었습니다. 고급 데이터베이스 작업의 경우 더 쉬운 상호 작용을 위해 ORM 또는 SQL 생성기 라이브러리를 사용할 수 있습니다. 특정 데이터베이스 사용에 대한 자세한 내용을 알아보려면 관련 공식 문서 및 Go 라이브러리 문서를 참조하세요. 다음은 몇 가지 참고 자료입니다. 🎜🎜🎜Golang용 데이터베이스/SQL: https://golang.org/pkg/database/sql/ 🎜🎜Go MySQL 드라이버: https://github.com/go-sql-driver/ mysql🎜 🎜Go PostgreSQL 드라이버: https://github.com/lib/pq🎜🎜MongoDB Go 드라이버: https://github.com/mongodb/mongo-go-driver🎜🎜

위 내용은 Go에서 데이터베이스를 어떻게 사용하나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명：

이전 기사：golang 프로세스가 비정상적으로 중지됩니다.다음 기사：golang 프로세스가 비정상적으로 중지됩니다.