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:

Copy

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

Kế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:

Copy

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:

Copy

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:

Copy

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

Copy

// 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

Copy

// 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

Copy

// 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

Hướng dẫn chi tiết sử dụng Go Lang để kết nối và thao tác với PostgreSQL và MySQL

Giới thiệu

Cài đặt driver cho PostgreSQL và MySQL

Kết nối đến cơ sở dữ liệu PostgreSQL và MySQL

Thao tác với cơ sở dữ liệu PostgreSQL và MySQL

Kết luận

Bình luận