open method

@override Future<void> open()

Implementation

@override
Future<void> open() async {
  connection = PostgreSQLConnection(
    connectionInfo.host,
    connectionInfo.port,
    connectionInfo.database,
    username: connectionInfo.username,
    password: connectionInfo.password,
    useSSL: connectionInfo.useSSL,
    timeoutInSeconds: connectionInfo.timeoutInSeconds,
  );
  //print( 'PostgreSqlExecutor@open timeoutInSeconds: ${connectionInfo!.timeoutInSeconds}');
  var com = connection as PostgreSQLConnection;
  await com.open();
  //isso executa uma query para definir os esquemas
  if (connectionInfo.enablePsqlAutoSetSearchPath == true &&
      connectionInfo.schemes?.isNotEmpty == true) {
    await query('set search_path to $schemesString;');
  }
  /* } else if (connection is PostgreSQLConnection) {
    var com = connection as PostgreSQLConnection;
    if (com.isClosed) {
      connection = PostgreSQLConnection(
        connectionInfo!.host,
        connectionInfo!.port!,
        connectionInfo!.database,
        username: connectionInfo!.username,
        password: connectionInfo!.password,
      );
      com = connection as PostgreSQLConnection;
      await com.open();
      //isso executa uma query para definir os esquemas
      if (connectionInfo?.enablePsqlAutoSetSearchPath == true &&
          connectionInfo?.schemes?.isNotEmpty == true) {
        await query('set search_path to $schemesString;', {});
      }
    }
  } else {
    await Future.value();
  }*/
  //print('PostgreSqlExecutor@open connection ${connection}');
}