Buen día, tengo una API Rest que me conecta sin problemas con MongoDB, pero quiero que me conecte con MySQL, pero no he podido quitar MongoDB para colocar MySQL, he hecho varios intentos, pero no me conecta con MySQL.
Original con MongoDB:
config.js
const mongoose = require('mongoose');
const dbConnection = async() => {
try {
await mongoose.connect( process.env.MONGODB_CNN, {
useNewUrlParser: true,
useUnifiedTopology: true,
useCreateIndex: true,
useFindAndModify: false
});
console.log('Base de datos online');
} catch (error) {
console.log(error);
throw new Error('Error a la hora de iniciar la base de datos');
}
}
module.exports = {
dbConnection
}
.env
PORT=8080
MONGODB_CNN=mongodb+srv://cafe_user:[email protected]/CafeDB
SECRETORPRIVATEKEY=EsTaEsmiPalabr@secretaDeTokENS123321
CLOUDINARY_URL=cloudinary://776571654463621:2U14cGjxKWwFrA4GA6wQYNjW_H4@dwragjgy0
Ahora MySQL: (La parte que no me funciona)
config.js
const mysql = require("mysql");
require("dotenv").config();
const dbConnection = async() => {
try {
await mysql.connect( process.env, {
host: 'process.env.DBHOST',
user: 'process.env.DBUSER',
password: 'process.env.DBPASSWORD',
database: 'process.env.DATABASE'
});
console.log('Base de datos online');
} catch (error) {
console.log(error);
throw new Error('Error a la hora de iniciar la base de datos');
}
}
module.exports = {
dbConnection
}
.env
PORT=8080
DBHOST: localhost
DBUSER: node_user2
DBPASSWORD: 123456
DATABASE: node_db
Actualización
Agrego también el server.js
, donde muestro las otras configuraciones que hay, ya que al modificar config.js
para MySQL también arroja errores en consola de este archivo.
He intentado varias opciones, pero ninguna me funciona, solo trabaja con MongoDB.
server.js
const express = require('express');
const cors = require('cors');
const fileUpload = require('express-fileupload');
const { dbConnection } = require('../database/config');
class Server {
constructor() {
this.app = express();
this.port = process.env.PORT;
this.paths = {
auth: '/api/auth',
buscar: '/api/buscar',
categorias: '/api/categorias',
productos: '/api/productos',
usuarios: '/api/usuarios',
uploads: '/api/uploads',
}
// Conectar a base de datos
this.conectarDB();
// Middlewares
this.middlewares();
// Rutas de mi aplicación
this.routes();
}
async conectarDB() {
await dbConnection();
}
middlewares() {
// CORS
this.app.use( cors() );
// Lectura y parseo del body
this.app.use( express.json() );
// Directorio Público
this.app.use( express.static('public') );
// Fileupload - Carga de archivos
this.app.use( fileUpload({
useTempFiles : true,
tempFileDir : '/tmp/',
createParentPath: true
}));
}
routes() {
this.app.use( this.paths.auth, require('../routes/auth'));
this.app.use( this.paths.buscar, require('../routes/buscar'));
this.app.use( this.paths.categorias, require('../routes/categorias'));
this.app.use( this.paths.productos, require('../routes/productos'));
this.app.use( this.paths.usuarios, require('../routes/usuarios'));
this.app.use( this.paths.uploads, require('../routes/uploads'));
}
listen() {
this.app.listen( this.port, () => {
console.log('Servidor corriendo en puerto', this.port );
});
}
}
module.exports = Server;