golang에서 데이터베이스에 연결하는 방법은 무엇입니까?-Golang-php.cn

golang에서 데이터베이스에 연결하는 방법은 무엇입니까?

PHPz

풀어 주다： 2023-04-25 15:47:32

원래의

2457명이 탐색했습니다.

현대 애플리케이션 개발에서는 대부분의 애플리케이션 데이터가 데이터베이스에 저장되기 때문에 데이터베이스와의 상호 작용은 매우 중요한 작업입니다. Golang 개발에 있어서 데이터베이스와의 연결 역시 필수적인 작업입니다. 이 기사에서는 Golang을 사용하여 데이터베이스에 연결하는 방법을 소개합니다.

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

Golang에서 데이터베이스에 연결하려면 해당 데이터베이스 드라이버를 사용해야 합니다. 따라서 시작하기 전에 해당 드라이버를 설치해야 합니다. Golang은 MySQL, PostgreSQL, SQL Server, Oracle 등과 같은 다양한 유형의 데이터베이스에 연결할 수 있습니다. 각 데이터베이스에는 서로 다른 드라이버가 필요합니다.

MySQL을 예로 들어 데이터베이스에 연결하는 방법을 설명하겠습니다. MySQL에 연결하기 전에 mysql 드라이버를 설치해야 합니다. 다음 명령을 사용하여 설치할 수 있습니다.

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

로그인 후 복사

물론 코드에서 해당 라이브러리를 가져와야 합니다.

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

로그인 후 복사

MySQL에 연결

MySQL에 연결하려면 다음 기본 정보가 필요합니다.

데이터베이스 이름
호스트 이름/IP 주소
포트 번호
사용자 이름
비밀번호

Golang에서, 당신은 사용할 수 있습니다 다음 코드 Connect to MySQL:

func Connect() (*sql.DB, error){

  //设置数据库连接信息
  db, err := sql.Open("mysql", "USER_NAME:PASSWORD@tcp(HOST:PORT)/DB_NAME")

  //测试连接
  err = db.Ping()
  if err != nil {
    return nil, err
  }

  return db, nil
}

로그인 후 복사

이 코드 조각에서는 sql.Open() 함수를 사용하여 데이터베이스 연결을 열고 매개변수를 전달하여 데이터베이스 연결 정보를 지정합니다. 이 경우 HOST는 데이터베이스 호스트의 IP 주소 또는 호스트 이름, PORT는 MySQL의 포트 번호, DB_NAME은 연결할 데이터베이스의 이름, USER_NAME 및 PASSWORD는 데이터베이스의 사용자 이름과 비밀번호입니다. 연결이 성공하면 데이터베이스 인스턴스에 대한 포인터가 반환됩니다. sql.Open()函数打开一个数据库连接，并且通过传递的参数来指定数据库的连接信息。在这种情况下，HOST是数据库主机的IP地址或主机名，PORT是MySQL的端口号，DB_NAME是要连接的数据库的名称，USER_NAME和PASSWORD是数据库的用户名和密码。如果连接成功，则返回一个指向数据库实例的指针。

执行查询

连接数据库之后，我们可以执行各种查询和操作。Golang中可以使用Prepare()和Exec()或Query()函数执行SQL查询。

例如，下面的代码段可以执行一个Insert查询：

func AddProduct(name string, price int) error {

  //连接到数据库
  db, err := Connect()
  if err != nil {
    return err
  }
  defer db.Close()

  //准备SQL语句
  stmt, err := db.Prepare("INSERT INTO products(name, price) VALUES(?,?)")
  if err != nil {
    return err
  }
  defer stmt.Close()

  //执行查询
  _, err = stmt.Exec(name, price)
  if err != nil {
    return err
  }

  return nil
}

로그인 후 복사

在这段代码中，我们使用Prepare()函数准备一个SQL语句，然后使用Exec()函数执行查询。Exec()函数返回行数和错误信息。如果错误为空，则插入语句成功。

类似的，我们可以使用Query()和Scan()