script.js

const { MongoClient } = require('mongodb');
const mysql = require('mysql2/promise');
require('dotenv').config(); // Carrega as variáveis de ambiente

// Configurações do MongoDB (usando variáveis de ambiente)
const MONGO_URI = process.env.MONGO_URI || "mongodb://localhost:27017/";
const COLECOES = [
    
    ""  

    // Adicione coleções que deseja migrar
];

// Configurações do MySQL (usando variáveis de ambiente)
const MYSQL_CONFIG = {
    host: process.env.MYSQL_HOST || "localhost",
    user: process.env.MYSQL_USER || "root",
    password: process.env.MYSQL_PASSWORD || "",
    database: process.env.MYSQL_DATABASE || ""
};

// Função para mapear tipos de dados do MongoDB para MySQL
function getSqlType(valor) {
    if (typeof valor === 'number') {
        return Number.isInteger(valor) ? 'INT' : 'FLOAT';
    }
    if (typeof valor === 'boolean') {
        return 'BOOLEAN';
    }
    // Todos os outros campos, incluindo datas, serão tratados como TEXT
    return 'TEXT';
}

async function copiarDados() {
    let mongoClient, mysqlConn;

    try {
        // Conecta ao MongoDB
        mongoClient = new MongoClient(MONGO_URI);
        await mongoClient.connect();
        const mongoDb = mongoClient.db();

        // Conecta ao MySQL
        mysqlConn = await mysql.createConnection(MYSQL_CONFIG);

        // Itera sobre as coleções
        for (const colecao of COLECOES) {
            console.log(`Processando coleção: ${colecao}`);
        
            // Recupera os dados do MongoDB
            const dados = await mongoDb.collection(colecao).find().toArray();
        
            if (dados.length > 0) {
                // Mapeia colunas e tipos de dados com base no primeiro documento
                const colunas = Object.keys(dados[0]).map(chave => {
                    const tipo = getSqlType(dados[0][chave]);
                    return `\`${chave}\` ${tipo}`;
                }).join(", ");
        
                // Cria a tabela no MySQL (se não existir)
                const sqlCreate = `CREATE TABLE IF NOT EXISTS \`${colecao}\` (id INT AUTO_INCREMENT PRIMARY KEY, ${colunas})`;
                await mysqlConn.execute(sqlCreate);
        
                // Declara `colunasInsert` corretamente
                const colunasInsert = Object.keys(dados[0]).map(chave => `\`${chave}\``).join(", ");
                
        
                // Insere os dados em lotes
                const batchSize = 5;
                for (let i = 0; i < dados.length; i += batchSize) {
                    const batch = dados.slice(i, i + batchSize);
        
                    // **Declara `placeholders` corretamente dentro do loop**
                    const placeholders = batch.map(() => `(${Object.keys(dados[0]).map(() => "?").join(", ")})`).join(", ");
        
                    const valores = batch.flatMap(doc => {
                        return Object.keys(dados[0]).map(chave => {
                            const valor = doc[chave];
                    
                            if (valor === undefined) {
                                return null; 
                            }
                            if (typeof valor === 'object' && valor !== null) {
                                return JSON.stringify(valor); 
                                
                            }
                            
                            return valor; // Mantém outros valores normais
                        });
                    });
        
                    console.log(`Inserindo lote de ${batch.length} documentos na coleção ${colecao}`);
                    console.log(`Colunas: ${colunasInsert}`);
                    console.log(`Valores: ${valores.length}`);
        
                    const sqlInsert = `INSERT INTO \`${colecao}\` (${colunasInsert}) VALUES ${placeholders}`;
                    await mysqlConn.execute(sqlInsert, valores);
                }
        
                console.log(`Dados da coleção ${colecao} copiados com sucesso!`);
            } else {
                console.log(`Coleção ${colecao} está vazia. Nenhum dado copiado.`);
            }
        }

        console.log("Transferência concluída!");
    } catch (error) {
        console.error("Erro durante a transferência de dados:", error);
    } finally {
        // Fecha as conexões
        if (mysqlConn) await mysqlConn.end();
        if (mongoClient) await mongoClient.close();
    }
}

// Executa o script
copiarDados();