mongodb 随机获取一条记录的方法

原理:

1.先查询表中的记录总数

2.随机获取偏移量为0~总记录数-1

3.查询时skip偏移量,再获取1条记录

因本人测试环境PHP已升级到7.0以上,mongodb扩展使用支持php7.0以上的扩展,很多方法与php5.6不同。因此代码必须在php7.0以上运行。如果是php5.6环境,需要修改代码才能运行。

代码如下:

function.php

<?php
// 连接mongodb
function conn($host, $user, $passwd){
  $server = 'mongodb://'.$user.':'.$passwd.'@'.$host;
  try{
    $conn = new MongoDB\Driver\Manager();
  } catch (MongoDB\Driver\Exception\ConnectionException $e){
    throw new ErrorException('Unable to connect to db server. Error:' . $e->getMessage(), 31);
  }
  return $conn;
}

// 插入数据
function add($conn, $dbname, $collname, $data, $index){

  // 创建索引
  $cmd = array(
    'createIndexes' => $collname,
    'indexes' => array(
      array(
        'name' => 'index',
        'key' => $index,
        'ns' => $dbname.'.'.$collname
      )
    )
  );
  $command = new MongoDB\Driver\Command($cmd);
  $conn->executeCommand($dbname, $command);

  // 插入数据
  $bulk = new MongoDB\Driver\BulkWrite();
  $inserted = 0;

  if($data){
    foreach($data as $k=>$v){
      $bulk->insert($v);
    }
    $result = $conn->executeBulkWrite($dbname.'.'.$collname, $bulk);
    $inserted = $result->getInsertedCount();
  }

  return $inserted;
}

// 获取总记录数
function getCount($conn, $dbname, $collname){
  $cmd = array(
    'count' => $collname,
    'query' => array()
  );
  $command = new MongoDB\Driver\Command($cmd);
  $result = $conn->executeCommand($dbname, $command);
  $response = current($result->toArray());
  if($response->ok==1){
    return $response->n;
  }
  return 0;
}

// 随机获取一条记录
function randOne($conn, $dbname, $collname){

  // 总记录数
  $total = getCount($conn, $dbname, $collname);

  // 随机偏移
  $skip = mt_rand(0, $total-1);

  $filter = array();
  $options = array('skip'=>$skip, 'limit'=>1);
  $query = new MongoDB\Driver\Query($filter, $options);
  $cursor = $conn->executeQuery($dbname.'.'.$collname, $query);

  $result = array();
  if($cursor){
    foreach($cursor as $v){
      $v = objectToArray($v);
      unset($v['_id']);
      $result[] = $v;
    }
  }

  return $result? $result[0] : $result;
}

// 对象转为数组
function objectToArray($obj){
  $arr = is_object($obj) ? get_object_vars($obj) : $obj;
  if(is_array($arr)){
    return array_map(__FUNCTION__, $arr);
  }else{
    return $arr;
  }
}
?>

demo.php

<?php
require('function.php');

// 连接mongodb
$conn = conn('localhost','testdb','root','123456');

// 插入50条数据记录
$data = array();

// 索引
$index = array('user'=>true);

for($i=0; $i<50; $i++){
  $data[] = array(
    'user' => 'test_user_'.str_pad($i, 4, '0', STR_PAD_LEFT)
  );
}

$inserted = add($conn, 'testdb', 'user', $data, $index);
echo '成功插入'.$inserted.'条测试记录数<br><br>';

// 随机获取一条记录,抽5次
echo '随机获取一条记录,抽5次<br>';
$result = array();
for($i=0; $i<5; $i++){
  $result[] = randOne($conn, 'testdb', 'user');
}

echo '<pre>';
print_r($result);
echo '</pre>';
?>

输出:

成功插入50条测试记录数

随机获取一条记录,抽5次
Array
(
  [0] => Array
    (
      [user] => test_user_0017
    )

  [1] => Array
    (
      [user] => test_user_0026
    )

  [2] => Array
    (
      [user] => test_user_0004
    )

  [3] => Array
    (
      [user] => test_user_0043
    )

  [4] => Array
    (
      [user] => test_user_0023
    )

)

测试php代码,首先需要在mongodb创建testdb及创建用户和执行auth。方法如下:

use testdb

db.createUser(
  {
    "user":"root",
    "pwd":"123456",
    "roles":[{"role" : "readWrite", "db":"testdb"}]
  }
) 

db.auth(
  {
    "user":"root",
    "pwd":"123456"
  }
)

源码下载地址:点击查看

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!

时间: 2016-10-20

MongoDB windows解压缩版安装教程详解

创建目录如下 将mongodb的压缩包解压到mongodb目录下 mongodata下创建data目录存放数据:创建log目录存放目录 cmd 输入命令: D:\mongo\mongodb\bin\mongod.exe --dbpath "D:\mongo\mongodata\data" --logpath "D:\mongo\mongodata\log\MongoDB.log" --install --serviceName "mongo" -

1亿条记录的MongoDB数据库随机查询性能测试

mongdb性能压力测试,随机查询,数据量1亿条记录 操作系统centos6.4x64位 从测试结果看,当mongodb将数据全部载入到内存后,查询速度根据文档的大小,性能瓶颈通常会是在网络流量和CPU的处理性能(该次测试中当数据全部在内存后,纯粹的查询速度可以稳定在10W/S左右,系统load可以维持在1以下,由于此时CPU已经被使用到极限了,当并发再大时load值会直线飙升,性能急剧下降). 压力生成服务器与Mongodb服务器基本配置 cpu型号:Intel(R) Xeon(R) CPU

mongodb中随机获取1条记录的实现方法

实现原理如下 1.先查询表中的记录总数 2.随机获取偏移量为0~总记录数-1 3.查询时skip偏移量,再获取1条记录 因本人测试环境php已升级到7.0以上,mongodb扩展使用支持php7.0以上的扩展,很多方法与php5.6不同.因此代码必须在php7.0以上运行.如果是php5.6环境,需要修改代码才能运行. 代码如下: function.php <?php // 连接mongodb function conn($host, $user, $passwd){ $server = 'mo

python实现爬虫数据存到 MongoDB

在以上两篇文章中已经介绍到了 Python 爬虫和 MongoDB , 那么下面我就将爬虫爬下来的数据存到 MongoDB 中去,首先来介绍一下我们将要爬取的网站, readfree 网站,这个网站非常的好,我们只需要每天签到就可以免费下载三本书,良心网站,下面我就将该网站上的每日推荐书籍爬下来. 利用上面几篇文章介绍的方法,我们很容易的就可以在网页的源代码中寻找到书籍的姓名和书籍作者的信息. 找到之后我们复制 XPath ,然后进行提取即可.源代码如下所示 # coding=utf-8 imp

MongoDB 主从复制实例讲解

主从复制可以用来做数据库的备份,故障恢复,读写分离. 本实验使用Mongodb 3.2版本,我们先查看一下mongod的帮助 [root@localhost mongodb]# mongod --help .....省略 Master/slave options (old; use replica sets instead): --master master mode --slave slave mode --source arg when slave: specify master as <s

Yii框架连接mongodb数据库的代码

yii2框架是yii的升级版本,本文我们分别讲解在yii框架中如何连接数据库mongodb. 在文件夹common/config/main_local.php中加入如下代码: <?php return [ 'components' => [ 'mongodb' => [ 'class' => 'yii\mongodb\Connection', 'dsn' => 'mongodb://localhost:27017/数据库名' ], ], ]; 以上所述是小编给大家介绍的Yii

mongodb 3.2.5安装详细过程

1. 准备安装介质 安装介质下载: mongodb的安装方式,我通常使用二进制包的方式,内网不能配置连接外网的yum源: 官方建议的mongodb下载地址为: Downloads.mongodb.org 但实际上,这个地址,很难找到下载表,正常下载,通常可以用下面的下载地址选择下载: https://www.mongodb.org/dl/linux/x86_64 我这里下载的是: 3.2.5 版本对应的 mongodb-linux-x86_64-rhel62-3.2.5-20-g07e21d8.

深入理解MongoDB分片的管理

前言 在MongoDB(版本 3.2.9)中,分片集群(sharded cluster)是一种水平扩展数据库系统性能的方法,能够将数据集分布式存储在不同的分片(shard)上,每个分片只保存数据集的一部分,MongoDB保证各个分片之间不会有重复的数据,所有分片保存的数据之和就是完整的数据集.分片集群将数据集分布式存储,能够将负载分摊到多个分片上,每个分片只负责读写一部分数据,充分利用了各个shard的系统资源,提高数据库系统的吞吐量. 数据集被拆分成数据块(chunk),每个数据块包含多个do

MongoDB 导出导入备份恢复数据详解及实例

数据库备份和数据恢复的重要性,我想大家都知道,这里就举例说明如何操作数据备份,数据恢复的实例: 创建测试数据 创建db:testdb,collection:user,插入10条记录 mongo MongoDB shell version: 3.0.2 connecting to: test > use testdb switched to db testdb > db.user.insert({id:1,name:"用户1"}); WriteResult({ "n

MongoDB安装图文教程

MongoDB是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的. 支持的数据结构非常松散,是类似json的bjson格式,因此可以存储比较复杂的数据类型. Mongo最大的特点是他支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且 还支持对数据建立索引. 1.下载MOngoDB:  MongoDB的下载地址:https://www.mongodb.org/downloads/ 我的系统是X

ASP.NET MVC4使用MongoDB制作相册管理

ASP.NET MVC4使用MongoDB制作相册管理实例分享 TIPS:1.Image转成Base64保存到mongodb字段          2.数据模型是嵌套的关联 首先定义Model层:  public class Photo : IEquatable<Photo> { [Required] public string PhotoName { get; set; } [Required] public string PhotoDescription { get; set; } pub

ASP.NET MVC4异步聊天室的示例代码

本文介绍了ASP.NET MVC4异步聊天室的示例代码,分享给大家,具体如下: 类图: Domain层 IChatRoom.cs using System; using System.Collections.Generic; namespace MvcAsyncChat.Domain { public interface IChatRoom { void AddMessage(string message); void AddParticipant(string name); void GetM

基于Asp.Net MVC4 Bundle捆绑压缩技术的介绍

很高兴,最近项目用到了Asp.Net MVC4 + Entity Framework5,发现mvc4加入了Bundle.Web API等技术,着实让我兴奋,以前是用第三方的,这里主要说说Bundle技术. 很多大网站都没有用Bundle技术造成很多资源浪费与性能的牺牲,别小瞧 用上了你会发现他的好处: 将多个请求捆绑为一个请求,减少服务器请求数 没有使用Bundle技术,debug下看到的是实际的请求数与路径 使用Bundle技术,并且拥有缓存功能调试设置为Release模式并按F5或修改web

javaWEB实现相册管理的简单功能

这仅仅只是一个小小的相册管理,主要实现的功能:能够实现对图片的上传,统一浏览,单个下载,单个删除,只能删除自己上传的文件. 现在对每个功能进行单个的解释: 图片的上传  图片的上传在之前的文章中写的很清楚了,点击打开链接:<JavaEE实现前后台交互的文件上传与下载> . 在这个相册管理中,就不是单一的文件传了,还需要涉及到很多参数供其他功能模块的使用 <span style="font-size:24px;">//上传文件一般采用外面的 apache的上传工具

Asp.Net MVC4通过id更新表单内容的思路详解

用户需求是:一个表单一旦创建完,其中大部分的字段便不可再编辑.只能编辑其中部分字段. 而不可编辑是通过对input输入框设置disabled属性实现的,那么这时候直接向数据库中submit表单中的内容就会报错,因为有些不能为null的字段由于disabled属性根本无法在前端被获取而后更新至数据库. 有下面两种思路: 1.通过创建隐藏表单,为每一个disabled控件分别创建一个隐藏控件,但是这样的问题是工作量太大(如果表单有一千个属性,你懂的) 2.通过获取该表单在数据库中的id,把该id和可

ASP.NET MVC4 利用uploadify.js多文件上传

页面代码: 1.引入js和css文件 <link href="~/Scripts/uploadify/uploadify.css" rel="external nofollow" rel="stylesheet" /> <style type="text/css"> #upDiv { width: 550px; height: 400px; border: 2px solid red; margin-t

ASP.NET MVC4中使用Html.DropDownListFor的方法示例

本文实例讲述了ASP.NET MVC4中使用Html.DropDownListFor的方法.分享给大家供大家参考,具体如下: 一.控制器部分: public ActionResult PageDetail() { var thisList = _sysDepartmentBll.GetAllDepartmentList();//数据源 //添加一条默认数据 var resultList = new List<SelectListItem> { new SelectListItem {Text

MongoDB快速入门笔记(七)MongoDB的用户管理操作

MongoDB 简介 MongoDB 是一个基于分布式文件存储的数据库.由 C++ 语言编写.旨在为 WEB 应用提供可扩展的高性能数据存储解决方案. MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的. 1.修改启动MongoDB时要求用户验证 加参数 --auth 即可. 现在我们把MongoDB服务删除,再重新添加服务 复制代码 代码如下: mongod --dbpath "D:\work\MongoDB\data" --

Html5+jQuery+CSS制作相册小记录

本文主要讲述采用Html5+jQuery+CSS 制作相册的小小记录. 主要功能点: Html5进行布局 调用jQuery(借用官网的一句话:The Write Less, Do More)极大的简化了JavaScript编程 CSS 样式将表现与内容分离 话不多说,先上效果图: 代码如下: <!DOCTYPE html> <html> <head> <title>The second html page</title> <style ty

ASP.NET MVC4入门教程(一):入门介绍

前言 本教程将为您讲解使用微软的Visual Studio Express 2012或Visual Web Developer 2010 Express Service Pack 1 来建立一个ASP.NET MVC4 Web应用程序所需要的基础知识.建议您使用Visual Studio 2012,你将不再需要安装任何组件,来完成此教程.如果您使用的是Visual Studio 2010,您必须安装下面的组件.您可以通过点击下面的链接,来安装所需的所有组件: Visual Studio Web