connect method

@override Future<void> connect()

Establishes a connection to the database.

This should be called before executing any queries.

Implementation

@override
Future<void> connect() async {
  _pool = Pool.withEndpoints(
    [
      Endpoint(
        host: config.host,
        database: config.database,
        port: config.port,
        username: config.username,
        password: config.password,
      ),
    ],
    settings: PoolSettings(
      maxConnectionCount: _poolConfig.maxConnections,
      connectTimeout: _poolConfig.connectionTimeout,
      maxConnectionAge:
          _poolConfig.idleTimeout == Duration.zero
              ? null
              : _poolConfig.idleTimeout,
      sslMode: SslMode.disable,
    ),
  );
}