datasource

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

type ColumnSchema struct {
	Name         string
	DataType     string
	Nullable     bool
	DefaultValue *string
	Comment      string
	IsPrimaryKey bool
	IsForeignKey bool
}

type Config struct {
	Type     string                 // 'jdbc', 'csv', 'excel'
	DBType   string                 // 'postgresql' (for JDBC)
	Settings map[string]interface{} // 具体配置
}

type DBConfig struct {
	DBType   string `json:"db_type"` // postgresql
	Host     string `json:"host"`
	Port     int    `json:"port"`
	Database string `json:"database"`
	Username string `json:"username"`
	Password string `json:"password"`
	SSLMode  string `json:"ssl_mode"` // disable, require
}

type DataSource interface {
	// Connect 连接数据源
	Connect(ctx context.Context) error
	// Close 关闭连接
	Close() error
	// GetTables 获取所有表名
	GetTables(ctx context.Context) ([]string, error)
	// GetTableSchema 获取表结构
	GetTableSchema(ctx context.Context, tableName string) (*TableSchema, error)
	// ExecuteQuery 执行查询
	ExecuteQuery(ctx context.Context, query string) (*QueryResult, error)
	// TestConnection 测试连接
	TestConnection(ctx context.Context) error
}

type DataSourceFactory struct{}

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

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

type ForeignKey struct {
	ColumnName     string
	RefTableName   string
	RefColumnName  string
	ConstraintName string
}

type IndexSchema struct {
	IndexName string
	Columns   []string
	IsUnique  bool
}

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

type QueryResult struct {
	Columns []string
	Rows    [][]interface{}
	Error   error
}

type TableSchema struct {
	TableName   string
	Columns     []ColumnSchema
	PrimaryKeys []string
	ForeignKeys []ForeignKey
	RowCount    int64
}