在Node环境中导入SQL转储

谁动了我的青春

我想要一个npm脚本来创建/配置/等。最后导入一个SQL转储。整个创建，配置等都可以正常工作，但是，我无法使导入正常工作。永远不会插入数据。这就是我所拥有的（不要嵌套嵌套的回调，因为它们会变成promise）：
connection.query(`DROP DATABASE IF EXISTS ${config.database};`, err => {
  connection.query(`CREATE DATABASE IF NOT EXISTS ${config.database};`, err => {
connection.query('use DATABASENAME', err => {
   const sqlDumpPath = path.join(__dirname, 'sql-dump/sql-dump.sql');
   connection.query(`SOURCE ${sqlDumpPath}`, err => {
      connection.end(err => resolve());
   });
})
  });
});
我还尝试了Sequelize（ORM）进行以下操作：
return new Promise(resolve => {
  const sqlDumpPath = path.join(__dirname, 'sql-dump/sql-dump.sql');
  fs.readFile('./sql/dump.sql', 'utf-8', (err, data) => {
sequelize
   .query(data)
   .then(resolve)
   .catch(console.error);
  });
});

解决方案:


            这是我使用迁移框架设置初始Sequelized导入的方法。这里有很多事情要做，但总之我：
[ol]在migrations文件夹中找到最新的sql-dump
使用读取文件 fs
将文本分为查询
检查其是否为有效查询，如果是，则应用我需要的数据进行一些清理（请参阅相关文章）
推送一个充满查询的数组-我首先通过调用第this.down一个来确保数据库是干净的
运行一切当成了承诺（如建议在这里使用）mapSeries（未在map）
[/ol]
sequelize-cli您可以在shell中使用以下代码来创建迁移：
sequelize migration:create
然后，您将自动在下面的代码输入文件中找到该文件。为了执行迁移，您只需编写：
sequelize db:migrate

"use strict";
const promise = require("bluebird");
const fs = require("fs");
const path = require("path");
const assert = require("assert");
const db = require("../api/models"); // To be able to run raw queries
const debug = require("debug")("my_new_api");
// I needed this in order to get some encoding issues straight
const Aring = new RegExp(String.fromCharCode(65533) +
  "\\" + String.fromCharCode(46) + "{1,3}", "g");
const Auml = new RegExp(String.fromCharCode(65533) +
  String.fromCharCode(44) + "{1,3}", "g");
const Ouml = new RegExp(String.fromCharCode(65533) +
  String.fromCharCode(45) + "{1,3}", "g");
module.exports = {
  up: function (queryInterface, Sequelize) {
// The following section allows me to have multiple sql-files and only use the last dump
var last_sql;
for (let fn of fs.readdirSync(__dirname)){
   if (fn.match(/\.sql$/)){
      fn = path.join(__dirname, fn);
      var stats = fs.statSync(fn);
      if (typeof last_sql === "undefined" ||
         last_sql.stats.mtime  db.sequelize.query(clean_query)
   });
}
// The Series is important as the order isn't retained with just map
return promise.mapSeries(actions, function(item) {
   debug(item.query);
   return item.exec();
}, { concurrency: 1 });
  },
  down: function (queryInterface, Sequelize) {
var tables_2_drop = [
   "items",
   "users",
   "usertypes"
];
var actions = [];
for (let tbl of tables_2_drop){
   actions.push({
      // The created should be created_at
      exec: () => db.sequelize.query("DROP TABLE IF EXISTS `" + tbl +"`")
   });
}
return promise.map(actions, function(item) {
   return item.exec();
}, { concurrency: 1 });/**/
  }
};

在Node环境中导入SQL转储

谁动了我的青春 LV1