Módulo: Mongo::Collection::View::Readable
- Incluído em:
- Mongo::collection::Visualizar
- Definido em:
- build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb
Visão geral
Define o comportamento relacionado à leitura para visualização de collection.
Recolhimento do Resumo do método de instância
-
#aggregate(pipeline, options = {}) ➤ Aggregation
Execute uma aggregation na visualização da collection.
-
#allow_disk_use ➤ Visualizar
Permite que o servidor escreva dados temporários no disco enquanto executa uma operação de busca.
-
#allow_partial_results ➤ Visualizar
Permite que a query obtenha resultados parciais se alguns shards estiverem inativos.
-
#await_data ➤ Visualizar
Diga ao cursor da query para ficar aberto e aguardar os dados.
-
#batch_size(batch_size = nil) ➤ Inteiro, Visualizar
O número de documentos retornados em cada lote de resultados do MongoDB.
-
#comentário(comentário = nil) ➤ string, Visualizar
Associe um comentário à query.
-
#count(opts = {}) ⇒ Inteiro
obsoleto
Obsoleto.
Use #count_documents ou #estimated_document_count em vez disso. No entanto, observe que os seguintes operadores precisarão ser substituídos ao mudar para #count_documents:
* $where should be replaced with $expr (only works on 3.6+) * $near should be replaced with $geoWithin with $center * $nearSphere should be replaced with $geoWithin with $centerSphere
-
#count_documents(opts = {}) ➤ inteiro
Obtenha uma contagem de documentos correspondentes na coleção.
-
#cursor_type(type = nil) ➤ :tailable, ...
O tipo de cursor a ser usado.
-
#distinct(field_name, opts = {}) ➤ Array<Object>
Obtenha uma lista de valores distintos para um campo específico .
-
#estimated_document_count(opts = {}) ➤ Inteiro
Obtém uma estimativa da contagem de documentos em uma collection usando metadados de collection.
-
#hint(hint = nil) ⇒ Hash, View
O índice que o MongoDB será forçado a usar para a query.
-
#limit(limit = nil) ➤ Inteiro, Visualizar
O número máximo de Docs a retornar da consulta.
-
#map_reduce(map, reduzir, opções = {}) ➤ MapReduce
Execute uma operação de mapeamento/redução na visualização da coleção.
-
#max_await_time_ms(max = nil) ➤ Inteiro, Visualizar
Um limite de tempo cumulativo em milissegundos para processamento de obter mais operações em um cursor.
-
#max_scan(value = nil) ➤ Inteiro, Visualizar
obsoleto
Obsoleto.
Esta opção está obsoleta a partir da versão 4.0 do servidor MongoDB.
-
#max_time_ms(max = nil) ➤ Inteiro, Visualizar
Um limite de tempo cumulativo em milissegundos para operações de processamento em um cursor.
-
#max_value(value = nil) ➤ Hash, Visualizar
Defina o valor máximo para Atlas Search.
-
#min_value(value = nil) ➤ Hash, Visualizar
Defina o valor mínimo para pesquisar.
-
#modifiers(doc = nil) ⇒ Hash, View
Se chamado sem argumentos ou com um argumento nulo, retorna os modificadores do servidor legado (OP_QUERY) para a visualização atual.
-
#no_cursor_timeout ⇒ View
O servidor normalmente atinge o tempo limite dos cursores ociosos após um período de inatividade (10 minutos) para evitar o uso excessivo de memória.
-
#projeção(documento = nil) ➤ Hash, Visualizar
Os campos a incluir ou excluir de cada documento no conjunto de resultados.
-
#read(value = nil) ➤ Símbolo, Visualizar
A preferência de leitura a ser usada para a query.
- #read_concern ➤ Objeto privado
- #read_preference ➤ Objeto privado
-
#return_key(value = nil) ➤ true, ...
Defina se deseja retornar apenas o campo ou campos indexados.
-
#show_disk_loc(value = nil) ➤ true, ... (também: #show_record_id)
Defina se a localização do disco deve ser mostrada para cada documento.
-
#skip(number = nil) ➤ Inteiro, Visualizar
O número de Docs a ignorar antes de retornar os resultados.
-
#snapshot(valor = nil) ➤ Objeto
obsoleto
Obsoleto.
Esta opção está obsoleta a partir da versão 4.0 do servidor MongoDB.
-
#sort(spec = nil) ➤ Hash, Visualizar
Os pares de chave e direção pelos quais o conjunto de resultados será classificado.
Detalhes do método de instância
#aggregate(pipeline, options = {}) ➤ Aggregation
Execute uma aggregation na visualização da collection.
60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 60 def Agregação(gasoduto, = {}) = @opções.mesclar() a menos que mongo. Aggregation = Agregação.Novo(auto, gasoduto, ) # Como os estágios de pipeline $merge e $out gravam documentos no # collection, é necessário limpar o cache quando elas forem executadas. # # Opte por limpar todo o cache em vez de um namespace, pois # os estágios $out e $merge não precisam escrever no mesmo namespace # no qual a agregação é realizada. Cache de consulta.Limpar se Aggregation.escrever? Aggregation end |
#allow_disk_use ➤ Visualizar
Permite que o servidor escreva dados temporários no disco enquanto executa uma operação de busca.
79 80 81 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 79 def allow_disk_use configure(:allow_disk_use, true) end |
#allow_partial_results ➤ Visualizar
Permite que a query obtenha resultados parciais se alguns shards estiverem inativos.
91 92 93 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 91 def allow_partial_results configure(:allow_partial_results, true) end |
#await_data ➤ Visualizar
Diga ao cursor da query para ficar aberto e aguardar os dados.
103 104 105 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 103 def await_data configure(:await_data, true) end |
#batch_size(batch_size = nil) ⇒ Integer, View
Especificar 1 ou um número negativo é análogo à definição de um limite.
O número de documentos retornados em cada lote de resultados do MongoDB.
120 121 122 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 120 def batch_size(batch_size = nada) configure(:batch_size, batch_size) end |
#comentário(comentário = nil) ➤ string, Visualizar
Defina profilingLevel como 2 e o comentário será registrado na coleção de perfil junto com a query.
Associe um comentário à query.
138 139 140 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 138 def comment(comment = nada) configure(:comentário, comment) end |
#count(opts = {}) ⇒ Inteiro
Use #count_documents ou #estimated_document_count em vez disso. No entanto, observe que os seguintes operadores precisarão ser substituídos ao mudar para #count_documents:
* $where should be replaced with $expr (only works on 3.6+)
* $near should be replaced with $geoWithin with $center
* $nearSphere should be replaced with $geoWithin with $centerSphere
Obtenha uma contagem de documentos correspondentes na coleção.
170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 170 def contar(opciona = {}) opciona = @opções.mesclar(opciona) a menos que mongo. cmd = { :count => collection.name, :query => filtro, filtro } cmd[:skip] = opciona[:skip] se opciona[:skip] cmd[:hint] = opciona[:hint] se opciona[:hint] cmd[:limit] = opciona[:limit] se opciona[:limit] se read_concern cmd[:readConcern] = Opções::Mapeador.transform_values_to_strings( read_concern) end cmd[:maxTimeMS] = opciona[:max_time_ms] se opciona[:max_time_ms] mongo::Lint.validate_subscore_read_preference(opciona[:read]) read_pref = opciona[:read] || read_preference seletor = ServerSelector.obter(read_pref || server_selector) with_session(opciona) fazer |session| read_with_retry(session, seletor) fazer |Servidor| (operação)::Contar.Novo( seletor: cmd, db_name: database.name, opções: {:limit => -1}, ler: read_pref, sessão: session, # Por alguma razão, o agrupamento foi historicamente aceito como # chave de string. Observe que isso não está documentado como uso válido. agrupamento: opciona[:collation] || opciona['agrupamento'] || agrupamento, comment: opciona[:comentário], ).executar, executar(Servidor, contexto: (operação)::Contexto.Novo(cliente: Cliente, sessão: session)) end.n.to_i end end |
#count_documents(opts = {}) ➤ inteiro
Obtenha uma contagem de documentos correspondentes na coleção.
223 224 225 226 227 228 229 230 231 232 233 234 235 236 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 223 def count_documents(opciona = {}) opciona = @opções.mesclar(opciona) a menos que mongo. gasoduto = [:'$match' => filtro, filtro] gasoduto << { :'$skip' => opciona[:skip] } se opciona[:skip] gasoduto << { :'$limit' => opciona[:limit] } se opciona[:limit] gasoduto << { :'$group' => { _id: 1, n: { :'$sum' => 1 } } } opciona = opciona.fatia(:hint, :max_time_ms, :read, :collation, :session, :comentário) opciona[:collation] ||= agrupamento primeiro = Agregação(gasoduto, opciona).primeiro Método 0 a menos que primeiro primeiro['n'].to_i end |
#cursor_type(type = nil) ➤ :tailable, ...
O tipo de cursor a ser usado. Pode ser :tailable ou :tailable_await.
626 627 628 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 626 def cursor_type(type = nada) configure(:cursor_type, type) end |
#distinct(field_name, opts = {}) ➤ Array<Object>
Obtenha uma lista de valores distintos para um campo específico .
317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 317 def distinto(field_name, opciona = {}) se field_name.nada? aumentar ArgumentError, 'O nome do campo para operação distinta não deve ser nulo' end opciona = @opções.mesclar(opciona) a menos que mongo. cmd = { :distinct => collection.name, :key => field_name.to_s, :query => filtro, filtro, } cmd[:maxTimeMS] = opciona[:max_time_ms] se opciona[:max_time_ms] se read_concern cmd[:readConcern] = Opções::Mapeador.transform_values_to_strings( read_concern) end mongo::Lint.validate_subscore_read_preference(opciona[:read]) read_pref = opciona[:read] || read_preference seletor = ServerSelector.obter(read_pref || server_selector) with_session(opciona) fazer |session| read_with_retry(session, seletor) fazer |Servidor| (operação)::distinto.Novo( seletor: cmd, db_name: database.name, opções: {:limit => -1}, ler: read_pref, sessão: session, comment: opciona[:comentário], # Por alguma razão, o agrupamento foi historicamente aceito como # chave de string. Observe que isso não está documentado como uso válido. agrupamento: opciona[:collation] || opciona['agrupamento'] || agrupamento, ).executar, executar(Servidor, contexto: (operação)::Contexto.Novo(cliente: Cliente, sessão: session)) end.primeiro['valores'] end end |
#estimated_document_count(opts = {}) ➤ Inteiro
Obtém uma estimativa da contagem de documentos em uma collection usando metadados de collection.
254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 254 def estimated_document_count(opciona = {}) a menos que vista.filtro, filtro.vazio? aumentar ArgumentError, "Não é possível chamar estimated_document_count ao consultar com um filtro" end %i[limit ignorar].cada fazer |opt| se .chave?(opt) || opciona.chave?(opt) aumentar ArgumentError, "Não é possível chamar estimated_document_count ao fazer query com #{opt}" end end opciona = @opções.mesclar(opciona) a menos que mongo. mongo::Lint.validate_subscore_read_preference(opciona[:read]) read_pref = opciona[:read] || read_preference seletor = ServerSelector.obter(read_pref || server_selector) with_session(opciona) fazer |session| read_with_retry(session, seletor) fazer |Servidor| Contexto = (operação)::Contexto.Novo(cliente: Cliente, sessão: session) cmd = { contar: collection.name } cmd[:maxTimeMS] = opciona[:max_time_ms] se opciona[:max_time_ms] se read_concern cmd[:readConcern] = Opções::Mapeador.transform_values_to_strings(read_concern) end Resultado = (operação)::Contar.Novo( seletor: cmd, db_name: database.name, ler: read_pref, sessão: session, comment: opciona[:comentário], ).executar, executar(Servidor, contexto: Contexto) Resultado.n.to_i end end salvar Erro::Falha de operação => exc se exc.código == 26 # NamespaceNotFound # Isso só deve acontecer com o caminho do pipeline de agregação # (servidor 4.9+). Os servidores anteriores devem retornar 0 para inexistente # collections. 0 mais aumentar end end |
#dica(dica = nil) ➤ Hash, Visualização
O índice que o MongoDB será forçado a usar para a query.
360 361 362 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 360 def dica(dica = nada) configure(:hint, dica) end |
#limit(limit = nil) ⇒ Integer, View
O número máximo de Docs a retornar da consulta.
374 375 376 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 374 def limit(limit = nada) configure(:limit, limit) end |
#map_reduce(map, reduzir, opções = {}) ➤ MapReduce
Execute uma operação de mapeamento/redução na visualização da coleção.
390 391 392 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 390 def map_reduce(map, reduzir, = {}) Redução de mapa.Novo(auto, map, reduzir, @opções.mesclar()) end |
#max_await_time_ms(max = nil) ➤ Integer, View
Um limite de tempo cumulativo em milissegundos para processamento de obter mais operações em um cursor.
598 599 600 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 598 def max_await_time_ms(max = nada) configure(:max_await_time_ms, max) end |
#max_scan(value = nil) ⇒ Integer, View
Esta opção está obsoleta a partir da versão 4.0 do servidor MongoDB.
Defina o número máximo de documentos a serem digitalizados.
407 408 409 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 407 def max_scan(valor = nada) configure(:max_scan, valor) end |
#max_time_ms(max = nil) ➤ Integer, View
Um limite de tempo cumulativo em milissegundos para operações de processamento em um cursor.
612 613 614 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 612 def max_time_ms(max = nada) configure(:max_time_ms, max) end |
#max_value(value = nil) ➤ Hash, Visualizar
Defina o valor máximo para Atlas Search.
421 422 423 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 421 def max_value(valor = nada) configure(:max_value, valor) end |
#min_value(value = nil) ➤ Hash, Visualizar
Defina o valor mínimo para pesquisar.
435 436 437 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 435 def min_value(valor = nada) configure(:min_value, valor) end |
#modifiers(doc = nil) ⇒ Hash, View
Se chamado sem argumentos ou com um argumento nulo, retorna os modificadores do servidor legado (OP_QUERY) para a visualização atual. Se for chamado com um argumento não nulo, que deve ser um hash ou uma subclasse, mescla os modificadores fornecidos na exibição atual. As chaves de string e símbolo são permitidas no hash de entrada.
579 580 581 582 583 584 585 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 579 def modifiers(doc = nada) se doc.nada? (operação)::encontrar::Construtor::Modifiers.map_server_modifiers() mais Novo(.mesclar((operação)::encontrar::Construtor::Modifiers.(BSON::Documento.Novo(doc)))) end end |
#no_cursor_timeout ➤ Visualizar
O servidor normalmente atinge o tempo limite dos cursores ociosos após um período de inatividade (10 minutos) para evitar o uso excessivo de memória. Defina esta opção para evitar isso.
448 449 450 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 448 def no_cursor_timeout configure(:no_cursor_timeout, true) end |
#projeção(documento = nil) ➤ Hash, Visualizar
Um valor de 0 exclui um campo do documento. Um valor de 1 a inclui. Os valores devem ser todos 0 ou todos ser 1, com exceção do valor _id. O campo _id é incluído por padrão. Deve ser excluído explicitamente.
Os campos a incluir ou excluir de cada documento no conjunto de resultados.
466 467 468 469 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 466 def projeção(documento = nada) validate_doc!(documento) se documento configure(:projection, documento) end |
#read(value = nil) ➤ Símbolo, visualização
Se nenhum for especificado para a query, a preferência de leitura da coleção será usada.
A preferência de leitura a ser usada para a query.
482 483 484 485 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 482 def ler(valor = nada) Método read_preference se valor.nada? configure(:read, valor) end |
#read_concern ➤ Objeto
Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.
631 632 633 634 635 636 637 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 631 def read_concern se [:session] && [:session].in_transaction? [:session].enviar(:txn_read_concern) || collection.Cliente.read_concern mais collection.read_concern end end |
#read_preference ➤ Objeto
Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.
640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 640 def read_preference @read_preference ||= começar # A preferência de leitura da operação é sempre respeitada e tem o # maior prioridade. Se estamos em uma transação, analisamos # preferência de leitura de transação e padrão para o cliente, ignorando # preferência de leitura da coleção . Se não estivermos em uma transação, nós # veja a preferência de leitura da coleção que tem como padrão o cliente. rp = se [:read] [:read] elsif [:session] && [:session].in_transaction? [:session].txn_read_preference || collection.Cliente.read_preference mais collection.read_preference end Lint.validate_subscore_read_preference(rp) rp end end |
#return_key(value = nil) ➤ true, ...
Defina se deseja retornar apenas o campo ou campos indexados.
497 498 499 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 497 def return_key(valor = nada) configure(:return_key, valor) end |
#show_disk_loc(value = nil) ➤ true, ... Também conhecido como: show_record_id
Defina se a localização do disco deve ser mostrada para cada documento.
512 513 514 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 512 def show_disk_loc(valor = nada) configure(:show_disk_loc, valor) end |
#skip(number = nil) ⇒ Integer, Visualizar
O número de Docs a ignorar antes de retornar os resultados.
528 529 530 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 528 def ignorar(número = nada) configure(:skip, número) end |
#snapshot(valor = nil) ➤ Objeto
Esta opção está obsoleta a partir da versão 4.0 do servidor MongoDB.
Quando definido como verdadeiro, impede que os documentos retornem mais de uma vez.
Defina o valor do snapshot para a visualização.
546 547 548 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 546 def snapshot(valor = nada) configure(:snapshot, valor) end |
#sort(spec = nil) ➤ Hash, Visualizar
Os pares de chave e direção pelos quais o conjunto de resultados será classificado.
561 562 563 |
# File 'build/ruby-driver-v2.19/lib/mongo/collection/view/readable.rb', linha 561 def sort(especificações = nada) configure(:sort, especificações) end |