zoukankan      html  css  js  c++  java
  • php给mongodb添加索引

    <?php
    /**
     * mongo字段加索引
     * Created by PhpStorm.
     * User: Administrator
     * Date: 2021/6/11
     * Time: 15:02
     */
    
    $mongoDB = 'deyibao';//mongo数据库名
    $mongoClient = new MongoClient();//mongo连接
    $db = $mongoClient->selectDB($mongoDB);//选择数据库
    $collectionNames = $db->getCollectionNames();//获取所有的集合名
    $rule1 = '/task_record_.*/';//正则表达式
    $rule2 = '/turn_.+_record_.*/';
    foreach ($collectionNames as $k=>$v){
        $index = $db->$v->getIndexInfo();//获取索引
        if (preg_match_all($rule1,$v)){
            foreach ($index as $key=>$val){
                if (!strstr('date',$val['name'])) $collection = $db->$v->ensureIndex(['date' => 1],['background'=>true]);
                if (!strstr('userId',$val['name'])) $collection = $db->$v->ensureIndex(['userId' => 1],['background'=>true]);
            }
        }
        if (preg_match_all($rule2,$v) || strstr($v,'turn_luck_money')){
            foreach ($index as $key=>$val){
                if (!strstr('date',$val['name'])) $collection = $db->$v->ensureIndex(['date' => 1],['background'=>true]);
                if (!strstr('userId',$val['name'])) $collection = $db->$v->ensureIndex(['userId' => 1],['background'=>true]);
                if (!strstr('type',$val['name'])) $collection = $db->$v->ensureIndex(['type' => 1],['background'=>true]);
                if (!strstr('createTime',$val['name'])) $collection = $db->$v->ensureIndex(['createTime' => 1],['background'=>true]);
            }
        }
        if (strstr($v,'turn_user_sign') || strstr($v,'turn_message') || strstr($v,'turn_group_ranklist_log')) {
            foreach ($index as $key=>$val){
                if (!strstr('userId',$val['name'])) $collection = $db->$v->ensureIndex(['userId' => 1],['background'=>true]);
            }
        }
        if (strstr($v,'turn_group_ranklist')) {
            foreach ($index as $key=>$val){
                if (!strstr('date',$val['name'])) $collection = $db->$v->ensureIndex(['date' => 1],['background'=>true]);
                if (!strstr('groupId',$val['name'])) $collection = $db->$v->ensureIndex(['groupId' => 1],['background'=>true]);
            }
        }
        if (strstr($v,'turn_contribution')) {
            foreach ($index as $key=>$val){
                if (!strstr('userId',$val['name'])) $collection = $db->$v->ensureIndex(['userId' => 1],['background'=>true]);
                if (!strstr('ctbUserId',$val['name'])) $collection = $db->$v->ensureIndex(['ctbUserId' => 1],['background'=>true]);
                if (!strstr('date',$val['name'])) $collection = $db->$v->ensureIndex(['date' => 1],['background'=>true]);
                if (!strstr('tierNum',$val['name'])) $collection = $db->$v->ensureIndex(['tierNum' => 1],['background'=>true]);
            }
        }
        if (strstr($v,'turn_exchange')) {
            foreach ($index as $key=>$val){
                if (!strstr('date',$val['name'])) $collection = $db->$v->ensureIndex(['date' => 1],['background'=>true]);
                if (!strstr('configId',$val['name'])) $collection = $db->$v->ensureIndex(['configId' => 1],['background'=>true]);
                if (!strstr('userId',$val['name'])) $collection = $db->$v->ensureIndex(['userId' => 1],['background'=>true]);
                if (!strstr('type',$val['name'])) $collection = $db->$v->ensureIndex(['type' => 1],['background'=>true]);
            }
        }
    }
    

    根据自己需求更改,此文章只为记录

  • 相关阅读:
    unable to start kestrel System.Net.Sockets.SocketException (10013): 以一种访问权限不允许的方式做了一个访问套接字的尝试。
    c# 复制文件夹内所有文件到另外一个文件夹
    git初始化
    c# 递归获取所有目录,所有文件,并替换文件
    新增项目 提交到gitee
    netcore3.1 跨域请求
    netcore appsettings.json 绑定对象
    nuget安装包
    做人六字诀:静,缓,忍,让,淡,平
    docker安装部署
  • 原文地址:https://www.cnblogs.com/ljkltt/p/14876084.html
Copyright © 2011-2022 走看看