createTableIfNotExists method

@Deprecated('createTableIfNotExists will be deprecated in version 1.1.0') TableDefinition createTableIfNotExists(String tableName, dynamic callback(Schema))

Implementation

@Deprecated('createTableIfNotExists will be deprecated in version 1.1.0')
TableDefinition createTableIfNotExists(
    String tableName, Function(Schema) callback) {
  _schemaBuilder.reset();
  _schemaBuilder.setTableName(tableName);

  Future<void> createFunction() async {
    callback(_schemaBuilder);

    String sql =
        _schemaBuilder.generateCreateTableSql(tableName, ifNotExists: true);
    if (_adapter != null && _adapter.driverName == 'pgsql') {
      final postgresAdapter = _adapter as dynamic;
      if (postgresAdapter.executeStatements != null) {
        await postgresAdapter.executeStatements(sql,
            (String statement) async {
          try {
            await _connection.connection!.execute(statement);
          } on QueryException catch (e) {
            stderr.writeln(
              'Error executing statement: $statement\nError: ${e.cause}',
            );
            exit(0);
          }
        });
        return;
      }
    }

    if (_adapter != null) {
      sql = _adapter.adaptQuery(sql);
    }
    try {
      await _connection.connection!.execute(sql);
    } on QueryException catch (e) {
      stderr.writeln(
        'Error executing statement: $sql\nError: ${e.cause}',
      );
      exit(0);
    }
  }

  return TableDefinition(tableName, createFunction,
      connection: _connection, adapter: _adapter);
}