精华内容
下载资源
问答
  • mongo数据库迁移

    2021-05-27 10:05:30
    mongo数据库表迁移迁移工具下载迁移命令mongoexport导出mongoimport导入迁移小工具导出工具导入工具 迁移工具下载 近期,公司涉及到mongodb 数据库迁移。 首先先下载迁移工具,mongodb-database-tools,我用的是...

    迁移工具下载

    近期,公司涉及到mongodb 数据库迁移。
    首先先下载迁移工具,mongodb-database-tools,我用的是windows的。
    在这里插入图片描述
    解压后,将该目录加入环境变量。

    迁移命令

    注意:mongo数据有密码的情况下加入 --authenticationDatabase admin

    mongoexport导出

      mongoexport -d dbname -c collectionname -o file --type json/csv -f field
            参数说明:
                -d :数据库名
                -c :collection名
                -o :输出的文件名
                --type : 输出的格式,默认为json
                -f :输出的字段,如果-type为csv,则需要加上-f "字段名"
    

    mongoimport导入

    mongoimport -d dbname -c collectionname --file filename --headerline --type json/csv -f field
            参数说明:
                -d :数据库名
                -c :collection名
                --type :导入的格式默认json
                -f :导入的字段名
                --headerline :如果导入的格式是csv,则可以使用第一行的标题作为导入的字段
                --file :要导入的文件
    

    迁移小工具

    本文基于python做了迁移小工具。

    导出工具

    import subprocess
    def export(port: str, host: str, user: str, password: str, database: str, collection: str, file_name: str):
        """
        mongo导出工具
        :param port: mongo数据库端口
        :param host: mongo数据库ip
        :param user: mongo数据库用户名
        :param password: mongo数据库密码
        :param database: mongo数据库名
        :param collection: mongo数据库collection名
        :param file_name: mongo数据库文件名json格式
        :return: 是否成功0成功、1失败
        """
        cmd = f'mongoexport --port {port} --host {host} --username {user} --password {password} --db {database} --collection {collection} --type=json -o {file_name} --authenticationDatabase admin'
        compilePopEn = subprocess.Popen(cmd)
        compilePopEn.wait()
        return compilePopEn.returncode
    

    导入工具

    def mongo_import(port: str, host: str, user: str, password: str, database: str, collection: str, file_name: str):
        """
        mongo导入工具
        :param port: mongo数据库端口
        :param host: mongo数据库ip
        :param user: mongo数据库用户名
        :param password: mongo数据库密码
        :param database: mongo数据库名
        :param collection: mongo数据库collection名
        :param file_name: mongo数据库文件名json格式
        :return: 是否成功0成功、1失败
        """
        cmd = f'mongoimport --port {port} --host {host} --username {user} --password {password} --db {database} --collection {collection} --file {file_name} --authenticationDatabase admin'
        compilePopEn = subprocess.Popen(cmd)
        compilePopEn.wait()
        return compilePopEn.returncode
    
    展开全文
  • mongo数据迁移

    想要将数据库1的40条记录插入到数据库2中去,用工具只能一条一条的插入,发现可以写一个简单的程序来解决这个问题

    原作者地址:mongoDB如何复制collection里的数据到另一个collection方法总结

    方法一:

    db.test(复制源表).find().forEach(function(x){
        db.target(目的表).insert(x);
    })

    在他的方法二基础上进行修改程序如下,可以跨不同的数据库操作,请自行扩展

    import com.mongodb.MongoClientURI;
    import org.bson.Document;
    import com.mongodb.MongoClient;
    import com.mongodb.client.FindIterable;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoCursor;
    import com.mongodb.client.MongoDatabase;
    
    import static com.mongodb.client.model.Filters.eq;
    
    public class MongoMigrationTool {
        public static void main(String[] args) {
            MongoClientURI connectURI = new MongoClientURI("mongodb://管理员用户名:管理员密码@127.0.0.1:27017");
            MongoClient client = new MongoClient( connectURI);
            MongoDatabase database = client.getDatabase( "database" );
            MongoCollection<Document> collection = database .getCollection("question" );
    
            MongoDatabase database1 = client.getDatabase( "database1" );
            MongoCollection<Document> collection1 = database1.getCollection("question" );
    
            FindIterable<Document> findIterable = collection1.find(eq("_id", "123")); //iterator——迭代
            MongoCursor<Document> mongoCursor = findIterable .iterator();  //游标
            int index=0;
            while (mongoCursor .hasNext()){
                Document d  = mongoCursor .next(); //遍历每一条数据
                collection .insertOne(d );
                System.out.println((index++)+":"+d);
            }
            System. out .println("转移成功" );
        }
    }


    下面是备份和恢复命令,记录一下

    mongodump -h 127.0.0.1:27017 --username myAdmin --password 12345678 -d test -o /tmp --authenticationDatabase test
    mongorestore -h 127.0.0.1:27017 -d test -u myAdmin -p 12345678 /tmp/test












    展开全文
  • mongo x.x.x.x:8003/apidb -u apidb-p xxx brew install mongodb-database-tools mongodump -h x.x.x.x:8003 -u apidb -p xxx -d apidb-o /Users/guozimo/Documents/csv mongorestore -h 127.0.0.1:27017...

    mongo x.x.x.x:8003/apidb -u apidb -p xxx

     

    brew install mongodb-database-tools

     

    mongodump -h x.x.x.x:8003 -u apidb -p xxx -d apidb -o /Users/guozimo/Documents/csv

     

     

    mongorestore -h 127.0.0.1:27017 -d apidb /Users/guozimo/Documents/csv/apidb

    展开全文
  • database : 'test'//mysql数据库名 }); myslconnection.query('set names utf8'); weiboEntity.findList(function(err, docs){ if (err) { console.log('error'); } else { for(var i=0;i;i++) { console....
    weibo.js
    
    var mongoose = require('mongoose');
    var connection = mongoose.createConnection('mongodb://127.0.0.1:27017/weibodata');
    var Schema = mongoose.Schema;
    var weiboSchema = new Schema({
        content : String,
        uid : String
    }, { 
    	collection: 'micro_blog' 
    });
    
    weiboSchema.methods.findList = function(callback) {
        return this.model('micro_blog').find({"uid" : "1730096327"}, callback);
    }
    
    var WeiboModel = connection.model('micro_blog', weiboSchema);
    
    var weiboEntity = new WeiboModel({});
    
    module.exports = weiboEntity;

    main.js

    var weiboEntity     = require('./weibo.js');
    var mysql      = require('mysql');
    
    var myslconnection = mysql.createConnection({
        host     : '127.0.0.1',//mysql服务器ip
        user     : 'root',//mysql登录名
        password : 'root',//mysql登录密码    
        database : 'test'//mysql数据库名
    });
    
    myslconnection.query('set names utf8');
    
    weiboEntity.findList(function(err, docs){
        if (err) {
            console.log('error');
        } else {
            for(var i=0;i<docs.length;i++) {
            	console.log("第" + (i + 1) + "条数据")
                var content = docs[i].content;
                var uid = docs[i].uid;
                var sql = "insert into weibo (content, author) values('" + content + "','" + uid + "');";
                myslconnection.query(sql, function(err, rows) {
                	if(err){
                    	console.log(err);
                	}
                });
            }         
            console.log("ok")
        }
    })


    展开全文
  • 下面小编就为大家分享一篇使用python和Django完成博客数据库迁移方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
  • 将sqlite3数据库迁移到mongodb。 为什么? 使用sqlite3 ID避免上传重复项 在一个命令中将所有表复制到mongo集合中 什么 它将所有表从sqlite3复制到指定数据库下的mongo集合中。 例如,如果您有一个带表: table1和...
  • MongoDB数据库迁移

    2017-04-05 19:18:00
    一、迁移整个库 1.mongodump(导出) 命令格式:mongodump -h host:port -d dbname -o D:\data\dump   2.mongorestore(导入) 命令格式:mongorestore -h host:port -d dbnameNew --dir D:\data\dump\dbname   ...
  • 有时工作中用到迁移的mongodb的数据库中的数据,mongodb的的也可以像的MySQL的一样备份数据,在这里我选择在本地备份阿里云的mongodb的数据库的数据作为测试; 备份 mongodump -h dbhost -d dbname -o dbdirectory ...
  • 使用Mongo自带的mongodump和mongorestore工具,需要一台阿里云ECS,因为阿里云的云MongoDb是不允许阿里云外的服务器访问的,要使用一台ECS作为桥接,在这一台ECS上安装安装mongodb-org-server, mongodb-org-shell, ...
  • MongoDB 的迁移方案

    2020-05-12 12:30:26
    一次Mongdb docker通过副本集方式进行迁移的实践
  • 由于系统软件升级,旧版本为了便捷存储Json数据使用mongo数据库,系统升级使用了mysql5.7,所以需要将原先mongo数据库数据迁移至mysql数据库,迁移过程中也学习了很多数据处理方法,以此记录一下。 说一下这次数据...
  • mongodb的数据迁移到mysql数据库中脚本, 在迁移前需要将mysql的表创建完成,他只负责数据同步
  • migrate-mongo是在Node.js中运行的MongoDB的数据库迁移工具 安装 $ npm install -g migrate-mongo CLI用法 $ migrate-mongo Usage: migrate-mongo [options] [command] Commands: init initialize a new migration...
  • mongo数据库导入mysql数据库 最近项目做了个定时器,由于之前是python做的,最近重构成了java,感觉mysql还是比mongo符合我们的项目管理要求,重构之后需要把以前的mongo数据导入到mysql记录如下 进入自己服务器...
  • 数据库(复制集)迁移 @(MongoDB)[复制集|迁移|] 数据库复制集迁移 前言 准备 架构图说明 步骤 1部署新节点 1 创建相应路径 2 修改启动文件 3 复制数据文件 4 启动新节点 2加入集群中 3检查数据同步状态 4切断...
  • 拷贝需要迁移数据库目录到指定目录(个人建议停止mongo后进行拷贝) 二.修改拷贝迁移后目录的的权限和相关用 在这一步其实特别重要,最需要注意的是保证文件的权限和拥有者分组的一致性(备注:-R是递归修改,...
  • 1、备份数据库数据 记得备份所有数据库,当然也包括admin mongodump -h 127.0.0.1:27017 -d [数据库名] -u [账号] -p [密码] -o [备份路径] 2、修改mongo配置 在mongod.conf文件中将dbpath修改为新的数据库存放地址...
  • <p>I want to change library for database from <code>github.com/mongodb/mongo-go-driver/mongo</code> to <code>github.com/globalsign/mgo</code>, my problem is I dont know how convert this code for new ...
  • -d:数据库名 -c:集合名称 -o : 导出数据文件的路径 -type : 导出数据类型,默认json 1.2 导入语法 mongoimport -d dbname -c collectionname --file filename --headerline --type json/csv -f field -d:数据
  • mongodb 备份和迁移

    千次阅读 2019-04-11 16:09:43
    下面例子中使用的是mac版本的nosqlbooster,该工具的简单操作(比如怎么登录怎么连接数据库等)这边就不介绍了,直接进入主题,怎么备份 登录后右键要备份的数据库,我这边是mall库 点击copy database复制...
  • MongoShake迁移同步mongo数据库 简介: Mongo-Shake 由阿里云 Nosql 团队开发和维护。Mongo-Shake 是基于 MongoDB 的 oplog 的通用服务平台。它从源 mongo 数据库中获取 oplog,并在目标 mongo 数据库中重放或...
  • Django 数据库操作(MongoDB+Django)ORM

    千次阅读 2019-04-26 16:14:25
    文章目录django-mongodb#0 GitHub#1 环境#2 开始#2.1 安装 mongoengine#2.2 新建django项目#2.3 在MongoDB新建一个数据库#2.4 修改settings.py配置#2.5 models.py#2.6 不需要数据库迁移#2.7 新建视图函数#2.8 访问...
  • mongoexport -d "数据库名" -c "表名" -o "要保存的文件名" --type "指定保存的数据文件类型"(json/csv) -f "指定要导出的字段" 参数说明: -d :数据库名 -c :collection名 -o :输出的文件名 --type : ...
  • 启动mongo数据库服务,在CMD中执行命令 即可 $ mongod --dbpath 数据库目录 本例将数据内容放在d盘根目录下db文件夹,因此写为mongod --dbpath D:/db 回车后静止在如下界面,注意红框标记处,是mongo数据库...
  • docker pull mongo #拉取官方mongo镜像(一般为第一个) ????️ 一些命令: docker images:列出本地主机上的镜像。 各选项说明: REPOSITORY:表示镜像的仓库源 TAG:镜像的标签 IMAGE ID:镜像...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 5,640
精华内容 2,256
关键字:

mongo数据库迁移