1、获取数据库所有表；2、查询某表是否存在

Author: MuZiLee

sqldb/lib/SQLdb/SQLdb.dart

@@ -77,20 +77,62 @@ class SQLdb {
     database.close();
   }
 
+  getTableAll({ValueChanged<List<Map>> onChanged}) async{
+    Database db = await _open();
+
+    var sql = "SELECT name FROM sqlite_master WHERE type='table'";
+
+    List<Map> tables = await db.rawQuery(sql);
+
+    if (onChanged != null) {
+
+      onChanged(tables);
+    }
+  }
+
+  queryTable({ValueChanged<Map> onChanged}) async {
+
+    Database db = await _open();
+
+    var sql = "SELECT name FROM sqlite_master WHERE type='table' AND name='${table}'";
+    Map tab = (await db.rawQuery(sql)).last;
+
+    print(tab);
+
+    if (tab['name'] == table) {
+      return true;
+    }
+
+    if (onChanged != null) {
+      onChanged(tab);
+    }
+  }
+
   /*
   * 插入数据
   * */
   insert(Map<String, dynamic> json, {ValueChanged<int> onChanged}) async {
     Database db = await _open();
-    int count = await db.insert(
-      table,
-      json,
-      conflictAlgorithm: more ? ConflictAlgorithm.rollback : ConflictAlgorithm.replace,
-    );
-    await db.close();
-    if (onChanged != null) {
-      onChanged(count);
+
+    var sql = "SELECT name FROM sqlite_master WHERE type='table' AND name='${table}'";
+    List<Map> tables = await db.rawQuery(sql);
+
+    print(tables);
+
+
+    for (var o in tables) {
+      
     }
+
+//    int count = await db.insert(
+//      table,
+//      json,
+//      conflictAlgorithm: more ? ConflictAlgorithm.rollback : ConflictAlgorithm.replace,
+//    );
+//    await db.close();
+//    if (onChanged != null) {
+//      onChanged(count);
+//    }
   }
 
   /*

sqldb/lib/main.dart

@@ -33,7 +33,7 @@ class _MyAppState extends State<MyApp> {
                       "step": 2
                     };
                     //TODO: 增加数据
-                    SQLdb.init("member_check_login", json: data).insert(data);
+                    SQLdb.init("member_check_login2", json: data).insert(data);
                     print("增加数据");
                   },
                 ),
@@ -73,7 +73,29 @@ class _MyAppState extends State<MyApp> {
                       print("删除数据:${count}");
                     });
                   },
-                )
+                ),
+
+                RaisedButton(
+                  child: Text("查询所有表"),
+                  onPressed: () {
+                    SQLdb.init("member_check_login").getTableAll(onChanged: (map){
+
+                      print(map);
+
+                    });
+                  },
+                ),
+
+                RaisedButton(
+                  child: Text("查询某表是否存在"),
+                  onPressed: () {
+                    SQLdb.init("member_check_login").queryTable(onChanged: (map){
+
+                      print(map);
+
+                    });
+                  },
+                ),
 
               ],
             ),