insertRelationshipSQLs method

FutureOr<bool> insertRelationshipSQLs(TransactionOperation op, String entityName, String table, List<SQL> sqls, dynamic id, String otherTable, List otherIds,)

Implementation

FutureOr<bool> insertRelationshipSQLs(
  TransactionOperation op,
  String entityName,
  String table,
  List<SQL> sqls,
  dynamic id,
  String otherTable,
  List otherIds,
) {
  if (sqls.length == 1 && sqls.first.isFullyDummy) {
    return true;
  }

  return executeTransactionOperation(op, sqls.first, (connection) {
    _logTransactionOperationSQL('insertRelationshipSQLs', op, sqls);

    var retInserts =
        sqls.map((sql) {
          var ret = doInsertRelationshipSQL(
            entityName,
            sql.mainTable ?? table,
            sql,
            op.transaction,
            connection,
          );

          if (sql.hasPosSQL) {
            return sql.posSQL!
                .map((e) {
                  _logTransactionOperationSQL(
                    'insertRelationship[POS]',
                    op,
                    e,
                  );
                  return doDeleteSQL(
                    entityName,
                    e.mainTable!,
                    e,
                    op.transaction,
                    connection,
                  );
                })
                .resolveAllWithValue(ret);
          } else {
            return ret;
          }
        }).resolveAll();
    return retInserts.resolveWithValue(true);
  });
}