BaseSQL - 飞书多维表格 GORM Driver

package main

import (
    "log"
    "time"
    
    basesql "github.com/ag9920/basesql"
    "gorm.io/gorm"
)

// 定义数据模型
type User struct {
    ID        string    `gorm:"primarykey"`
    Name      string    `gorm:"size:100"`
    Email     string    `gorm:"size:100"`
    Age       int
    Active    bool      `gorm:"default:true"`
    CreatedAt time.Time `gorm:"autoCreateTime"`
    UpdatedAt time.Time `gorm:"autoUpdateTime"`
}

func main() {
    // 配置连接
    config := &basesql.Config{
        AppID:     "your_app_id",     // 替换为你的 App ID
        AppSecret: "your_app_secret", // 替换为你的 App Secret
        AppToken:  "your_app_token",  // 替换为你的多维表格 App Token
        AuthType:  basesql.AuthTypeTenant,
        DebugMode: true,             // 开发时建议开启调试模式
    }

    // 连接数据库
    db, err := gorm.Open(basesql.Open(config), &gorm.Config{})
    if err != nil {
        log.Fatalf("failed to connect database: %v", err)
    }

    // 自动迁移
    if err := db.AutoMigrate(&User{}); err != nil {
        log.Fatalf("failed to migrate database: %v", err)
    }

    // 创建记录
    user := &User{
        Name:  "张三",
        Email: "zhangsan@example.com",
        Age:   25,
    }
    
    if err := db.Create(user).Error; err != nil {
        log.Fatalf("failed to create user: %v", err)
    }
    
    log.Printf("Created user: %+v", user)

    // 查询记录
    var users []User
    if err := db.Where("age > ?", 20).Find(&users).Error; err != nil {
        log.Fatalf("failed to query users: %v", err)
    }
    
    log.Printf("Found %d users", len(users))

    // 更新记录
    if err := db.Model(user).Update("age", 26).Error; err != nil {
        log.Fatalf("failed to update user: %v", err)
    }

    // 删除记录
    if err := db.Delete(user).Error; err != nil {
        log.Fatalf("failed to delete user: %v", err)
    }
}

config := &basesql.Config{
    AppID:     "your_app_id",
    AppSecret: "your_app_secret",
    AppToken:  "your_app_token",
    AuthType:  basesql.AuthTypeTenant,
}

config := &basesql.Config{
    AppID:       "your_app_id",
    AppSecret:   "your_app_secret",
    AppToken:    "your_app_token",
    AuthType:    basesql.AuthTypeUser,
    AccessToken: "your_user_token", // 用户访问令牌
}

// 文本字段操作
db.Where("name = ?", "张三")
db.Where("name LIKE ?", "%张%")
db.Where("name IN ?", []string{"张三", "李四"})
db.Where("name IS NULL")

// 数字字段操作
db.Where("age = ?", 25)
db.Where("age > ?", 18)
db.Where("salary >= ?", 5000.0)
db.Where("age IN ?", []int{25, 30, 35})

// 布尔字段操作
db.Where("active = ?", true)
db.Where("active = ?", false)
db.Where("active IS NULL")

// 日期字段操作
db.Where("created_at > ?", time.Now().AddDate(0, -1, 0))
db.Where("birth_date IS NOT NULL")

// 多选字段操作
db.Where("skills IN ?", []string{"Go", "Python"})

// 人员字段操作
db.Where("manager = ?", "张三")
db.Where("manager IN ?", []string{"张三", "李四"})

type Config struct {
    // 飞书应用配置
    AppID     string        // 飞书应用 ID
    AppSecret string        // 飞书应用密钥
    BaseURL   string        // API 基础 URL（可选，默认为官方 API）
    
    // 认证配置
    AuthType    AuthType      // 认证类型
    AccessToken string        // 用户访问令牌（用户认证时需要）
    
    // 多维表格配置
    AppToken string        // 多维表格 App Token
    TableID  string        // 默认表 ID（可选）
    
    // 连接配置
    Timeout         time.Duration // 请求超时时间（可选，默认 30 秒）
    MaxRetries      int           // 最大重试次数
    RetryInterval   time.Duration // 重试间隔
    RateLimitQPS    int           // 每秒请求限制
    BatchSize       int           // 批量操作大小
    CacheEnabled    bool          // 是否启用缓存
    CacheTTL        time.Duration // 缓存过期时间
    DebugMode       bool          // 调试模式（可选，开启后会打印详细日志）
    ConsistencyMode bool          // 一致性模式
    
    // 稳定性配置
    CircuitBreakerEnabled    bool          // 是否启用熔断器
    CircuitBreakerThreshold  int           // 熔断器失败阈值
    CircuitBreakerTimeout    time.Duration // 熔断器超时时间
    ConnectionPoolSize       int           // 连接池大小
    ConnectionPoolMaxIdle    int           // 连接池最大空闲连接数
    ConnectionPoolIdleTimeout time.Duration // 连接池空闲超时时间
    RateLimiterEnabled       bool          // 是否启用限流器
    RateLimiterBurst         int           // 限流器突发容量
}

// 获取熔断器统计信息
stats := client.GetStabilityStats()
log.Printf("熔断器状态: %s, 失败次数: %d", stats.CircuitBreakerState, stats.CircuitBreakerFailures)

// 重置熔断器
client.ResetStabilityComponents()

// 更新连接池配置
newPoolConfig := &common.ConnectionPoolConfig{
    MaxConnections:    50,
    MaxIdleConns:      10,
    IdleConnTimeout:   time.Minute * 5,
    MaxConnLifetime:   time.Minute * 30,
}
client.UpdateConnectionPoolConfig(newPoolConfig)

// 更新限流器配置
newRateConfig := &common.RateLimiterConfig{
    Rate:       10,    // 每秒 10 个请求
    Burst:      20,    // 突发容量 20
    Enabled:    true,
}
client.UpdateRateLimiterConfig(newRateConfig)

// 执行健康检查
if err := client.HealthCheck(); err != nil {
    log.Printf("健康检查失败: %v", err)
} else {
    log.Println("系统运行正常")
}

stats := client.GetStabilityStats()
log.Printf("统计信息: %+v", stats)
// 输出包括：
// - 熔断器状态和统计
// - 连接池使用情况
// - 限流器统计
// - 请求成功/失败次数
// - 平均响应时间等

if err := db.Create(&user).Error; err != nil {
    if basesql.IsPermissionError(err) {
        log.Println("权限不足，请检查应用权限配置")
        // 可能需要重新配置应用权限或检查 App Token
    } else if basesql.IsRetryableError(err) {
        log.Println("网络错误，可以重试")
        // 可以实现重试逻辑
        time.Sleep(time.Second)
        // 重试操作...
    } else {
        log.Printf("其他错误: %v", err)
        // 处理其他类型的错误
    }
}