executeMutation method

  1. @override
Future<int> executeMutation(
  1. JsonQuery query
)
override

Execute a mutation (CREATE, UPDATE, DELETE) and return affected rows.

Implementation

@override
Future<int> executeMutation(JsonQuery query) async {
  final sqlQuery = compiler.compile(query);

  // For CREATE queries, we want to return the created row
  if (query.action == 'create') {
    final result = await adapter.queryRaw(sqlQuery);
    return result.rows.isNotEmpty ? 1 : 0;
  }

  // For other mutations, return affected row count
  final affectedRows = await adapter.executeRaw(sqlQuery);
  return affectedRows;
}