使用Knex构建GraphQL Resolvers：单数据库连接实现与事务疑问

问题背景 #

使用GraphQL + Knex.js编写Resolver时，希望单个查询/Mutation复用同一个数据库连接，例如以下查询中post和author字段的数据库调用共用同一连接：

query {
    post {
        author
    }
}

当前尝试用事务实现，但存在事务处理和方案合理性的疑问。

疑问2：事务是否为正确方案？应使用Knex哪些功能实现查询+Mutation共用单连接？ #

• 如果业务逻辑不需要事务的ACID特性（比如无需保证多操作的原子性、一致性），单纯为复用连接的话，事务不是最优选择——事务会持续占用连接直到提交/回滚，还会引入额外开销。这种场景可以直接手动获取和释放连接。
• 如果业务逻辑依赖事务特性（比如Mutation中的多数据库操作必须原子执行，要么全成要么全败），那事务是合理方案。

Knex实现单连接复用的两种核心方式：

1. 手动管理连接：通过knex.client.acquireConnection()获取连接，用完后调用releaseConnection()释放，适合无事务需求的场景。
2. 事务管理连接：Knex的事务本身会绑定一个连接，事务生命周期内所有操作复用该连接，适合有事务需求的场景。

疑问1：如何正确处理事务？例如如何在查询/Mutation完成时调用trx.commit()避免连接闲置？ #

你当前的实现存在问题：trxProvider()每次调用都会创建新事务，所以post和authorResolver拿到的是不同事务（对应不同连接），且未执行提交/回滚，会导致连接泄漏。

正确做法是在请求生命周期层面统一管理事务，利用GraphQL的Context传递同一个事务实例：

1. 在请求启动时创建事务并注入Context

以Apollo Server为例，在Context函数中初始化事务，并通过请求钩子处理后续提交/回滚：

const knex = require('knex')(/* 你的Knex配置 */);

async function createContext() {
  // 为当前请求创建事务
  const trx = await knex.transaction();
  return {
    trx,
    isTransaction: true
  };
}

const server = new ApolloServer({
  typeDefs,
  resolvers,
  context: createContext,
  plugins: [
    {
      async requestDidStart() {
        return {
          async willSendResponse({ context }) {
            if (context.isTransaction) {
              try {
                // 请求无异常则提交事务
                await context.trx.commit();
              } catch (err) {
                // 出现异常则回滚事务
                await context.trx.rollback();
                throw err;
              }
            }
          }
        };
      }
    }
  ]
});

2. 在Resolver中从Context获取同一事务实例

所有需要复用连接的Resolver都从Context中取同一个事务：

const resolvers = {
  Query: {
    post: async (_, __, { trx }) => {
      return await trx('posts').first();
    },
    author: async (_, __, { trx }) => {
      return await trx('authors').first();
    }
  },
  Post: {
    // 嵌套字段同样复用同一事务
    author: async (parent, _, { trx }) => {
      return await trx('authors').where('id', parent.authorId).first();
    }
  }
};

3. 异常处理

若Resolver执行过程中抛出异常，willSendResponse钩子会自动回滚事务，避免连接长期闲置。

手动管理连接示例（无事务需求） #

如果仅需复用连接、无需事务特性，可直接操作连接：

async function createContext() {
  const connection = await knex.client.acquireConnection();
  return {
    connection,
    // 封装用当前连接执行查询的方法
    query: (table) => knex(table).connection(connection)
  };
}

const server = new ApolloServer({
  typeDefs,
  resolvers,
  context: createContext,
  plugins: [
    {
      async requestDidStart() {
        return {
          async willSendResponse({ context }) {
            // 请求结束后释放连接
            await knex.client.releaseConnection(context.connection);
          }
        };
      }
    }
  ]
});

// Resolver中使用封装的查询方法
const resolvers = {
  Query: {
    post: async (_, __, { query }) => {
      return await query('posts').first();
    },
    author: async (_, __, { query }) => {
      return await query('authors').first();
    }
  }
};

内容的提问来源于stack exchange，提问作者Mondo Duke