// 手动分片逻辑示例
func getShardDB(userID int) *gorm.DB {
    dbIndex := userID % 4
    dsn := fmt.Sprintf("user:pwd@tcp(db-%d:3306)/user_db_%d", dbIndex, dbIndex)
    db, _ := gorm.Open(mysql.Open(dsn), &gorm.Config{})
    return db.Table(fmt.Sprintf("users_%d", userID/4%4))
}

顶

Top

收藏

关注

评论