data_dashboards/server/db/mysql.js

const mysql = require('mysql');
// 创建数据库连接对象


const pool = mysql.createPool({
    connectionLimit: 10,
    host: '47.112.185.207',
    user: 'weiban_census',
    password: 'GZy6SLJGPRbNLABe',
    database: 'weiban_census',
    charset: 'utf8mb4'

});

function queryDatabase(sql, callback) {

    pool.getConnection((err,connection)=>{
        if (err) {
            console.error('获取连接出现错误：', err);
            return;
        }
        console.log("连接数据库成功");

        connection.query(sql, (err, results) => {
            connection.release();
            if (err) {
                console.error('查询数据出错：', err);
                callback(err, null);
                return;
            }
            callback(null, results);
        });
        
    })
}



module.exports =  {queryDatabase};