sql

type BaseSQL struct {
	DB           *sql.DB
	Logger       *log.Logger
	Serializer   *common.ProtoSerializer
	KeyManager   *keymanager.EncryptionKeyManager
	Dialect      SQLDialect
	Clock        *Clock
	StateManager *StateManager
	LeaseRuntime *LeaseRuntimeCalculator
}

type Clock struct{}

type Config struct {
	// Connection pooling
	MaxOpenConns    int
	MaxIdleConns    int
	ConnMaxLifetime int // seconds

	// SQLite-specific
	BusyTimeout int // milliseconds
	WALMode     bool
	Synchronous string // NORMAL, FULL, etc.
}

type LeaseRuntime struct {
	LeaseStartedAt     int64
	LeaseExpiry        int64
	LastHeartbeatAt    int64
	HeartbeatExpiry    int64
	LeaseExtensionUsed int64
}

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

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

type SQLDialect interface {
	// Query syntax
	Placeholder(n int) string          // Positional parameter syntax: $1 (Postgres) vs ? (SQLite/MySQL)
	CurrentTimestamp() string          // CURRENT_TIMESTAMP vs NOW()
	JSONSet() string                   // json_set (SQLite) vs jsonb_set (Postgres)
	JSONSetPath(key string) string     // Path argument for JSONSet
	JSONExtract() string               // json_extract (SQLite) vs jsonb_extract_path_text (Postgres)
	JSONExtractPath(key string) string // Path argument for JSONExtract
	ToJSON(value string) string        // Convert value to JSON: raw value (SQLite) vs to_jsonb() (Postgres)
	UnixMillis(column string) string   // Extract unix milliseconds from timestamp column

	// Type mappings
	BlobType() string      // BLOB vs BYTEA
	TimestampType() string // TIMESTAMP vs TIMESTAMPTZ
	BigIntType() string    // INTEGER vs BIGINT
	JSONType() string      // TEXT vs JSONB

	// Feature support
	SupportsReturning() bool            // RETURNING clause support
	SupportsSkipLocked() bool           // SELECT FOR UPDATE SKIP LOCKED
	SupportsAdvisoryLocks() bool        // Postgres advisory locks
	RequiresSerializableForClaim() bool // Needs SERIALIZABLE isolation for claiming

	// Connection configuration
	SetWALMode() string                 // SQLite: PRAGMA journal_mode=WAL
	SetBusyTimeout(ms int) string       // SQLite: PRAGMA busy_timeout
	SetSynchronous(level string) string // PRAGMA synchronous
}

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

type TxOptions struct {
	Isolation sql.IsolationLevel
	Timeout   time.Duration
	ReadOnly  bool
}