nodejs讀取數據庫的一種寫法


MySQLStore.prototype.createDatabaseTable = function(cb) {

    debug_log('Creating sessions database table');

    var fs = require('fs');
    /**讀取當前目錄下上級目錄中的schema.sql中sql語句*/
    /**

        CREATE TABLE IF NOT EXISTS `sessions` (
      `session_id` varchar(255) COLLATE utf8_bin NOT NULL,
      `expires` int(11) unsigned NOT NULL,
      `data` text,
      PRIMARY KEY (`session_id`)
    ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 COLLATE=utf8_bin

    */
    fs.readFile(__dirname + '/../schema.sql', 'utf-8', function(error, sql) {

        if (error) {
            return cb(error);
        }
          // '??' 變成 ??
        sql = sql.replace(/`[^`]+`/g, '??');

        var params = [
            this.options.schema.tableName,
            this.options.schema.columnNames.session_id,
            this.options.schema.columnNames.expires,
            this.options.schema.columnNames.data,
            this.options.schema.columnNames.session_id
        ];
        //創建sessions表,有列session_id,expires,data
        this.connection.query(sql, params, function(error) {

            if (error) {
                debug_error('Failed to create sessions database table.');
                debug_error(error);
                return cb && cb(error);
            }

            cb && cb();
        });

    }.bind(this));
};

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM