node fs读取json文件并写入mongoose
标签：none comm 文件 object app ppa strong ber nbsp
1。导入mongoose的js
const Koa = require(‘koa‘)
const app = new Koa()
const Router = require(‘koa-router‘)
let router = new Router()
const mongoose = require(‘mongoose‘)
const fs = require(‘fs‘)
router.get(‘/insertAllGoodsInfo‘, async (ctx) => {
fs.readFile(‘./newGoods.json‘, ‘utf8‘, (err, data) => {
data = JSON.parse(data)
let saveCount = 0
const Goods = mongoose.model(‘Goods‘)
data.map((value, index) => {
console.log(value)
//放入建模,建模的js在下面
let newGoods = new Goods(value)
newGoods.save().then(() => {
saveCount++
console.log(‘成功‘ + saveCount)
}).catch(error => {
console.log(‘失败：‘ + error)
})
})
})
ctx.body = "开始导入数据"
})
module.exports = router;
2.建模的js
const mongoose = require(‘mongoose‘) //引入Mongoose
const Schema = mongoose.Schema //声明Schema
let ObjectId = Schema.Types.ObjectId //声明Object类型
//创建我们的用户Schema
const goodsSchema = new Schema({
ID: { unique: true, type: String },
GOODS_SERIAL_NUMBER: String,
SHOP_ID: String,
SUB_ID: String,
GOOD_TYPE: Number,
STATE: Number,
NAME: String,
ORI_PRICE: Number,
PRESENT_PRICE: Number,
AMOUNT: Number,
DETAIL: String,
BRIEF: String,
SALES_COUNT: Number,
IMAGE1: String,
IMAGE2: String,
IMAGE3: String,
IMAGE4: String,
IMAGE5: String,
ORIGIN_PLACE: String,
GOOD_SCENT: String,
CREATE_TIME: String,
UPDATE_TIME: String,
IS_RECOMMEND: Number,
PICTURE_COMPERSS_PATH: String
}, {
collections: ‘Goods‘
})
//发布模型
mongoose.model(‘Goods‘, goodsSchema)
3.发布到index.js里面
let goods = require(‘./appApi/goods.js‘)
router.use(‘/goods‘,goods.routes())
node fs读取json文件并写入mongoose
标签：none comm 文件 object app ppa strong ber nbsp
原文地址：https://www.cnblogs.com/zmzzr47/p/14328857.html
评论