when i run the delete from ccc where id=1 an throw a error.

[normidar]

delete from ccc where id=1;
when I run the delete from ccc where id=1 and throw an error.
it is like this:
ERROR: Bad state: StreamSink is closed

delete from ccc where id=1;
ERROR: Bad state: StreamSink is closed
dart:io                                                    _Socket.add
package:postgres/src/query.dart 95:12                      Query.sendExtended
package:postgres/src/connection_fsm.dart 197:9             _PostgreSQLConnectionStateIdle.processQuery
package:postgres/src/connection_fsm.dart 183:14            _PostgreSQLConnectionStateIdle.awake
package:postgres/src/connection_fsm.dart 214:12            _PostgreSQLConnectionStateIdle.onEnter
package:postgres/src/connection.dart 234:41                PostgreSQLConnection._transitionToState
package:postgres/src/connection.dart 263:11                PostgreSQLConnection._readData
===== asynchronous gap ===========================
dart:async                                                 _Completer.completeError
package:postgres/src/query.dart 169:17                     Query.completeError
package:postgres/src/connection_fsm.dart 202:11            _PostgreSQLConnectionStateIdle.processQuery.<fn>
===== asynchronous gap ===========================
dart:async                                                 scheduleMicrotask
package:postgres/src/connection_fsm.dart 201:7             _PostgreSQLConnectionStateIdle.processQuery
package:postgres/src/connection_fsm.dart 183:14            _PostgreSQLConnectionStateIdle.awake
package:postgres/src/connection_fsm.dart 214:12            _PostgreSQLConnectionStateIdle.onEnter
package:postgres/src/connection.dart 234:41                PostgreSQLConnection._transitionToState
package:postgres/src/connection.dart 263:11                PostgreSQLConnection._readData
===== asynchronous gap ===========================
dart:io                                                    _Socket.listen
package:postgres/src/connection.dart 149:15                PostgreSQLConnection.open
===== asynchronous gap ===========================
dart:async                                                 _asyncThenWrapperHelper
package:fig_database_linker/dataLinkerPostgres.dart 57:17  DataLinkerPostgres.getConn
test/postgres_test.dart 67:16                              main.<fn>

[normidar]

[isoos]

Can you open a connection and run SELECT 1; on it?

[normidar]

Can you open a connection and run SELECT 1; on it?

when I run SELECT 1;, it is no error.

And when I unclose the database link it is no error too.
is it can not close after DELETE?

[isoos]

At one point you are closing the connection. Could you please share how you are using calling it?

[normidar]

At one point you are closing the connection. Could you please share how you are using calling it?

my code is:

.....
var sql = 'DELETE FROM $table WHERE "' + idName +'" = ' + id +';';
await _conn.query(sql)
if(!_conn.isClosed)await _conn.close();

the _conn is PostgreSQLConnection class.

I'm using Postgres in this website
https://www.elephantsql.com/

[normidar]

is it can not close after the drop and the delete?
when I close after the drop it has an error too.

[isoos]

Do you do anything else between opening the connection and querying it? Please provide full example (without the connection string).

[normidar]

Do you do anything else between opening the connection and querying it? Please provide full example (without the connection string).

  LinkSets card = LinkSets(
    'raja.db.elephantsql.com',
    '5432',
    'wabjtpfp',
    'Q5q05nP9mcDUY9V3bWidtwegWxU9IO_J',
    'wabjtpfp',
  );
  Future<String> getConn() async{
    _conn = PostgreSQLConnection(
      card.host,
      int.parse(card.port ?? 5432),
      card.db,
      username: card.user,
      password: card.psw,
    );
    await _conn.open();
    return _conn.isClosed.toString();
  }
  Future deleteTable(String table)async{
    _getRows('DROP TABLE ' + table + ';');
  }
  Future<List<List<dynamic>>> _getRows(String sql)async{
    List<List<dynamic>> results = await _getRealRows(sql);
    return results;
  }
  Future<PostgreSQLResult> _getRealRows(String sql){
    return _conn.query(sql);
  }
  Future closeDatabase()async{
    if(!_conn.isClosed)await _conn.close();
  }

    await link.getConn();
    await link.deleteTable('ccc');
    await link.closeDatabase();

you can link it whit this setting, maybe it is wrong in the server, I do not know.

[isoos]

• You have shared the DB password, I'd suggest to change it for good.
• You have a missing return in deleteTable, e.g. return _getRows('DROP TABLE ' + table + ';');

I'd suggest to add unawaited_futures to you analysis_options.yaml as an extra lint.