분산 시스템에서 데이터베이스는 매우 중요한 역할을 합니다. 대규모 분산 시스템의 경우 애플리케이션 요구 사항을 충족하기 위해 분할 상환 처리를 위해 여러 데이터베이스를 사용해야 하는 경우가 많습니다. 널리 사용되는 관계형 데이터베이스인 MySQL은 Go 언어를 통해 여러 인스턴스를 연결하고 관리하여 고가용성, 고성능 분산 시스템을 구축할 수 있습니다.
이 글에서는 Go 언어를 사용하여 분산 MySQL 데이터베이스에 연결하는 방법을 다음 부분으로 나누어 설명합니다.
1. Go 언어 설치
2. MySQL 데이터베이스 연결
4. 여러 예제를 관리하려면
5. 분산 트랜잭션 사용
go get -u github.com/go-sql-driver/mysql
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" ) func main() { //连接MySQL数据库 db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test") if err != nil { panic(err.Error()) } defer db.Close() //查询MySQL数据库中的数据 rows, err := db.Query("SELECT * from user") if err != nil { panic(err.Error()) } defer rows.Close() //遍历查询结果 for rows.Next() { var id int var name string if err := rows.Scan(&id, &name); err != nil { panic(err.Error()) } fmt.Printf("id: %d, name: %s ", id, name) } }
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "sync" ) var dbMap = sync.Map{} func getDBInstance(addr string) (*sql.DB, error) { var ( db *sql.DB err error ) //从连接池中获取数据库实例 if val, ok := dbMap.Load(addr); ok { db = val.(*sql.DB) return db, nil } //创建新的数据库实例 db, err = sql.Open("mysql", "root:123456@"+addr+"/test") if err != nil { return nil, err } //将新的数据库实例加入连接池中 dbMap.Store(addr, db) return db, nil } //查询数据库中数据 func query(addr string) { db, err := getDBInstance(addr) if err != nil { panic(err) } rows, err := db.Query("SELECT * from user") if err != nil { panic(err) } defer rows.Close() for rows.Next() { var id int var name string if err := rows.Scan(&id, &name); err != nil { panic(err) } fmt.Printf("id:%d name:%s ", id, name) } } func main() { addrList := []string{"127.0.0.1:3306", "127.0.0.1:3307"} for _, addr := range addrList { go query(addr) } select {} }
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "sync" ) var dbMap = sync.Map{} func getDBInstance(addr string) (*sql.DB, error) { var ( db *sql.DB err error ) if val, ok := dbMap.Load(addr); ok { db = val.(*sql.DB) return db, nil } db, err = sql.Open("mysql", "root:123456@"+addr+"/test") if err != nil { return nil, err } dbMap.Store(addr, db) return db, nil } func transfer(fromDB, toDB string, amount int) error { tx, err := getDBInstance(fromDB).Begin() //开始事务 if err != nil { return err } defer tx.Rollback() //回滚事务 //从fromDB转移amount到toDB _, err = tx.Exec("UPDATE account SET balance=balance-? WHERE id=1", amount) if err != nil { return err } _, err = getDBInstance(toDB).Exec("UPDATE account SET balance=balance+? WHERE id=2", amount) if err != nil { return err } err = tx.Commit() //提交事务 if err != nil { tx.Rollback() return err } return nil } func main() { err := transfer("127.0.0.1:3306", "127.0.0.1:3307", 100) if err != nil { fmt.Println(err) } else { fmt.Println("transfer success") } }
위 내용은 Go 언어를 사용하여 분산 MySQL 데이터베이스에 연결하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!