当前位置：首页 > news >正文

Go语言跨平台数据库开发：实现跨平台数据持久化

news 2026/5/28 18:54:51

Go语言跨平台数据库开发：实现跨平台数据持久化

引言

数据持久化是任何应用程序的核心需求。Go语言提供了丰富的数据库驱动和ORM库，支持跨平台数据库开发。本文将深入探讨如何使用Go语言进行跨平台数据库开发，包括SQL和NoSQL数据库的使用。

一、Go语言数据库开发概述

1.1 常用数据库驱动

Go语言支持多种数据库：

// SQL数据库 // github.com/go-sql-driver/mysql - MySQL驱动 // github.com/lib/pq - PostgreSQL驱动 // github.com/mattn/go-sqlite3 - SQLite驱动 // github.com/denisenkom/go-mssqldb - SQL Server驱动 // NoSQL数据库 // go.mongodb.org/mongo-driver/mongo - MongoDB驱动 // github.com/go-redis/redis/v8 - Redis驱动 // github.com/influxdata/influxdb-client-go - InfluxDB驱动

1.2 标准库database/sql

Go语言的database/sql包提供了统一的数据库接口：

import ( "database/sql" _ "github.com/go-sql-driver/mysql" ) func main() { db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/dbname") if err != nil { panic(err) } defer db.Close() }

二、SQLite跨平台数据库

2.1 安装SQLite驱动

go get github.com/mattn/go-sqlite3

2.2 基础操作

package main import ( "database/sql" "fmt" "log" _ "github.com/mattn/go-sqlite3" ) type User struct { ID int Name string Age int } func main() { // 打开SQLite数据库（跨平台，无需额外服务） db, err := sql.Open("sqlite3", "./example.db") if err != nil { log.Fatal(err) } defer db.Close() // 创建表 createTable(db) // 插入数据 insertUser(db, "Alice", 30) insertUser(db, "Bob", 25) // 查询数据 users, err := getUsers(db) if err != nil { log.Fatal(err) } for _, user := range users { fmt.Printf("ID: %d, Name: %s, Age: %d\n", user.ID, user.Name, user.Age) } } func createTable(db *sql.DB) { query := ` CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, age INTEGER ) ` _, err := db.Exec(query) if err != nil { log.Fatal(err) } } func insertUser(db *sql.DB, name string, age int) { query := "INSERT INTO users (name, age) VALUES (?, ?)" result, err := db.Exec(query, name, age) if err != nil { log.Fatal(err) } id, _ := result.LastInsertId() fmt.Printf("Inserted user with ID: %d\n", id) } func getUsers(db *sql.DB) ([]User, error) { query := "SELECT id, name, age FROM users" rows, err := db.Query(query) if err != nil { return nil, err } defer rows.Close() var users []User for rows.Next() { var user User err := rows.Scan(&user.ID, &user.Name, &user.Age) if err != nil { return nil, err } users = append(users, user) } return users, nil }

三、MySQL数据库开发

3.1 安装MySQL驱动

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

3.2 连接池配置

package main import ( "database/sql" "fmt" "time" _ "github.com/go-sql-driver/mysql" ) func main() { // DSN格式: user:password@tcp(host:port)/dbname?charset=utf8mb4&parseTime=True&loc=Local dsn := "root:password@tcp(localhost:3306)/mydb?charset=utf8mb4&parseTime=True&loc=Local" db, err := sql.Open("mysql", dsn) if err != nil { panic(err) } defer db.Close() // 配置连接池 db.SetMaxOpenConns(20) db.SetMaxIdleConns(10) db.SetConnMaxLifetime(30 * time.Minute) db.SetConnMaxIdleTime(10 * time.Minute) // 验证连接 err = db.Ping() if err != nil { panic(err) } fmt.Println("Connected to MySQL successfully!") }

3.3 事务处理

func transferMoney(db *sql.DB, fromID, toID int, amount float64) error { tx, err := db.Begin() if err != nil { return err } defer tx.Rollback() // 扣除余额 _, err = tx.Exec( "UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromID, ) if err != nil { return err } // 增加余额 _, err = tx.Exec( "UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, toID, ) if err != nil { return err } return tx.Commit() }

四、PostgreSQL数据库

4.1 安装PostgreSQL驱动

go get github.com/lib/pq

4.2 使用PostgreSQL特性

package main import ( "database/sql" "fmt" _ "github.com/lib/pq" ) func main() { // DSN格式 dsn := "host=localhost port=5432 user=postgres password=password dbname=mydb sslmode=disable" db, err := sql.Open("postgres", dsn) if err != nil { panic(err) } defer db.Close() // 使用JSONB类型 query := ` CREATE TABLE IF NOT EXISTS documents ( id SERIAL PRIMARY KEY, data JSONB ) ` _, err = db.Exec(query) if err != nil { panic(err) } // 插入JSON数据 jsonData := `{"name": "Alice", "tags": ["admin", "user"]}` _, err = db.Exec("INSERT INTO documents (data) VALUES ($1)", jsonData) if err != nil { panic(err) } fmt.Println("JSON data inserted successfully!") }

五、ORM框架GORM

5.1 安装GORM

go get gorm.io/gorm go get gorm.io/driver/sqlite

5.2 基础用法

package main import ( "fmt" "gorm.io/driver/sqlite" "gorm.io/gorm" ) type Product struct { gorm.Model Name string Price float64 Stock int } func main() { // 连接数据库 db, err := gorm.Open(sqlite.Open("test.db"), &gorm.Config{}) if err != nil { panic("failed to connect database") } // 自动迁移 db.AutoMigrate(&Product{}) // 创建记录 product := Product{Name: "iPhone", Price: 9999.0, Stock: 100} db.Create(&product) fmt.Printf("Created product with ID: %d\n", product.ID) // 查询记录 var p Product db.First(&p, 1) fmt.Printf("Found product: %s, Price: %.2f\n", p.Name, p.Price) // 更新记录 db.Model(&p).Update("Price", 8999.0) // 删除记录 db.Delete(&p) }

5.3 高级查询

func queryExamples(db *gorm.DB) { var products []Product // 查询所有 db.Find(&products) // 条件查询 db.Where("price > ?", 100).Find(&products) // 排序 db.Order("price DESC").Find(&products) // 分页 db.Limit(10).Offset(20).Find(&products) // 关联查询 db.Preload("Orders").Find(&products) // 原生SQL db.Raw("SELECT * FROM products WHERE stock > ?", 0).Scan(&products) }

六、MongoDB开发

6.1 安装MongoDB驱动

go get go.mongodb.org/mongo-driver/mongo

6.2 基础操作

package main import ( "context" "fmt" "log" "time" "go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/bson/primitive" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" ) type User struct { ID primitive.ObjectID `bson:"_id,omitempty"` Name string `bson:"name"` Age int `bson:"age"` } func main() { // 创建客户端 ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() client, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://localhost:27017")) if err != nil { log.Fatal(err) } defer client.Disconnect(ctx) // 获取数据库和集合 db := client.Database("mydb") collection := db.Collection("users") // 插入文档 user := User{Name: "Alice", Age: 30} result, err := collection.InsertOne(ctx, user) if err != nil { log.Fatal(err) } fmt.Printf("Inserted user with ID: %s\n", result.InsertedID) // 查询文档 var foundUser User err = collection.FindOne(ctx, bson.M{"name": "Alice"}).Decode(&foundUser) if err != nil { log.Fatal(err) } fmt.Printf("Found user: %s, Age: %d\n", foundUser.Name, foundUser.Age) }

七、Redis开发

7.1 安装Redis驱动

go get github.com/go-redis/redis/v8

7.2 基础操作

package main import ( "context" "fmt" "time" "github.com/go-redis/redis/v8" ) func main() { // 创建客户端 rdb := redis.NewClient(&redis.Options{ Addr: "localhost:6379", Password: "", // no password set DB: 0, // use default DB }) ctx := context.Background() // 设置键值 err := rdb.Set(ctx, "key", "value", 10*time.Minute).Err() if err != nil { panic(err) } // 获取值 val, err := rdb.Get(ctx, "key").Result() if err != nil { panic(err) } fmt.Printf("key = %s\n", val) // 哈希操作 err = rdb.HSet(ctx, "user:1", "name", "Alice", "age", "30").Err() if err != nil { panic(err) } user, err := rdb.HGetAll(ctx, "user:1").Result() if err != nil { panic(err) } fmt.Printf("User: %v\n", user) }

八、跨平台数据库配置

8.1 多数据库支持

type DatabaseConfig struct { Type string `json:"type"` Host string `json:"host"` Port int `json:"port"` Username string `json:"username"` Password string `json:"password"` Database string `json:"database"` } func NewDatabase(config DatabaseConfig) (*sql.DB, error) { var dsn string switch config.Type { case "mysql": dsn = fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=utf8mb4&parseTime=True", config.Username, config.Password, config.Host, config.Port, config.Database) return sql.Open("mysql", dsn) case "postgres": dsn = fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable", config.Host, config.Port, config.Username, config.Password, config.Database) return sql.Open("postgres", dsn) case "sqlite": return sql.Open("sqlite3", config.Database) default: return nil, fmt.Errorf("unsupported database type: %s", config.Type) } }

8.2 数据库迁移

package main import ( "database/sql" "log" ) type Migration struct { Version int Up string Down string } var migrations = []Migration{ { Version: 1, Up: `CREATE TABLE users ( id INTEGER PRIMARY KEY, name TEXT NOT NULL )`, Down: `DROP TABLE users`, }, { Version: 2, Up: `ALTER TABLE users ADD COLUMN age INTEGER`, Down: `ALTER TABLE users DROP COLUMN age`, }, } func runMigrations(db *sql.DB) error { // 创建迁移记录表 _, err := db.Exec(` CREATE TABLE IF NOT EXISTS migrations ( version INTEGER PRIMARY KEY ) `) if err != nil { return err } // 获取当前版本 var currentVersion int err = db.QueryRow("SELECT version FROM migrations ORDER BY version DESC LIMIT 1").Scan(&currentVersion) if err == sql.ErrNoRows { currentVersion = 0 } else if err != nil { return err } // 执行迁移 for _, migration := range migrations { if migration.Version > currentVersion { log.Printf("Applying migration %d...\n", migration.Version) _, err := db.Exec(migration.Up) if err != nil { return err } _, err = db.Exec("INSERT INTO migrations (version) VALUES (?)", migration.Version) if err != nil { return err } } } return nil }

九、数据库最佳实践

9.1 连接池管理

func setupConnectionPool(db *sql.DB) { db.SetMaxOpenConns(20) db.SetMaxIdleConns(10) db.SetConnMaxLifetime(30 * time.Minute) db.SetConnMaxIdleTime(10 * time.Minute) }

9.2 查询优化

// 使用预编译语句 stmt, err := db.Prepare("SELECT * FROM users WHERE id = ?") if err != nil { panic(err) } defer stmt.Close() rows, err := stmt.Query(1)

9.3 错误处理

func getUser(db *sql.DB, id int) (*User, error) { var user User err := db.QueryRow("SELECT id, name, age FROM users WHERE id = ?", id). Scan(&user.ID, &user.Name, &user.Age) if err == sql.ErrNoRows { return nil, fmt.Errorf("user not found") } if err != nil { return nil, fmt.Errorf("failed to query user: %w", err) } return &user, nil }