database

type DatabaseConfig struct {
	*registry.ServiceConfig

	// Database-specific settings
	SSLMode          string `yaml:"ssl_mode" json:"ssl_mode"`
	ApplicationName  string `yaml:"application_name" json:"application_name"`
	SearchPath       string `yaml:"search_path" json:"search_path"`
	StatementTimeout int    `yaml:"statement_timeout" json:"statement_timeout"`
	LockTimeout      int    `yaml:"lock_timeout" json:"lock_timeout"`

	// Connection pool settings
	MaxOpenConns    int           `yaml:"max_open_conns" json:"max_open_conns"`
	MaxIdleConns    int           `yaml:"max_idle_conns" json:"max_idle_conns"`
	ConnMaxLifetime time.Duration `yaml:"conn_max_lifetime" json:"conn_max_lifetime"`
	ConnMaxIdleTime time.Duration `yaml:"conn_max_idle_time" json:"conn_max_idle_time"`

	// Replication settings
	Role             string   `yaml:"role" json:"role"` // "primary" or "replica"
	ReplicationSlots []string `yaml:"replication_slots" json:"replication_slots"`
}

type DatabaseFactory struct {
	// contains filtered or unexported fields
}

type DatabasePool struct {
	// contains filtered or unexported fields
}

type DatabaseService interface {
	registry.ServiceInterface

	// Database operations
	Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row
	Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

	// Transaction support
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

	// Connection pool management
	GetDB() *sql.DB
	SetMaxOpenConns(n int)
	SetMaxIdleConns(n int)
	SetConnMaxLifetime(d time.Duration)

	// Migration support
	RunMigrations(ctx context.Context, migrationsPath string) error
	GetSchemaVersion() (int, error)

	// Backup and restore
	Backup(ctx context.Context, path string) error
	Restore(ctx context.Context, path string) error
}

type LoadBalanceStrategy string

type MySQLService struct {
	// contains filtered or unexported fields
}

type PostgresService struct {
	// contains filtered or unexported fields
}

type QueryBuilder interface {
	Select(columns ...string) QueryBuilder
	From(table string) QueryBuilder
	Where(condition string, args ...interface{}) QueryBuilder
	Join(joinType, table, condition string) QueryBuilder
	GroupBy(columns ...string) QueryBuilder
	Having(condition string, args ...interface{}) QueryBuilder
	OrderBy(column string, desc bool) QueryBuilder
	Limit(limit int) QueryBuilder
	Offset(offset int) QueryBuilder
	Build() (string, []interface{})
}