diff --git a/docs/lib/broken.dart b/docs/lib/broken.dart
new file mode 100644
index 000000000..e7d55988a
--- /dev/null
+++ b/docs/lib/broken.dart
@@ -0,0 +1,5 @@
+import 'package:drift/drift.dart';
+
+class BrokenTable extends Table {
+  IntColumn get unknownRef => integer().customConstraint('CHECK foo > 10')();
+}
diff --git a/drift_dev/lib/src/lints/drift_errors.dart b/drift_dev/lib/src/lints/drift_errors.dart
index e502c9005..bd946ff21 100644
--- a/drift_dev/lib/src/lints/drift_errors.dart
+++ b/drift_dev/lib/src/lints/drift_errors.dart
@@ -1,14 +1,17 @@
+import 'dart:io';
+
 import 'package:analyzer/dart/analysis/results.dart';
 import 'package:analyzer/dart/analysis/session.dart';
+import 'package:analyzer/dart/ast/ast.dart';
 import 'package:analyzer/dart/element/element.dart';
-import 'package:analyzer/dart/element/visitor.dart';
 import 'package:analyzer/error/error.dart' hide LintCode;
 import 'package:analyzer/error/listener.dart';
-import 'package:analyzer/src/dart/ast/ast.dart';
 import 'package:custom_lint_builder/custom_lint_builder.dart';
 import 'package:drift_dev/src/analysis/backend.dart';
-import 'package:drift_dev/src/backends/build/backend.dart';
-import 'package:logging/src/logger.dart';
+import 'package:drift_dev/src/analysis/options.dart';
+import 'package:logging/logging.dart';
+
+import '../analysis/driver/driver.dart';
 
 final columnBuilderChecker =
     TypeChecker.fromName('DriftDatabase', packageName: 'drift');
@@ -22,59 +25,81 @@ class DriftBuildErrors extends DartLintRule {
         'All futures in a transaction should be awaited to ensure that all operations are completed before the transaction is closed.',
     errorSeverity: ErrorSeverity.ERROR,
   );
+
   @override
   void run(CustomLintResolver resolver, ErrorReporter reporter,
       CustomLintContext context) async {
     final unit = await resolver.getResolvedUnitResult();
+    final backend = CustomLintBackend(unit.session);
+    final driver = DriftAnalysisDriver(backend, const DriftOptions.defaults());
 
-    /// @Simon
+    final file = await driver.fullyAnalyze(unit.uri);
+    print(
+        'test? - ${unit.uri} - ${file.allErrors.length} - ${file.analysis.length}');
+    for (final error in file.allErrors) {
+      if (error.span case final span?) {
+        reporter.reportErrorForSpan(_code, span);
+      }
+    }
   }
 }
 
 class CustomLintBackend extends DriftBackend {
   @override
-  // TODO: implement canReadDart
-  bool get canReadDart => throw UnimplementedError();
+  final Logger log = Logger('drift_dev.CustomLintBackend');
+  final AnalysisSession session;
+
+  CustomLintBackend(this.session);
 
   @override
-  Future<AstNode?> loadElementDeclaration(Element element) {
-    // TODO: implement loadElementDeclaration
-    throw UnimplementedError();
-  }
+  bool get canReadDart => true;
 
   @override
-  // TODO: implement log
-  Logger get log => throw UnimplementedError();
+  Future<AstNode?> loadElementDeclaration(Element element) async {
+    final library = element.library;
+    if (library == null) return null;
+
+    final info = await library.session.getResolvedLibraryByElement(library);
+    if (info is ResolvedLibraryResult) {
+      return info.getElementDeclaration(element)?.node;
+    } else {
+      return null;
+    }
+  }
 
   @override
-  Future<String> readAsString(Uri uri) {
-    // TODO: implement readAsString
-    throw UnimplementedError();
+  Future<String> readAsString(Uri uri) async {
+    final file = session.getFile(uri.path);
+
+    if (file is FileResult) {
+      return file.content;
+    }
+
+    throw FileSystemException('Not a file result: $file');
   }
 
   @override
-  Future<LibraryElement> readDart(Uri uri) {
-    // TODO: implement readDart
-    throw UnimplementedError();
+  Future<LibraryElement> readDart(Uri uri) async {
+    final result = await session.getLibraryByUri(uri.toString());
+    if (result is LibraryElementResult) {
+      return result.element;
+    }
+
+    throw NotALibraryException(uri);
   }
 
   @override
   Future<Expression> resolveExpression(
       Uri context, String dartExpression, Iterable<String> imports) {
-    // TODO: implement resolveExpression
-    throw UnimplementedError();
+    throw CannotReadExpressionException('Not supported at the moment');
   }
 
   @override
   Future<Element?> resolveTopLevelElement(
       Uri context, String reference, Iterable<Uri> imports) {
-    // TODO: implement resolveTopLevelElement
     throw UnimplementedError();
   }
 
   @override
-  Uri resolveUri(Uri base, String uriString) {
-    // TODO: implement resolveUri
-    throw UnimplementedError();
-  }
+  Uri resolveUri(Uri base, String uriString) => base.resolve(uriString);
 }