Function dropExtras

tests/globalSetup.ts:115–191

(t: SqlTarget, extras: string[])

}

async function dropExtras(t: SqlTarget, extras: string[]): Promise<string[]> {
  if (extras.length === 0) {
    return [];
  }
  const dropped: string[] = [];

  try {
    switch (t.kind) {
      case 'postgres':
      case 'postgis':
        await withPg(t.port, async c => {
          for (const name of extras) {
            const q = name.replace(/"/g, '""');
            try {
              await c.query(`DROP DATABASE IF EXISTS "${q}" WITH (FORCE)`);
              dropped.push(name);
            } catch {
              /* skip */
            }
          }
        });
        break;
      case 'mysql':
      case 'mariadb':
        await withMysql(t.port, async c => {
          await c.query('SET FOREIGN_KEY_CHECKS=0');
          for (const name of extras) {
            const q = name.replace(/`/g, '``');
            try {
              await c.query(`DROP DATABASE IF EXISTS \`${q}\``);
              dropped.push(name);
            } catch {
              /* skip */
            }
          }
        });
        break;
      case 'mssql':
        await withMssql(t.port, async c => {
          for (const name of extras) {
            const q = name.replace(/]/g, ']]');
            try {
              // `set offline` over `set single_user` to avoid the 3702 race where a torn-down
              // pool connection grabs the single-user slot before the drop executes. Dropping
              // an offline database leaves the underlying `.mdf`/`.ldf` files behind, so
              // capture the physical paths first and explicitly remove them after the drop —
              // otherwise a subsequent run that creates the same DB name fails with error
              // 5170 ("file already exists").
              await mssqlQuery(
                c,
                `declare @drop_files table (path nvarchar(260)); ` +
                  `insert into @drop_files (path) select physical_name from sys.master_files where database_id = db_id(N'${q}'); ` +
                  `alter database [${q}] set offline with rollback immediate; ` +
                  `drop database [${q}]; ` +
                  `declare @drop_path nvarchar(260); ` +
                  `declare drop_files_cursor cursor local fast_forward for select path from @drop_files; ` +
                  `open drop_files_cursor; fetch next from drop_files_cursor into @drop_path; ` +
                  `while @@fetch_status = 0 begin ` +