powerage-ristoris-flutter/lib/database/sql_logger.dart

import 'package:drift/drift.dart';

class SqlLoggingInterceptor extends QueryInterceptor {
  @override
  Future<List<Map<String, Object?>>> runSelect(
    QueryExecutor executor,
    String statement,
    List<Object?> args,
  ) {
    print('[Drift] SELECT: $statement | args: $args');
    return executor.runSelect(statement, args);
  }

  @override
  Future<int> runInsert(
    QueryExecutor executor,
    String statement,
    List<Object?> args,
  ) {
    print('[Drift] INSERT: $statement | args: $args');
    return executor.runInsert(statement, args);
  }

  @override
  Future<int> runUpdate(
    QueryExecutor executor,
    String statement,
    List<Object?> args,
  ) {
    print('[Drift] UPDATE: $statement | args: $args');
    return executor.runUpdate(statement, args);
  }

  @override
  Future<int> runDelete(
    QueryExecutor executor,
    String statement,
    List<Object?> args,
  ) {
    print('[Drift] DELETE: $statement | args: $args');
    return executor.runDelete(statement, args);
  }

  @override
  Future<void> runCustom(
    QueryExecutor executor,
    String statement,
    List<Object?> args,
  ) {
    print('[Drift] CUSTOM: $statement | args: $args');
    return executor.runCustom(statement, args);
  }

  @override
  Future<void> runBatched(
    QueryExecutor executor,
    BatchedStatements statements,
  ) {
    for (final s in statements.statements) {
      print('[Drift] BATCHED: $s');
    }
    return executor.runBatched(statements);
  }
}