如何在 knex.js 迁移中链接承诺

Posted 2023-03-08

【中文标题】如何在 knex.js 迁移中链接承诺

【英文标题】：How to chain promises inside a knex.js migration

【发布时间】：2021-10-17 11:39:19

【问题描述】：

session-pg-simple 需要创建一个表来存储会话，我想将此表添加到我的 knex.js 迁移脚本中。

CREATE TABLE "session" (
  "sid" varchar NOT NULL COLLATE "default",
    "sess" json NOT NULL,
    "expire" timestamp(6) NOT NULL
)
WITH (OIDS=FALSE);

ALTER TABLE "session" ADD CONSTRAINT "session_pkey" PRIMARY KEY ("sid") NOT DEFERRABLE INITIALLY IMMEDIATE;

CREATE INDEX "IDX_session_expire" ON "session" ("expire");

以上是https://github.com/voxpelli/node-connect-pg-simple/blob/HEAD/table.sql的建表脚本

exports.up = function (knex) 
  return Promise.all([
    knex.schema
      .createTable("session", function (table) 
        table.text("sid").notNullable().collate("default");
        table.json("sess").notNullable();
        table.timestamp("expire",  precision: 6 ).notNullable();
      )
      .then(
        knex.schema.raw(
          'ALTER TABLE "session" ADD CONSTRAINT "session_pkey" PRIMARY KEY ("sid") NOT DEFERRABLE INITIALLY IMMEDIATE;'
        )
      )
      .then(
        knex.schema.raw(
          'CREATE INDEX "IDX_session_expire" ON "session" ("expire");'
        )
      ),

    knex.schema.createTable("users", function (table) 
       //...
    ),
  ]);
;

初始表创建后的 2 .thens 没有运行，我尝试在 Promise.all([]) 末尾添加它们，但它也不起作用。 如何将这两行代码实现到我的脚本中？

【问题讨论】：

您的代码也缺少来自其他 .then 调用的 return 语句。这就是为什么你的链接被破坏的原因。也承诺所有不应该被使用。

【参考方案1】：

Promise.all 不需要，并且您错过了 then 块中的 return 语句。 反正你的代码可以大大简化，knex 支持chaining，也就是说你可以创建一个方法链，依次调用：

exports.up = function (knex) 
  return knex.schema
    .createTable("session", function (table) 
      table.text("sid").notNullable().collate("default");
      table.json("sess").notNullable();
      table.timestamp("expire",  precision: 6 ).notNullable();
    )
    .raw(
      'ALTER TABLE "session" ADD CONSTRAINT "session_pkey" PRIMARY KEY ("sid") NOT DEFERRABLE INITIALLY IMMEDIATE;'
    )
    .raw(
      'CREATE INDEX "IDX_session_expire" ON "session" ("expire");'
    )
    .createTable("users", function (table) 
       //...
    )
;

【参考方案2】：

使用此代码，您无需更改表或在raw 中创建索引：

exports.up = knex => 
    return Promise.all([
        knex.schema.createTable('session', function (table) 
            table.string('sid').primary().notNullable();
            table.json('sess').notNullable();
            table.timestamp('expire',  precision: 6 ).notNullable();
        )
    ]);
;

exports.down = knex => 
    return Promise.all([knex.schema.dropTableIfExists('sessions')
    ]);
;