mongodb

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

type MongoDBConfig struct {
	Timeout  time.Duration `mapstructure:"timeout" json:"timeout" yaml:"timeout"` // 超时秒数
	DB       string        `mapstructure:"db" json:"db" yaml:"db"`
	Addr     string        `mapstructure:"addr" json:"addr" yaml:"addr"` // host:port
	User     string        `mapstructure:"user" json:"user" yaml:"user"` // 可选用户名
	Password string        `mapstructure:"password" json:"password" yaml:"password"`
}

type MongoTemplate interface {
	// Client 返回底层原生 MongoDB 客户端。
	Client() *mongo.Client
	// Collection 返回原生集合句柄(手动操作入口)。
	Collection(name string) *mongo.Collection

	// InsertMany 批量插入文档;返回插入结果(含 IDs)。
	InsertMany(ctx context.Context, tableName string, documents []interface{}) (*mongo.InsertManyResult, error)
	// Count 统计匹配 filter 的文档数。
	Count(ctx context.Context, tableName string, filter interface{}) (int64, error)
	// UpdateMany 批量更新匹配 filter 的文档;返回更新结果。
	UpdateMany(ctx context.Context, tableName string, filter, update interface{}) (*mongo.UpdateResult, error)
}