인터넷의 급속한 발전과 함께 비관계형 데이터베이스(NoSQL)가 점점 더 널리 사용되고 있으며, Go 언어에도 데이터를 처리하는 비관계형 방식이 있습니다. 그러나 MySQL과 같은 일부 기존 관계형 데이터베이스의 경우 일부 기술을 사용하여 비관계형 데이터 처리 기능을 구현할 수도 있습니다.
이 기사에서는 비관계형 테이블을 생성 및 설계하는 방법을 포함하여 MySQL을 사용하여 Go 언어로 비관계형 데이터 처리를 구현하는 방법과 기술을 소개하고 데이터를 읽고 쓰고 갱신하는 방법을 예제를 통해 보여줍니다. . 이 프로세스에서는 github.com/go-sql-driver/mysql 라이브러리 중 하나를 사용합니다.
1. 비관계형 테이블 만들기
MySQL 데이터베이스의 경우 일반적으로 관계형 데이터베이스라고 생각하기 때문에 테이블을 설계하고 테이블 간의 관계를 유지해야 합니다. 그러나 때로는 JSON 형식 데이터와 같은 비관계형 구조로 데이터를 저장해야 하는 경우도 있습니다.
MySQL에서는 JSON 유형 필드를 사용하여 비관계형 저장소를 구현할 수 있습니다. 예를 들어, 사용자의 개인 정보를 저장하기 위한 JSON 유형 필드 "info"가 포함된 사용자 정보를 저장하는 테이블을 생성합니다.
CREATE TABLE users ( id INT(11) NOT NULL AUTO_INCREMENT, name VARCHAR(50) NOT NULL, info JSON NOT NULL, PRIMARY KEY (id) );
위 코드에서는 "users"라는 테이블을 생성합니다. 여기에는 세 개의 필드가 포함됩니다. 아이디, 이름, 정보입니다. 정보 필드의 유형은 사용자의 개인 정보를 저장하는 데 사용되는 JSON입니다. 실제 응용 프로그램에서는 BLOB, TEXT 등과 같은 다른 비관계형 유형을 사용할 수도 있습니다.
2. Go 언어를 사용하여 MySQL 데이터베이스에 연결
Go 언어로 MySQL 데이터베이스에 연결하려면 타사 라이브러리를 사용해야 하며, 가장 일반적으로 사용되는 라이브러리는 github.com/go-sql-driver/mysql입니다. 먼저 다음 명령을 통해 설치할 수 있는 이 라이브러리를 설치해야 합니다.
go get github.com/go-sql-driver/mysql
이 라이브러리는 데이터베이스 연결 및 작업에 사용할 수 있는 sql.DB 유형을 제공합니다. 데이터베이스에 연결하기 전에 다음과 같은 몇 가지 구성 정보를 제공해야 합니다.
dsn := "root:password@(127.0.0.1:3306)/database_name?charset=utf8mb4&parseTime=True&loc=Local"
db, err := sql.Open("mysql", dsn)
if err != nil {
panic(err)
}
defer db.Close()dsn은 데이터베이스에 연결하는 데 사용되는 데이터 소스 이름입니다. 여기에는 사용자 이름, 비밀번호, 호스트 주소, 포트 번호, 데이터베이스 이름, 인코딩 방법 및 기타 정보가 포함됩니다. 위 코드에서는 로컬 호스트 주소와 기본 3306 포트 번호를 사용하고 사용자 이름과 비밀번호를 해당 값으로 바꿉니다. 연결이 성공하면 db 변수에는 연결한 MySQL 데이터베이스에 대한 참조가 포함됩니다.
3. 비관계형 데이터를 읽고 쓰는 Go 언어
MySQL 데이터베이스에 연결한 후 sql.DB 유형을 사용하여 SQL 쿼리를 실행하고 관련 데이터를 얻을 수 있습니다. 비관계형 데이터의 경우 MySQL의 JSON 함수를 사용하여 JSON 유형 필드를 읽고 쓸 수 있습니다.
다음 코드는 사용자 테이블에 새 사용자 정보를 쓰는 방법을 보여줍니다.
info := `{
"age": 23,
"gender": "male",
"email": "john@example.com"
}`
result, err := db.Exec("INSERT INTO users(name, info) VALUES(?, ?)", "John", info)
if err != nil {
panic(err)
}
fmt.Printf("New user id: %d
", result.LastInsertId())이 예에서는 먼저 사용자 정보 문자열이 포함된 JSON 문자를 정의합니다. 그런 다음 Exec 함수를 사용하여 insert 문을 실행하고 사용자 정보를 매개 변수로 SQL 문에 전달합니다. 삽입이 성공하면 새 사용자의 ID를 얻어 출력합니다.
다음으로 비관계형 필드에 저장된 JSON 데이터를 읽는 방법을 보여드리겠습니다. MySQL의 JSON_EXTRACT 함수를 사용하여 JSON에서 키-값 쌍을 간단히 얻을 수 있습니다. 다음 코드는 users 테이블의 모든 사용자 정보를 읽는 방법을 보여줍니다.
rows, err := db.Query("SELECT * FROM users")
if err != nil {
panic(err)
}
defer rows.Close()
for rows.Next() {
var id int
var name string
var info []byte
err := rows.Scan(&id, &name, &info)
if err != nil {
panic(err)
}
var user map[string]interface{}
err = json.Unmarshal(info, &user)
if err != nil {
panic(err)
}
fmt.Printf("ID: %d, Name: %s, Age: %f, Gender: %s, Email: %s
", id, name, user["age"], user["gender"], user["email"])
}이 예에서는 먼저 db.Query 함수를 사용하여 users 테이블의 모든 데이터를 쿼리합니다. 그런 다음 행.Scan 함수를 사용하여 각 데이터 행의 ID, 이름 및 정보 필드를 읽습니다. 다음으로, info 필드의 값을 map[string]interface{} 유형의 사용자 변수로 변환하고 구문 분석을 위해 json.Unmarshal 함수를 사용합니다. 마지막으로 각 사용자의 ID, 이름, 나이, 성별, 이메일을 출력합니다.
마지막으로 비관계형 필드에 저장된 데이터를 업데이트하는 방법을 보여줍니다. MySQL의 JSON_SET 함수를 사용하여 JSON 필드의 키-값 쌍을 동적으로 업데이트할 수 있습니다. 아래 코드는 사용자의 이메일 주소를 새 값으로 업데이트하는 방법을 보여줍니다.
result, err := db.Exec("UPDATE users SET info=JSON_SET(info, '$.email', ?) WHERE name=?", "john_doe@example.com", "John")
if err != nil {
panic(err)
}
rowsAffected, err := result.RowsAffected()
if err != nil {
panic(err)
}
fmt.Printf("Rows affected: %d
", rowsAffected)이 예에서는 Exec 함수를 사용하여 업데이트 문을 실행하고 새 이메일 주소를 SQL 문의 JSON_SET 함수에 매개 변수로 전달합니다. . WHERE 절을 사용하여 업데이트할 사용자의 이름을 지정합니다. 업데이트가 성공하면 영향을 받은 행 수를 확인하고 출력합니다.
4. 요약
Go 언어에서는 MySQL 데이터베이스를 사용하여 비관계형 데이터를 저장할 수 있습니다. JSON 유형의 필드를 사용하면 데이터를 JSON 형식으로 쉽게 저장하고 처리할 수 있습니다. 이 문서에서는 비관계형 테이블 생성, MySQL 데이터베이스 연결, 비관계형 데이터 읽기 및 쓰기를 위한 방법과 기술, 데이터 작업을 위한 JSON_EXTRACT 및 JSON_SET 함수 사용 예를 소개합니다. 실제 애플리케이션에서 MySQL을 사용하여 비관계형 데이터를 더 잘 처리하는 데 도움이 될 수 있습니다.
위 내용은 Go 언어에서 MySQL을 사용하여 비관계형 데이터 처리 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
