safechat/nodejs/database/index.js

module.exports = function() {
    var mysql = require('mysql');
    var fs = require('fs');
    var config = require(__dirname+'/config.json');
    config.multipleStatements = true;
    var pool = mysql.createPool(config);
    
    pool.query(fs.readFileSync(__dirname+'/schema.sql').toString());
    if (config.max_allowed_packet)
        pool.query("set global max_allowed_packet=?", [config.max_allowed_packet]);
    
    return pool;
};