mongodriver

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

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

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

type CursorColumn struct {
	Col   string `json:"col"`   // Column name
	Order string `json:"order"` // "asc" or "desc"
}

type CursorInfo struct {
	SelID   int            `json:"sel_id"`   // Selection ID for cursor prefix
	Prefix  string         `json:"prefix"`   // Cursor prefix (e.g., "gj-")
	OrderBy []CursorColumn `json:"order_by"` // Order-by columns for cursor value
}

type Driver struct{}

type FKConnect struct {
	Path   string `json:"path"`   // Field path in document (e.g., "owner")
	Column string `json:"column"` // FK column name (e.g., "owner_id")
}

type FieldInfo struct {
	Name     string
	BSONType string
	SQLType  string
	Required bool
	IsArray  bool
	IsUnique bool
}

type IntrospectOptions struct {
	SampleSize        int  `json:"sample_size"`
	IncludeValidators bool `json:"include_validators"`
}

type NestedInsert struct {
	Collection string         `json:"collection"`
	ID         int            `json:"id"`
	ParentID   int            `json:"parent_id"`
	RelType    string         `json:"rel_type,omitempty"`     // "one_to_one" or "one_to_many"
	FKCol      string         `json:"fk_col,omitempty"`       // FK column name (e.g., "owner_id")
	FKOnParent bool           `json:"fk_on_parent,omitempty"` // true if FK is on parent table, false if on child
	IsConnect  bool           `json:"is_connect,omitempty"`   // true if this is a connect (UPDATE) rather than insert
	Document   map[string]any `json:"document"`
}

type NestedUpdate struct {
	Collection string         `json:"collection"`
	ID         int            `json:"id"`
	ParentID   int            `json:"parent_id"`
	Type       string         `json:"type"`                   // "update", "connect", "disconnect"
	RelType    string         `json:"rel_type,omitempty"`     // Relationship type
	FKCol      string         `json:"fk_col,omitempty"`       // FK column to update for connect/disconnect
	FKOnParent bool           `json:"fk_on_parent,omitempty"` // true if FK is on parent table
	Filter     map[string]any `json:"filter"`
	Update     map[string]any `json:"update,omitempty"`
}

type QueryCondition struct {
	// VarParam is the parameter placeholder (e.g., "$1") for the variable value
	VarParam string `json:"var_param"`
	// Op is the operation: "eq" for @include (show if var == true),
	// "ne" for @skip (show if var != true)
	Op string `json:"op"`
}

type QueryDSL struct {
	Operation         string           `json:"operation"`
	Collection        string           `json:"collection,omitempty"`
	FieldName         string           `json:"field_name,omitempty"`     // GraphQL field name to wrap result in
	Singular          bool             `json:"singular,omitempty"`       // If true, return single object instead of array
	Typename          string           `json:"typename,omitempty"`       // If set, add __typename field with this value to each result
	QueryTypename     string           `json:"query_typename,omitempty"` // If set, add root __typename field with this value
	Pipeline          []map[string]any `json:"pipeline,omitempty"`
	Document          map[string]any   `json:"document,omitempty"`
	Documents         []map[string]any `json:"documents,omitempty"`       // For bulk inserts (insertMany)
	RawDocument       string           `json:"raw_document,omitempty"`    // Raw document placeholder (e.g., "$1")
	ConnectColumn     string           `json:"connect_column,omitempty"`  // Array column to populate from connect
	ConnectPath       string           `json:"connect_path,omitempty"`    // Path to connect IDs in document (e.g., "$2")
	FKConnect         *FKConnect       `json:"fk_connect,omitempty"`      // FK column to populate from connect (single value)
	FKConnects        []FKConnect      `json:"fk_connects,omitempty"`     // Multiple FK columns to populate from connects
	FKValues          map[string]any   `json:"fk_values,omitempty"`       // Direct FK values to set on root document
	ReturnPipeline    []map[string]any `json:"return_pipeline,omitempty"` // Pipeline to run after insert to fetch return data
	Filter            map[string]any   `json:"filter,omitempty"`
	Update            map[string]any   `json:"update,omitempty"`
	Options           map[string]any   `json:"options,omitempty"`
	Presets           map[string]any   `json:"presets,omitempty"` // Preset values to merge with document
	Params            []string         `json:"params,omitempty"`
	Queries           []*QueryDSL      `json:"queries,omitempty"`             // For multi_aggregate operations
	Inserts           []NestedInsert   `json:"inserts,omitempty"`             // For nested_insert operations
	Updates           []NestedUpdate   `json:"updates,omitempty"`             // For nested_update operations
	RootCollection    string           `json:"root_collection,omitempty"`     // Root collection for nested_insert/nested_update
	RootMutateID      int              `json:"root_mutate_id,omitempty"`      // ID of root mutation for nested_insert
	AllSameCollection bool             `json:"all_same_collection,omitempty"` // True if all inserts are in same collection (recursive-only)
	Condition         *QueryCondition  `json:"condition,omitempty"`           // Condition for variable-based directives
	CursorInfo        *CursorInfo      `json:"cursor_info,omitempty"`         // Cursor pagination metadata
	CursorParam       string           `json:"cursor_param,omitempty"`        // Parameter placeholder for cursor value (e.g., "$1")
}

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

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

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

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

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