シャーディング

SQLパーサーと置換を使用してシャーディングプラグインは、大きなテーブルを小さなテーブルに分割し、クエリをシャーディングテーブルにリダイレクトします。高性能なデータベースアクセスを提供します。

https://github.com/go-gorm/sharding

機能

• 非侵入型設計。プラグインをロードし、設定を指定するだけで完了です。
• 超高速。ネットワークベースのミドルウェアはなく、Goと同じくらい高速です。
• 複数のデータベースをサポート。PostgreSQLはテスト済み、MySQLとSQLiteは近日公開予定です。
• プライマリキーのジェネレーターをカスタマイズできます（組み込みのkeygen、Sequence、Snowflakeなど）。

使用方法

シャーディングミドルウェアを設定し、シャード化するテーブルを登録します。設定の詳細については、Godocを参照してください。

import (
  "fmt"

  "gorm.io/driver/postgres"
  "gorm.io/gorm"
  "gorm.io/sharding"
)

dsn := "postgres://:5432/sharding-db?sslmode=disable"
db, err := gorm.Open(postgres.New(postgres.Config{DSN: dsn}))

db.Use(sharding.Register(sharding.Config{
    ShardingKey:         "user_id",
    NumberOfShards:      64,
    PrimaryKeyGenerator: sharding.PKSnowflake,
}, "orders").Register(sharding.Config{
    ShardingKey:         "user_id",
    NumberOfShards:      256,
    PrimaryKeyGenerator: sharding.PKSnowflake,
    // This case for show up give notifications, audit_logs table use same sharding rule.
}, Notification{}, AuditLog{}))

通常どおりdbセッションを使用します。シャーディングテーブルを操作する場合は、クエリに`シャーディングキー`を含める必要があることに注意してください。

// Gorm create example, this will insert to orders_02
db.Create(&Order{UserID: 2})
// sql: INSERT INTO orders_2 ...

// Show have use Raw SQL to insert, this will insert into orders_03
db.Exec("INSERT INTO orders(user_id) VALUES(?)", int64(3))

// This will throw ErrMissingShardingKey error, because there not have sharding key presented.
db.Create(&Order{Amount: 10, ProductID: 100})
fmt.Println(err)

// Find, this will redirect query to orders_02
var orders []Order
db.Model(&Order{}).Where("user_id", int64(2)).Find(&orders)
fmt.Printf("%#v\n", orders)

// Raw SQL also supported
db.Raw("SELECT * FROM orders WHERE user_id = ?", int64(3)).Scan(&orders)
fmt.Printf("%#v\n", orders)

// This will throw ErrMissingShardingKey error, because WHERE conditions not included sharding key
err = db.Model(&Order{}).Where("product_id", "1").Find(&orders).Error
fmt.Println(err)

// Update and Delete are similar to create and query
db.Exec("UPDATE orders SET product_id = ? WHERE user_id = ?", 2, int64(3))
err = db.Exec("DELETE FROM orders WHERE product_id = 3").Error
fmt.Println(err) // ErrMissingShardingKey

完全な例はこちらです。