调用同一函数在sqflite创建多表报错，表不存在问题求助

需要动态创建多个数据表（每个播放列表对应一张表，表名来自用户输入），调用同一数据库创建函数时，首次创建正常，第二次创建播放列表时程序崩溃，报错如下：

Unhandled Exception: DatabaseException(no such table: sports (code 1 
SQLITE_ERROR): , while compiling: INSERT INTO sports (title, link, logo, 
playlistName) VALUES (?, ?, NULL, ?)) sql 'INSERT INTO sports (title, link, logo, 
playlistName)

使用的数据库创建代码：

Future open( String name) async {
  Directory documentsDirectory = await getApplicationDocumentsDirectory();
final path = join(documentsDirectory.path, 'playlist1.db');
_database = await openDatabase(path, version: 2,
    onCreate: (Database db, int version) async {
      await db.execute('''
  create table $name ( 
 id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,playlistName TEXT, link TEXT, title TEXT, 
 logo TEXT)
   ''');
    });
   }

1. onCreate仅执行一次：openDatabase的onCreate回调只会在数据库文件首次创建时触发。第二次调用open函数时，数据库已经存在，该回调不会执行，导致新表无法创建，插入数据时就会出现“表不存在”的错误。
2. 版本号固定：代码中版本号硬编码为2，后续调用不会触发onUpgrade回调，也无法通过版本升级来创建新表。
3. 重复初始化数据库实例：每次调用open都会重新获取数据库实例，可能导致连接冲突或状态异常。

方案1：每次调用时检查并创建表（推荐） #

修改open函数，在获取数据库实例后，先检查表是否存在，不存在则执行创建语句，替代仅依赖onCreate的逻辑：

Future open(String name) async {
  Directory documentsDirectory = await getApplicationDocumentsDirectory();
  final path = join(documentsDirectory.path, 'playlist1.db');
  
  // 打开数据库，版本号可设为1（或根据实际情况调整）
  _database = await openDatabase(path, version: 1);
  
  // 检查表是否存在，不存在则创建
  final tableExists = await _database.rawQuery(
    "SELECT name FROM sqlite_master WHERE type='table' AND name='$name'"
  );
  
  if (tableExists.isEmpty) {
    await _database.execute('''
      CREATE TABLE $name ( 
        id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
        playlistName TEXT, 
        link TEXT, 
        title TEXT, 
        logo TEXT
      )
    ''');
  }
}

方案2：实现单例数据库实例 #

确保整个应用中只存在一个数据库实例，避免重复打开连接：

class DatabaseHelper {
  static final DatabaseHelper _instance = DatabaseHelper._internal();
  Database? _database;

  factory DatabaseHelper() => _instance;
  DatabaseHelper._internal();

  Future<Database> get database async {
    if (_database != null) return _database!;
    _database = await _initDatabase();
    return _database!;
  }

  Future<Database> _initDatabase() async {
    Directory documentsDirectory = await getApplicationDocumentsDirectory();
    final path = join(documentsDirectory.path, 'playlist1.db');
    return await openDatabase(path, version: 1);
  }

  // 单独的创建表方法
  Future createTable(String name) async {
    final db = await database;
    final tableExists = await db.rawQuery(
      "SELECT name FROM sqlite_master WHERE type='table' AND name='$name'"
    );
    if (tableExists.isEmpty) {
      await db.execute('''
        CREATE TABLE $name ( 
          id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
          playlistName TEXT, 
          link TEXT, 
          title TEXT, 
          logo TEXT
        )
      ''');
    }
  }
}

使用时直接调用DatabaseHelper().createTable("sports")即可。

注意事项 #

• 动态表名要做好SQL注入防护：如果用户输入的表名未做过滤，可能存在安全风险，建议对输入的表名进行校验（比如限制只能包含字母、数字和下划线）。
• 避免过度创建表：过多的表会增加数据库维护成本，也可以考虑设计一张包含playlistName字段的统一表，用字段区分不同播放列表，这种方案在多数场景下更合理。

内容的提问来源于stack exchange，提问作者Fuad Mostafij