mysql - SqlJocky 的 ConnectionPool 是否需要关闭

Question

我正在 Dart 中创建一个后端服务器应用程序，它使用 MySQL 数据库来存储数据。为了进行 SQL 调用，我使用了 SqlJocky 的 ConnectionPool。

应用启动时我做了什么:

1. 创建一个存储连接池的单例
2. 使用 prepareExecute 和 query 执行多个查询

在本地，这种方法运行良好。现在我将开发版本推送到 Heroku，几分钟后我遇到了连接问题。

所以我想知道，我是否需要从用于执行查询的池中关闭/释放单个连接？还是查询后的连接重新放入池中免费使用？

所有 MySQL 存储的抽象基类:

abstract class MySQLStore {

  MySQLStore(ConnectionPool connectionPool) {
    this._connectionPool = connectionPool;
  }

  ConnectionPool get connectionPool => this._connectionPool;
  ConnectionPool _connectionPool;
}

方法getAll的具体实现:

Future<List<T>> getAll() async {
  Completer completer = new Completer();

  connectionPool.query("SELECT id, name, description FROM role").then((result) {
    return result.toList();
  }).then((rows) {
    completer.complete(this._processRows(rows));
  }).catchError((error) {
    // TODO: Better error handling.
    print(error);
    completer.complete(null);
  });

  return completer.future;
}

我得到的错误:

SocketException: OS Error: Connection timed out, errno = 110, address = ...

Answer 1

这并不能完全回答您的问题，但我认为您可以像这样简化代码:

Future<List<T>> getAll() async {
  try {
    var result = await connectionPool.query(
        "SELECT id, name, description FROM role");
    return this._processRows(await result.toList());
  } catch(error) {
    // TODO: Better error handling.
    print(error);
    return null;
  } 
}

我确定这里不需要关闭与query 的连接。不过我不知道prepareExecute。
根据 SqlJocky 代码中的评论，数据库服务器释放连接可能需要相当长的时间。
也许您需要增加连接池大小(默认为 5)，以便在 ConnectionPool 等待释放连接时不会耗尽连接。