fix edges

Author: frank06

lib/src/adapter/adapter.dart

@@ -391,9 +391,9 @@ abstract class _BaseAdapter<T extends DataModelMixin<T>> with _Lifecycle {
 
   Set<String> _keysFor(String key, String name) {
     final result = db.select(
-        'SELECT src, dest FROM _edges WHERE (src = ? AND name = ?) OR (dest = ? AND inverse = ?)',
+        'SELECT key_, _key FROM _edges WHERE (key_ = ? AND name_ = ?) OR (_key = ? AND _name = ?)',
         [key, name, key, name]);
-    return {for (final r in result) r['src'] == key ? r['dest'] : r['src']};
+    return {for (final r in result) r['key_'] == key ? r['_key'] : r['key_']};
   }
 
   void _initializeRelationships(T model, {String? fromKey}) {

lib/src/model/relationship/relationship.dart

@@ -65,14 +65,13 @@ sealed class Relationship<E extends DataModelMixin<E>, N> with EquatableMixin {
 
   void _addAll(Iterable<String> keys, {bool notify = true}) {
     final ps = db.prepare(
-        'REPLACE INTO _edges (src, name, dest, inverse) VALUES (?, ?, ?, ?)');
+        'REPLACE INTO _edges (key_, name_, _key, _name) VALUES (?, ?, ?, ?)');
     final additions = [];
     for (final key in keys) {
       final order = ownerKey.compareTo(key);
       final args = order == -1
           ? [ownerKey, name, key, inverseName]
           : [key, inverseName, ownerKey, name];
-      // TODO if we dont have inverseName?
       ps.execute(args);
       additions.add(key);
     }
@@ -100,11 +99,11 @@ sealed class Relationship<E extends DataModelMixin<E>, N> with EquatableMixin {
 
     if (order == -1) {
       db.execute(
-          'UPDATE _edges SET dest = ? WHERE src = ? AND name = ? AND dest = ?',
+          'UPDATE _edges SET dest = ? WHERE key_ = ? AND name_ = ? AND _key = ?',
           args);
     } else {
       db.execute(
-          'UPDATE _edges SET src = ? WHERE dest = ? AND inverse = ? AND src = ?',
+          'UPDATE _edges SET key_ = ? WHERE _key = ? AND _name = ? AND key_ = ?',
           args);
     }
 
@@ -118,7 +117,7 @@ sealed class Relationship<E extends DataModelMixin<E>, N> with EquatableMixin {
 
   void _removeAll({bool notify = true}) {
     db.execute(
-        'DELETE FROM _edges WHERE (src = ? AND name = ?) OR (dest = ? AND inverse = ?)',
+        'DELETE FROM _edges WHERE (key_ = ? AND name_ = ?) OR (_key = ? AND _name = ?)',
         [_ownerKey!, _name!, _ownerKey!, _name!]);
   }
 
@@ -130,11 +129,10 @@ sealed class Relationship<E extends DataModelMixin<E>, N> with EquatableMixin {
 
     if (order == -1) {
       db.execute(
-          'DELETE FROM _edges WHERE src = ? AND name = ? AND dest = ?', args);
+          'DELETE FROM _edges WHERE key_ = ? AND name_ = ? AND _key = ?', args);
     } else {
       db.execute(
-          'DELETE FROM _edges WHERE dest = ? AND inverse = ? AND src = ?',
-          args);
+          'DELETE FROM _edges WHERE _key = ? AND _name = ? AND key_ = ?', args);
     }
 
     _adapter.core._notify(

lib/src/storage/in_memory_local_storage.dart

@@ -8,22 +8,6 @@ class InMemoryLocalStorage extends LocalStorage {
 
     try {
       db = sqlite3.openInMemory();
-
-      db.execute('''
-        CREATE TABLE IF NOT EXISTS _edges (
-          src INTEGER NOT NULL,
-          name TEXT NOT NULL,
-          dest INTEGER NOT NULL,
-          inverse TEXT
-        );
-
-        CREATE TABLE IF NOT EXISTS _keys (
-          key INTEGER PRIMARY KEY AUTOINCREMENT,
-          type TEXT NOT NULL,
-          id TEXT,
-          is_int INTEGER DEFAULT 0
-        );
-      ''');
     } catch (e, stackTrace) {
       print('[flutter_data] Failed to open:\n$e\n$stackTrace');
     }

lib/src/storage/local_storage.dart

@@ -34,14 +34,15 @@ class LocalStorage {
           VACUUM;
           
           CREATE TABLE IF NOT EXISTS _edges (
-            src INTEGER NOT NULL,
-            name TEXT NOT NULL,
-            dest INTEGER NOT NULL,
-            inverse TEXT,
-            PRIMARY KEY (src, dest)
+            key_ INTEGER NOT NULL,
+            name_ TEXT,
+            _key INTEGER NOT NULL,
+            _name TEXT,
+            UNIQUE (key_, name_, _key)
+            UNIQUE (_key, _name, key_)
           );
-          CREATE INDEX IF NOT EXISTS src_name_idx ON _edges(src, name);
-          CREATE INDEX IF NOT EXISTS dest_inverse_idx ON _edges(dest, inverse);
+          CREATE INDEX IF NOT EXISTS key_name_idx ON _edges(key_, name_);
+          CREATE INDEX IF NOT EXISTS inv_key_name_idx ON _edges(_key, _name);
 
           CREATE TABLE IF NOT EXISTS _keys (
             key INTEGER PRIMARY KEY AUTOINCREMENT,