adapters

type Adapter interface {

	// Connect устанавливает подключение к БД
	Connect(ctx context.Context, cfg Config) error

	// Close закрывает подключение к БД
	Close(ctx context.Context) error

	// Ping проверяет доступность БД
	Ping(ctx context.Context) error

	// ExportTable экспортирует всю таблицу в TDTP пакеты
	ExportTable(ctx context.Context, tableName string) ([]*packet.DataPacket, error)

	// ExportTableWithQuery экспортирует таблицу с фильтрацией через TDTQL
	ExportTableWithQuery(
		ctx context.Context,
		tableName string,
		query *packet.Query,
		sender, recipient string,
	) ([]*packet.DataPacket, error)

	// ExportTableIncremental экспортирует только измененные записи с момента последней синхронизации
	// Использует IncrementalConfig для отслеживания изменений
	// Возвращает пакеты и последнее значение tracking поля для следующей синхронизации
	ExportTableIncremental(
		ctx context.Context,
		tableName string,
		incrementalConfig IncrementalConfig,
	) ([]*packet.DataPacket, string, error)

	// ImportPacket импортирует один TDTP пакет в БД
	ImportPacket(ctx context.Context, pkt *packet.DataPacket, strategy ImportStrategy) error

	// ImportPackets импортирует множество пакетов атомарно (в одной транзакции)
	ImportPackets(ctx context.Context, packets []*packet.DataPacket, strategy ImportStrategy) error

	// GetTableSchema возвращает схему таблицы в формате TDTP
	GetTableSchema(ctx context.Context, tableName string) (packet.Schema, error)

	// GetTableNames возвращает список всех таблиц в БД
	GetTableNames(ctx context.Context) ([]string, error)

	// GetViewNames возвращает список всех views в БД с информацией об updatable/read-only
	GetViewNames(ctx context.Context) ([]ViewInfo, error)

	// TableExists проверяет существование таблицы
	TableExists(ctx context.Context, tableName string) (bool, error)

	// BeginTx начинает транзакцию
	BeginTx(ctx context.Context) (Tx, error)

	// GetDatabaseVersion возвращает версию СУБД
	GetDatabaseVersion(ctx context.Context) (string, error)

	// GetDatabaseType возвращает тип СУБД: "sqlite", "postgres", "mssql"
	GetDatabaseType() string

	// InspectTable returns extended metadata for a live DB table:
	// native column types, FK relationships, row count, and a sample record.
	// Unlike GetTableSchema (which returns TDTP-typed schema),
	// InspectTable is optimized for agentic discovery — it reveals the
	// "raw" database view of a table without any TDTP abstraction.
	InspectTable(ctx context.Context, tableName string) (*TableReport, error)
}

type AdapterConstructor func() Adapter

type ColumnInfo struct {
	Name         string       // Имя колонки
	Type         string       // SQL тип
	TDTPField    packet.Field // TDTP представление
	Nullable     bool         // Допускает NULL
	DefaultValue *string      // Значение по умолчанию
	IsPrimaryKey bool         // Является ли Primary Key
	IsAutoIncr   bool         // Auto increment/SERIAL
	Comment      string       // Комментарий (если поддерживается)
}

type ColumnReport struct {
	Name       string `yaml:"name" json:"name"`
	NativeType string `yaml:"native_type" json:"native_type"`
	TDTPType   string `yaml:"tdtp_type" json:"tdtp_type"`
	Nullable   bool   `yaml:"nullable" json:"nullable"`
	PrimaryKey bool   `yaml:"primary_key" json:"primary_key"`
	Identity   bool   `yaml:"identity,omitempty" json:"identity,omitempty"`   // auto-increment / IDENTITY column
	Computed   bool   `yaml:"computed,omitempty" json:"computed,omitempty"`   // computed / generated column
	Default    string `yaml:"default,omitempty" json:"default,omitempty"`     // default expression; empty if none
	Length     int    `yaml:"length,omitempty" json:"length,omitempty"`       // char/varchar max length
	Precision  int    `yaml:"precision,omitempty" json:"precision,omitempty"` // numeric precision
	Scale      int    `yaml:"scale,omitempty" json:"scale,omitempty"`         // numeric scale
}

type Config struct {
	// Type - тип СУБД: "sqlite", "postgres", "mssql"
	Type string

	// DSN - строка подключения (connection string)
	// Примеры:
	//   SQLite:     "file:app.db"
	//   PostgreSQL: "postgresql://user:pass@localhost:5432/dbname"
	//   MS SQL:     "sqlserver://user:pass@localhost:1433?database=dbname"
	DSN string

	// Schema - схема по умолчанию (для PostgreSQL/MS SQL)
	// SQLite игнорирует это поле
	Schema string

	// Timeout - таймаут для запросов
	Timeout time.Duration

	// MaxConns - максимальное количество подключений в пуле
	MaxConns int

	// MinConns - минимальное количество idle подключений
	MinConns int

	// SSL - настройки SSL/TLS
	SSL SSLConfig

	// CompatibilityMode - режим совместимости для MS SQL Server
	// Значения: "2012", "2016", "2019", "auto" (по умолчанию)
	// Используется только для MS SQL Server adapter
	CompatibilityMode string

	// StrictCompatibility - строгий режим совместимости
	// Если true, ошибка при попытке использовать недоступные функции
	// Если false, предупреждение и fallback на альтернативные методы
	StrictCompatibility bool

	// WarnOnIncompatible - предупреждать о несовместимых функциях
	// Показывает предупреждения когда используются функции недоступные
	// в текущем compatibility mode
	WarnOnIncompatible bool

	// NoDateSentinels — список дат-заглушек для "нет даты" (DB-specific conventions).
	// При экспорте: если дата в поле совпадает с sentinel → кодируется как "0000-00-00" в TDTP.
	// Пример для MSSQL: ["1900-01-01", "1753-01-01"]
	NoDateSentinels []string

	// Charset — кодировка строковых данных в БД.
	// Оставить пустым если драйвер конвертирует в UTF-8 автоматически (pgx, go-mssqldb, modernc/sqlite).
	// Указать явно для адаптеров где auto-conversion отсутствует (ODBC, JDBC, legacy drivers).
	// Примеры: "windows-1251", "koi8-r", "iso-8859-1"
	Charset string

	// StrictSchema — при CreateTable восстанавливать заявленную длину
	// текстовых полей (VARCHAR(n)/CHAR(n)) вместо безусловного TEXT.
	// По умолчанию false: TEXT без ограничений, чтобы импорт не падал на
	// обрезании (см. историю в pkg/adapters/postgres/types.go — этот же
	// откат уже случился один раз). При true колонка получает то же
	// ограничение длины, что было на источнике, и вставка строки длиннее
	// n падает с ошибкой БД сразу, вместо молчаливого расширения до TEXT —
	// то есть обменивает удобство на "падать вовремя, а не после".
	//
	// Точное совпадение длины гарантировано только когда пакет
	// импортируется в ту же СУБД, из которой был экспортирован: единица
	// длины (символы/байты) и правила усечения различаются между
	// движками. Сейчас читается только адаптером PostgreSQL.
	StrictSchema bool
}

type DatabaseInfo struct {
	Type      string       // "sqlite", "postgres", "mssql"
	Version   string       // Версия СУБД
	Schemas   []SchemaInfo // Схемы (для PostgreSQL/MS SQL)
	Tables    []TableInfo  // Таблицы
	TotalSize int64        // Общий размер БД
	Encoding  string       // Кодировка
}

type ExportOptions struct {
	// BatchSize - размер батча (количество строк в одном пакете)
	BatchSize int

	// IncludeSchema - включать ли схему в пакеты
	IncludeSchema bool

	// Sender - отправитель (для заполнения Header.Sender)
	Sender string

	// Recipient - получатель (для заполнения Header.Recipient)
	Recipient string

	// Compression - использовать ли сжатие (будущая функциональность)
	Compression bool
}

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

type ForeignKeyReport struct {
	Column           string `yaml:"column" json:"column"`
	ReferencesTable  string `yaml:"references_table" json:"references_table"`
	ReferencesColumn string `yaml:"references_column" json:"references_column"`
	OnDelete         string `yaml:"on_delete,omitempty" json:"on_delete,omitempty"`
}

type ImportOptions struct {
	// Strategy - стратегия импорта
	Strategy ImportStrategy

	// CreateTable - создавать ли таблицу автоматически
	CreateTable bool

	// TruncateFirst - очистить таблицу перед импортом
	TruncateFirst bool

	// BatchSize - размер батча для массовых вставок
	BatchSize int

	// UseTransaction - использовать транзакцию
	UseTransaction bool

	// ContinueOnError - продолжать при ошибках (не рекомендуется)
	ContinueOnError bool
}

type ImportStrategy string

type IncrementalConfig = sync.IncrementalConfig

type QueryBuilder interface {
	// BuildSelectAll строит SELECT * FROM table
	BuildSelectAll(tableName string) string

	// BuildSelectWithFilter строит SELECT с WHERE/LIMIT/OFFSET
	// Возвращает SQL запрос и массив параметров
	BuildSelectWithFilter(tableName string, query *packet.Query) (sql string, args []any, err error)

	// BuildInsert строит INSERT INTO table (cols) VALUES (...)
	BuildInsert(tableName string, fields []packet.Field) string

	// BuildUpsert строит запрос для UPSERT операции
	// pkFields - список колонок Primary Key
	// Синтаксис зависит от СУБД:
	//   PostgreSQL: INSERT ... ON CONFLICT DO UPDATE
	//   SQLite:     INSERT OR REPLACE
	//   MS SQL:     MERGE
	BuildUpsert(tableName string, fields []packet.Field, pkFields []string) string

	// BuildCreateTable строит CREATE TABLE запрос
	BuildCreateTable(tableName string, schema packet.Schema) string

	// QuoteIdentifier экранирует идентификатор (имя таблицы/колонки)
	// PostgreSQL: "table_name"
	// SQLite:     "table_name" или `table_name`
	// MS SQL:     [table_name]
	QuoteIdentifier(identifier string) string
}

type SSLConfig struct {
	// Mode - режим SSL:
	//   "disable"     - без SSL
	//   "require"     - требовать SSL
	//   "verify-ca"   - проверять CA сертификат
	//   "verify-full" - полная проверка сертификата
	Mode string

	// CertPath - путь к клиентскому сертификату
	CertPath string

	// KeyPath - путь к приватному ключу
	KeyPath string

	// CAPath - путь к CA сертификату
	CAPath string
}

type SchemaInfo struct {
	Name        string   // Имя схемы
	Tables      []string // Список таблиц в схеме
	Description string   // Описание схемы (если есть)
}

type TableInfo struct {
	Name      string       // Имя таблицы
	Schema    string       // Схема (для PostgreSQL/MS SQL)
	Columns   []ColumnInfo // Колонки
	RowCount  int64        // Примерное количество строк
	SizeBytes int64        // Размер таблицы в байтах (если доступно)
	Comment   string       // Комментарий таблицы
}

type TableReport struct {
	Table       string             `yaml:"table" json:"table"`
	DBType      string             `yaml:"db_type" json:"db_type"`
	DBVersion   string             `yaml:"db_version" json:"db_version"`
	Schema      string             `yaml:"schema,omitempty" json:"schema,omitempty"`
	Columns     []ColumnReport     `yaml:"columns" json:"columns"`
	ForeignKeys []ForeignKeyReport `yaml:"foreign_keys,omitempty" json:"foreign_keys,omitempty"`
	Stats       TableStats         `yaml:"stats" json:"stats"`
	Sample      map[string]string  `yaml:"sample,omitempty" json:"sample,omitempty"`
}

type TableStats struct {
	TotalRows int64 `yaml:"total_rows" json:"total_rows"`
}

type Tx interface {
	// Commit фиксирует изменения транзакции
	Commit(ctx context.Context) error

	// Rollback откатывает изменения транзакции
	Rollback(ctx context.Context) error
}

type TypeMapper interface {
	// TDTPToSQL конвертирует поле TDTP в SQL тип
	// Пример:
	//   PostgreSQL: Field{Type:"INTEGER", Subtype:"bigint"} → "BIGINT"
	//   SQLite:     Field{Type:"INTEGER"} → "INTEGER"
	TDTPToSQL(field packet.Field) string

	// SQLToTDTP конвертирует SQL тип в поле TDTP
	// Пример:
	//   PostgreSQL: "VARCHAR(100)" → Field{Type:"TEXT", Length:100}
	//   SQLite:     "INTEGER" → Field{Type:"INTEGER"}
	SQLToTDTP(sqlType string, nullable bool) (packet.Field, error)

	// ValueToString конвертирует значение БД в строку для TDTP пакета
	// Обрабатывает специфичные типы каждой СУБД (UUID, JSON, массивы и т.д.)
	ValueToString(value any) string

	// StringToValue конвертирует строку из TDTP пакета в значение для БД
	// Используется при импорте данных
	StringToValue(str string, field packet.Field) (any, error)
}

type ViewInfo struct {
	// Name - имя view
	Name string

	// IsUpdatable - можно ли выполнять INSERT/UPDATE/DELETE на этом view
	// true  = updatable view (можно импортировать)
	// false = read-only view (только экспорт)
	IsUpdatable bool
}