Giới thiệu
Go Lang (hay Golang) là một ngôn ngữ lập trình được phát triển bởi Google, nổi bật với tốc độ xử lý nhanh, cú pháp đơn giản và khả năng bảo trì dễ dàng. Trong bài viết này, chúng ta sẽ tìm hiểu cách sử dụng Go Lang để kết nối và tương tác với hai hệ quản trị cơ sở dữ liệu phổ biến là PostgreSQL và MySQL.
Cài đặt driver cho PostgreSQL và MySQL
Trước khi tiến hành lập trình, bạn cần cài đặt các driver cần thiết để Go Lang có khả năng kết nối tới PostgreSQL và MySQL. Đối với PostgreSQL, chúng ta sử dụng driver từ thư viện github.com/lib/pq, và đối với MySQL, driver là github.com/go-sql-driver/mysql. Để cài đặt các driver này, hãy sử dụng các lệnh sau trong terminal:
go get github.com/lib/pq
go get github.com/go-sql-driver/mysqlKết nối đến cơ sở dữ liệu PostgreSQL và MySQL
Sau khi đã cài đặt drivers, bước tiếp theo là kết nối đến cơ sở dữ liệu. Đầu tiên, bạn cần import các gói cần thiết trong tệp Go:
import (
"database/sql"
"fmt"
"log"
_ "github.com/lib/pq"
_ "github.com/go-sql-driver/mysql"
)Tiếp theo, hãy dùng hàm sql.Open() để thiết lập kết nối tới cơ sở dữ liệu PostgreSQL và MySQL. Dưới đây là đoạn mã mẫu thể hiện cách kết nối tới từng loại cơ sở dữ liệu:
func main() {
// Kết nối PostgreSQL
pgDB, err := sql.Open("postgres", "host=localhost port=5432 user=postgres password=your_password dbname=your_database sslmode=disable")
if err != nil {
log.Fatal(err)
}
defer pgDB.Close()
// Kết nối MySQL
mysqlDB, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/your_database")
if err != nil {
log.Fatal(err)
}
defer mysqlDB.Close()
// Kiểm tra kết nối thành công
err = pgDB.Ping()
if err != nil {
log.Fatal(err)
}
err = mysqlDB.Ping()
if err != nil {
log.Fatal(err)
}
fmt.Println("Kết nối thành công")
}Trong đoạn mã trên, bạn hãy thay đổi thông tin kết nối như host, port, user, password và dbname sao cho phù hợp với cấu hình cơ sở dữ liệu của bạn. Đặc biệt, hãy chắc chắn rằng thông tin kết nối đã chính xác để đảm bảo quá trình kết nối thành công.
Khi kết nối thành công, sẽ có thông báo Kết nối thành công. Nếu xuất hiện lỗi, hãy kiểm tra lại các thông tin đã nhập nhé.
Thao tác với cơ sở dữ liệu PostgreSQL và MySQL
Khi đã kết nối thành công tới cơ sở dữ liệu, bạn có thể thực hiện các thao tác như truy vấn, chèn, cập nhật và xóa dữ liệu. Dưới đây là ví dụ thao tác truy vấn dữ liệu từ cơ sở dữ liệu PostgreSQL và MySQL:
func main() {
// Kết nối PostgreSQL
pgDB, err := sql.Open("postgres", "host=localhost port=5432 user=postgres password=your_password dbname=your_database sslmode=disable")
if err != nil {
log.Fatal(err)
}
defer pgDB.Close()
// Truy vấn dữ liệu từ PostgreSQL
rows, err := pgDB.Query("SELECT id, email FROM users ORDER BY id LIMIT 10")
if err != nil {
log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
var id int
var email string
err := rows.Scan(&id, &email)
if err != nil {
log.Fatal(err)
}
fmt.Println("ID:", id, "Email:", email)
}
// Kết nối MySQL
mysqlDB, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/your_database")
if err != nil {
log.Fatal(err)
}
defer mysqlDB.Close()
// Truy vấn dữ liệu từ MySQL
rows, err = mysqlDB.Query("SELECT id, email FROM users ORDER BY id LIMIT 10")
if err != nil {
log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
var id int
var email string
err := rows.Scan(&id, &email)
if err != nil {
log.Fatal(err)
}
fmt.Println("ID:", id, "Email:", email)
}
}Trong đoạn mã trên, chúng ta sử dụng hàm Query() để lấy dữ liệu từ bảng users trong cơ sở dữ liệu PostgreSQL và MySQL. Sau đó, với hàm Scan(), chúng ta có thể đọc và hiển thị các kết quả truy vấn ra màn hình.
Ngoài ra, chúng ta có thể sử dụng các hàm như Exec() để thực hiện các thao tác thêm mới, cập nhật và xóa dữ liệu. Dưới đây là ví dụ cho từng thao tác:
Thêm mới dữ liệu
// Thêm mới dữ liệu vào PostgreSQL
_, err = pgDB.Exec("INSERT INTO users (name, email) VALUES ($1, $2)", "Nguyen Van A", "nguyen.van.a@example.com")
if err != nil {
log.Fatal(err)
}
// Thêm mới dữ liệu vào MySQL
_, err = mysqlDB.Exec("INSERT INTO users (name, email) VALUES (?, ?)", "Nguyen Van A", "nguyen.van.a@example.com")
if err != nil {
log.Fatal(err)
}Cập nhật dữ liệu
// Cập nhật dữ liệu trong PostgreSQL
_, err = pgDB.Exec("UPDATE users SET email = $1 WHERE id = $2", "new_email@example.com", 1)
if err != nil {
log.Fatal(err)
}
// Cập nhật dữ liệu trong MySQL
_, err = mysqlDB.Exec("UPDATE users SET email = ? WHERE id = ?", "new_email@example.com", 1)
if err != nil {
log.Fatal(err)
}Xóa dữ liệu
// Xóa dữ liệu từ PostgreSQL
_, err = pgDB.Exec("DELETE FROM users WHERE id = $1", 1)
if err != nil {
log.Fatal(err)
}
// Xóa dữ liệu từ MySQL
_, err = mysqlDB.Exec("DELETE FROM users WHERE id = ?", 1)
if err != nil {
log.Fatal(err)
}Trong các ví dụ trên, chúng ta đã sử dụng hàm Exec() để thực hiện các câu lệnh SQL như INSERT, UPDATE và DELETE. Hãy nhớ sử dụng các tham số xác định $1, $2, ... cho PostgreSQL và ?, ?, ... cho MySQL.
Kết luận
Trong bài viết này, chúng ta đã tìm hiểu cách sử dụng Go Lang để tương tác với cơ sở dữ liệu PostgreSQL và MySQL. Cụ thể, chúng ta đã cài đặt driver, thiết lập kết nối và thực hiện các thao tác tương tác với dữ liệu. Sự kết hợp giữa Go Lang và các driver hỗ trợ giúp quá trình làm việc với cơ sở dữ liệu diễn ra dễ dàng và hiệu quả hơn.
Hy vọng rằng bài viết này đã cung cấp cho bạn những kiến thức bổ ích về cách sử dụng Go Lang trong tương tác với hệ quản trị cơ sở dữ liệu PostgreSQL và MySQL.
source: viblo
