1. 程式人生 > >Nodejs指令碼實現從mongo資料庫遷移資料至mysql資料庫

Nodejs指令碼實現從mongo資料庫遷移資料至mysql資料庫

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")
    }
})


相關推薦

Nodejs指令碼實現mongo資料庫遷移資料mysql資料庫

weibo.jsvar mongoose = require('mongoose'); var connection = mongoose.createConnection('mongodb://12

Android平臺實現與Apache Tomcat伺服器資料互動(MySql資料庫)

簡介:     在前些天寫的專案中用到了Android與Apache伺服器的資料互動,即“通過HttpClient的方式向伺服器傳送請求,伺服器的Servlet接收並執行資料處理(從資料庫中提取資料),最後返回給Android平臺,平臺解析”的過程。 配置: 伺服器:A

ABP模板含Zero使用者角色的專案還原資料庫資料MySql相關問題記錄

ABP是啥這裡就不多說了,既然都已經到還原資料庫了,肯定對ABP已經有所瞭解,ABP通過官網建立時目前提供兩種方式:ASP.NET MVC 5.x、ASP.NET Core 2.x,這裡分別描述ASP.

利用USB-I2C實現機I2C收發資料

Ginkgo USB-I2C介面卡韌體從V2.8.17版本開始支援I2C從機功能,下面就針對這個功能的使用做簡單介紹。實現目的:1、I2C從機接收資料,也就是接收I2C主機的資料並顯示出來;2、I2C從機發送資料,也就是把資料傳輸到介面卡裡面後,主機能將這些資料讀出來;上位機測試軟體用Ginkgo_

Python3學習(三十四):pythonmongo中取資料,使用pandas.DataFrame進行列操作並轉字典

使用該操作的具體場景(一般與mongo相結合): 比如mongo中存了幾萬條資料,需要將mongo中的資料取出來,並對其中的一列進行相關操作,最後轉化為字典格式。 具體程式碼實現如下: import pandas as pd import pymongo import

Android Studio平臺下使用hellochart實現txt檔案讀取資料繪折線圖

Android Studio平臺下使用hellochart實現從文字讀取資料繪折線圖 本人是一個剛剛接觸Android不超過兩個月的小白,最近在做的論文是關於這一塊的相關內容。所有的東西都是自學的,聽導師的建議也是第一次留個這樣的資料,可能有很多地方理解不到位,

shell指令碼實現rysnc檔案備份以及資料傳輸校驗

通過shell指令碼整合了rsync(daemon)守護程序模式對檔案備份以及進行md5校驗的功能。 #!/bin/bash file=access_2018-12-8.logtarfile=./backup$(date +%F).tar.gz tar zcf $tar_file $filemd5sum

關於平滑遷移Windows下MySQL資料庫一臺電腦到另外一臺電腦

目錄 1、使用場景      因為本人最近需要把以前使用的三星膝上型電腦,替換加入固態硬碟和擴充套件了記憶體的ThinkPad電腦,主要原始識公司開始購買的三星本無法擴充套件記憶體條,搞微服務開發,多開幾個服務;記憶體就直接到95%以上了,原來三星

python-檔案讀取json資料寫到資料庫

#!/bin/env python #coding=utf-8 import sys import urllib2 import json import datetime import pymysql as MySQLdb import time from itert

python實現檔案中讀取資料並繪製成 x y 軸圖形

import matplotlib.pyplot as plt import numpy as np def readfile(filename):     dataList = []     dataNum = 0     with open(filename,'r')

JAVAExcel中讀取資料儲存到資料庫

1.jar包 2.資料庫資訊 3.JDBC連線資料庫工具類 package Test; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedSta

利用Python將Excel表中的資料匯入Mysql資料庫

 python操作Excel 需要匯入xlrd包,可以通過pip install xlrd 一鍵安裝。 #coding=utf-8 ''' python 將指定目錄下的excel檔案匯入到資料庫中 ''' # 引入資料庫包 import pymysql # 引入操作excel包

Shell_mysql命令以及將資料匯入Mysql資料庫

連線MYSQL資料庫 mysql -h${db_ip} -u${db_user} -p${db_pawd} -P${db_port} -D${db_name} -s -e "${sql}"   db_ip:主機地址   db_user :資料庫使用者名稱   db_pwd:密碼   db

MYSQL遷移資料sqlserver

第一步:下載安裝MYSQL ODBC https://dev.mysql.com/downloads/connector/odbc/ 安裝過程比較簡單 第二步:配置資料來源 版本要和mysql版本對應.   第三步:建立連線伺服器 我用的工具是&nbs

利用pandas的to_sql將資料插入MySQL資料庫和所踩過的坑

前言 最近做一個Django web的專案要把爬取的一些資料存入MySQL中,資料儲存為csv格式,想到pandas中有to_sql這個方法,就採用它了 準備:連線MySQL資料庫所需的第三方包pymysql、sqlalchemy(pip安裝即可) 實現 from sql

將scrapy爬蟲框架爬取到的資料存入mysql資料庫

使用scrapy爬取網站資料,是一個目前來說比較主流的一個爬蟲框架,也非常簡單。 1、建立好專案之後現在settings.py裡面把ROBOTSTXT_OBEY的值改為False,不然的話會預設遵循robots協議,你將爬取不到任何資料。 2、在爬蟲檔案裡開始寫

python中CSV檔案資料存入mysql資料庫

使用pandas讀取檔案 自定義函式新增資料 #!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2018/10/20 10:32 # @Author : deli Guo # @Site :

[資料庫遷移] ORACLE到MYSQL經驗總結

最近工作中有個專案需要做資料庫遷移,ORACLE到MYSQL,WEBLOGIC到TOMCAT. 原因是ORACLE和WEBLOGIC都是收費的,降低專案成本。 經過半個月的工作總算初見成效,以下是工作中的經驗總結。 1.轉移資料庫檔案(表結構,序列,檢視,索引,資料)

如何使用SQLyog將大量資料匯入mysql資料庫

之前是通過SQLyog將excel檔案儲存為csv檔案,然後匯入mysql資料庫,不過由於資料量大,建表語句寫的很麻煩(先copy Excel橫表的第一行(屬性那一行),然後轉置,到txt檔案,寫建表語句,加逗號),昨天用一天的時間琢磨這個問題,在前輩的指點下,發現這個能匯

Python爬蟲-利用百度地圖API介面爬取資料並儲存MySQL資料庫

首先,我這裡有一份相關城市以及該城市的公園數量的txt檔案: 其次,利用百度地圖API提供的介面爬取城市公園的相關資訊。 所利用的API介面有兩個: 1、http://api.map.baidu.com/place/v2/search?q=公園&