Multer – Nodejs Upload/Download Multiple Files/Images to Server MySQL/PostgreSQL database – Sequelize + Ajax

Author: loizenai

Nodejs-Upload-Download-Files/app/config/db.config.js

@@ -0,0 +1,24 @@
+const env = require('./env.js');
+ 
+const Sequelize = require('sequelize');
+const sequelize = new Sequelize(env.database, env.username, env.password, {
+  host: env.host,
+  dialect: env.dialect,
+  operatorsAliases: false,
+ 
+  pool: {
+    max: env.max,
+    min: env.pool.min,
+    acquire: env.pool.acquire,
+    idle: env.pool.idle
+  }
+});
+ 
+const db = {};
+ 
+db.Sequelize = Sequelize;
+db.sequelize = sequelize;
+ 
+db.files = require('../models/file.model.js')(sequelize, Sequelize);
+ 
+module.exports = db;

Nodejs-Upload-Download-Files/app/config/env.js

@@ -0,0 +1,15 @@
+const env = {
+  database: 'loizenaidb',
+  username: 'root',
+  password: '12345',
+  host: 'localhost',
+  dialect: 'mysql',
+  pool: {
+    max: 5,
+    min: 0,
+    acquire: 30000,
+    idle: 10000
+  }
+};
+ 
+module.exports = env;

Nodejs-Upload-Download-Files/app/config/multer.config.js

@@ -0,0 +1,6 @@
+const multer = require('multer');
+
+var storage = multer.memoryStorage()
+var upload = multer({storage: storage});
+
+module.exports = upload;

Nodejs-Upload-Download-Files/app/controllers/file.controller.js

@@ -0,0 +1,106 @@
+var stream = require('stream');
+var await = require('await')
+
+const db = require('../config/db.config.js');
+const File = db.files;
+
+
+exports.uploadFile = (req, res) => {
+	File.create({
+		type: req.file.mimetype,
+		name: req.file.originalname,
+		data: req.file.buffer
+	}).then(file => {
+		console.log(file);
+
+		const result = {
+			status: "ok",
+			filename: req.file.originalname,
+			message: "Upload Successfully!",
+			downloadUrl: "http://localhost:8080/api/file/" + file.dataValues.id,
+		}
+
+		res.json(result);
+	}).catch(err => {
+		console.log(err);
+
+		const result = {
+			status: "error",
+			error: err
+		}
+		res.json(result);
+	});
+}
+
+exports.uploadMultipleFiles = async (req, res) => {
+	const messages = [];
+
+	for (const file of req.files) {
+		const uploadfile = await File.create({
+								type: file.mimetype,
+								name: file.originalname,
+								data: file.buffer
+							});
+
+        // It will now wait for above Promise to be fulfilled and show the proper details
+        console.log(uploadfile);
+
+	    if (!uploadfile){
+			const result = {
+				status: "fail",
+				filename: file.originalname,				
+				message: "Can NOT upload Successfully",
+			}
+
+			messages.push(result);
+		} else {
+			const result = {
+				status: "ok",
+				filename: file.originalname,
+				message: "Upload Successfully!",
+				downloadUrl: "http://localhost:8080/api/file/" + uploadfile.dataValues.id,
+			}
+
+			messages.push(result);
+		}
+	}
+
+	return res.json(messages);
+}
+
+exports.listAllFiles = (req, res) => {
+	File.findAll({attributes: ['id', 'name']}).then(files => {
+
+		const fileInfo = [];
+
+		console.log(files);
+	  
+		for(let i=0; i<files.length; i++){
+			fileInfo.push({
+				filename: files[i].name,
+				url: "http://localhost:8080/api/file/" + files[i].dataValues.id
+			})
+		}
+
+	    res.json(fileInfo);
+	}).catch(err => {
+		console.log(err);
+		res.json({msg: 'Error', detail: err});
+	});
+}
+
+exports.downloadFile = (req, res) => {
+	File.findByPk(req.params.id).then(file => {
+		var fileContents = Buffer.from(file.data, "base64");
+		var readStream = new stream.PassThrough();
+		readStream.end(fileContents);
+		
+		res.set('Content-disposition', 'attachment; filename=' + file.name);
+		res.set('Content-Type', file.type);
+
+		readStream.pipe(res);
+	}).catch(err => {
+		console.log(err);
+		res.json({msg: 'Error', detail: err});
+	});
+}

Nodejs-Upload-Download-Files/app/models/file.model.js

@@ -0,0 +1,15 @@
+module.exports = (sequelize, Sequelize) => {
+	const File = sequelize.define('file', {
+	  type: {
+			type: Sequelize.STRING
+	  },
+	  name: {
+			type: Sequelize.STRING
+	  },
+	  data: {
+			type: Sequelize.BLOB('long')
+	  }
+	});
+	
+	return File;
+}

Nodejs-Upload-Download-Files/app/routers/file.router.js

@@ -0,0 +1,20 @@
+let express = require('express');
+let router = express.Router();
+let upload = require('../config/multer.config.js');
+ 
+const fileWorker = require('../controllers/file.controller.js');
+
+let path = __basedir + '/views/';
+
+router.get('/', (req,res) => {
+    res.sendFile(path + "index.html");
+});
+
+router.post('/api/file/upload', upload.single("file"), fileWorker.uploadFile);
+router.post('/api/file/multiple/upload', upload.array('files', 4), fileWorker.uploadMultipleFiles);
+ 
+router.get('/api/file/info', fileWorker.listAllFiles);
+ 
+router.get('/api/file/:id', fileWorker.downloadFile);
+ 
+module.exports = router;