1

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;

1 respuesta 1

2

Uno de tus problemas reside en que en el .env del MySQL tienes : en vez de =

Pásalo a lo siguiente:

PORT=8080
DBHOST=localhost
DBUSER=node_user2
DBPASSWORD=123456
DATABASE=node_db

Otro problema es que solamente has cogido código que funciona con un módulo de MongoDB y le has cambiado las partes que pone MongoDB por MySQL y crees que eso va a funcionar... Son módulos completamente diferentes y nada tienen que ver el uno con el otro, no puedes esperar que cambiando 4 nombres funcione como si nada...

Cambia el config.js a lo siguiente:

var mysql = require("mysql");
require("dotenv").config();

const dbConnection = async() => {
    var connection =  mysql.createConnection({
        host: process.env.DBHOST,
        user: process.env.DBUSER,
        password: process.env.DBPASSWORD,
        database: process.env.DATABASE
    });

    connection.connect(function(err) {
        if (err) {
            console.error('error connecting: ' + err.stack);
            return;
        }
 
        console.log('connected as id ' + connection.threadId);

    });

    return connection;
}

Tendrás que recoger el return en donde llamas a la función del 'server.js', esto pasa porque necesitas el connecion que estás declarando para realizar las querys.

Te dejo la documentación del paquete MySQL de node para que le eches un ojo

9
  • ya agregue el cambio pero sigue con el mismo problema no conecta con mysql
    – Giovanny
    el 17 may. 2022 a las 12:16
  • @Giovanny De acuerdo, perdona. Error mío te edito la respuesta y añado más porque se me ha pasado una cosa
    – adrigo
    el 17 may. 2022 a las 12:44
  • @Giovanny ya lo tienes
    – adrigo
    el 17 may. 2022 a las 12:58
  • agregue el codigo que me envio pero ahora me muestra un error en consola del archivo server.js line 34 "await dbConnection();" , donde dice "TypeError: dbConnection is not a function" . subi a la pregunta el archivo server.js ya que al adicionar tu respuesta ocasiona este error.
    – Giovanny
    el 17 may. 2022 a las 13:18
  • Le has quitado el module.exports = { dbConnection } al archivo config.js no?
    – adrigo
    el 17 may. 2022 a las 13:24

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.