Mysql
 sql >> база данни >  >> RDS >> Mysql

NodeJS MySQL Dump

Кодът, както е написан, дори не стигна до файл, който се запазва за мен. Изглежда, че има няколко проблема. Не съм сигурен дали това е действителният код или някои неща са се изгубили в копирането. Въпреки това, въз основа на това, което имате:

Голямото е, че никога не се свързвате с базата данни във вашия код с connection.connect().

Кодът, който искате да изпълните, след като се свържете, трябва да бъде вътре в обратното извикване на connection.connect(). напр.

connection.connect(function (err, empty) {
    if (err)
        throw new Error ('Panic');

    // if no error, we are off to the races...
}

Въпреки това, дори ако бързо преработите кода си, за да обвиете последните си редове вътре в това обратно извикване на връзка, пак ще имате проблеми, защото унищожавате връзката преди да бъдат направени различните SQL повиквания, така че ще искате да преместите код в някакъв вид окончателно обратно извикване.

Дори и след като направите това, вие пак ще имате празен файл, тъй като извиквате save_backup от вашето обратно извикване 'SHOW TABLES', а не след като действително сте го попълнили чрез вътрешното обратно извикване, където получавате оператора CREATE TABLE и попълвате резервно свойство.

Това е минималното пренаписване на вашия код, което ще направи това, което възнамерявате. Важно нещо, което трябва да се отбележи, е "броячът", който управлява кога да запише файла и да затвори връзката. Бих направил други промени, ако беше моя, включително:

  • Използване на „аз“ вместо „аз“
  • Използване на числов цикъл for вместо синтаксис for (... в ...)
  • Моите собствени обратни извиквания попадат в конвенцията за възел (грешка, неща)
  • По-съществена промяна е, че бих пренаписал това, за да използвам обещания, тъй като това може да ви спести малко мъка с объркването, присъщо на дълбоко вложените обратни извиквания. Аз лично харесвам библиотеката Q, но тук има няколко опции.

Надявам се това да е помогнало.

var mysql_backup = function(){
    this.backup = '';
    this.mysql = require('mysql');

    this.init = function(){
        this.connection = this.mysql.createConnection({
            user     : 'root',
            password : 'root',
            database : 'test'
        });

    };

    this.query = function(sql, callback) {
        this.connection.query(sql, function (error, results, fields) {
            if (error) {
                throw error;
            }
            if (results.length  > 0) {
                callback(results);
            }
        });
    };

    this.get_tables = function(callback){
        var counter = 0;
        var me = this;
        this.query('SHOW TABLES',
            function(tables) {
                for (table in tables){
                    counter++;
                    me.query(
                        'SHOW CREATE TABLE ' + tables[table].Tables_in_mvc,
                        function(r){
                            for (t in r) {
                                me.backup += "DROP TABLE " + r[t].Table + "\n\n";
                                me.backup += r[t]["Create Table"] + "\n\n";
                            }
                            counter--;
                            if (counter === 0){
                                me.save_backup();
                                me.connection.destroy();

                            }
                        }
                    )
                }
            });
    };

    this.save_backup = function(){
        var fs = require('fs');
        fs.writeFile("./backup_test.txt", this.backup, function(err) {
            if(err) {
                console.log(err);
            } else {
                console.log("The file was saved!");
            }
        });
    }

};

var db = new mysql_backup;
db.init();
db.connection.connect(function (err){
    if (err) console.log(err);
    db.get_tables(function(x){;});

});

Актуализация:Ако сте любопитни, ето една силно коментирана реализация, използваща обещания. Имайте предвид, че без коментарите, обясняващи функциите на библиотеката Q обещания, тя е малко по-кратка от оригиналната версия и също така предлага по-изчерпателна обработка на грешки.

var MysqlBackup = function(connectionInfo, filename){

    var Q = require('q');
    var self = this;
    this.backup = '';
    // my personal preference is to simply require() inline if I am only
    // going to use something a single time. I am certain some will find
    // this a terrible practice
    this.connection = require('mysql').createConnection(connectionInfo);

    function getTables(){
        //  return a promise from invoking the node-style 'query' method
        //  of self.connection with parameter 'SHOW TABLES'.
        return Q.ninvoke(self.connection,'query', 'SHOW TABLES');
    };

    function doTableEntries(theResults){

        // note that because promises only pass a single parameter around,
        // if the 'denodeify-ed' callback has more than two parameters (the
        // first being the err param), the parameters will be stuffed into
        // an array. In this case, the content of the 'fields' param of the
        // mysql callback is in theResults[1]

        var tables = theResults[0];
        // create an array of promises resulting from another Q.ninvoke()
        // query call, chained to .then(). Note that then() expects a function,
        // so recordEntry() in fact builds and returns a new one-off function
        // for actually recording the entry (see recordEntry() impl. below)

        var tableDefinitionGetters = [];
        for (var i = 0; i < tables.length ; i++){
            //  I noticed in your original code that your Tables_in_[] did not
            //  match your connection details ('mvc' vs 'test'), but the below
            //  should work and is a more generalized solution
            var tableName = tables[i]['Tables_in_'+connectionInfo.database];

            tableDefinitionGetters.push(Q.ninvoke(self.connection, 'query', 'SHOW CREATE TABLE ' + tableName)
                                        .then(recordEntry(tableName)) );
        }

        // now that you have an array of promises, you can use Q.allSettled
        // to return a promise which will be settled (resolved or rejected)
        // when all of the promises in the array are settled. Q.all is similar,
        // but its promise will be rejected (immediately) if any promise in the
        // array is rejected. I tend to use allSettled() in most cases.

        return Q.allSettled(tableDefinitionGetters);
    };

    function recordEntry (tableName){
        return function(createTableQryResult){
            self.backup += "DROP TABLE " + tableName + "\n\n";
            self.backup += createTableQryResult[0][0]["Create Table"] + "\n\n";
        };
    };

    function saveFile(){
        // Q.denodeify return a promise-enabled version of a node-style function
        // the below is probably excessively terse with its immediate invocation
        return (Q.denodeify(require('fs').writeFile))(filename, self.backup);
    }

    // with the above all done, now you can actually make the magic happen,
    // starting with the promise-return Q.ninvoke to connect to the DB
    // note that the successive .then()s will be executed iff (if and only
    // if) the preceding item resolves successfully, .catch() will get
    // executed in the event of any upstream error, and finally() will
    // get executed no matter what.

    Q.ninvoke(this.connection, 'connect')
    .then(getTables)
    .then(doTableEntries)
    .then(saveFile)
    .then( function() {console.log('Success'); } )
    .catch( function(err) {console.log('Something went awry', err); } )
    .finally( function() {self.connection.destroy(); } );
};

var myConnection = {
    host     : '127.0.0.1',
    user     : 'root',
    password : 'root',
    database : 'test'
};

// I have left this as constructor-based calling approach, but the
// constructor just does it all so I just ignore the return value

new MysqlBackup(myConnection,'./backup_test.txt');



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Най-добри практики на mysqldump:Част 1 – Предпоставки за MySQL

  2. mySQL ::вмъкване в таблица, данни от друга таблица?

  3. Разлика в MySQL JOIN срещу LEFT JOIN

  4. Как да стартирате MySQL или MariaDB Galera Cluster - актуализиран

  5. Mysql синхронизиране на база данни между две бази данни