Function dbQuery

keyserver/src/database/database.js:134–183

(
  statement: SQLStatementType,
  options?: QueryOptions,
)

  +multipleStatements?: boolean,
};
async function dbQuery(
  statement: SQLStatementType,
  options?: QueryOptions,
): Promise<QueryResults> {
  const triesLeft = options?.triesLeft ?? 2;
  const multipleStatements = options?.multipleStatements ?? false;

  let connection;
  if (connectionContext.migrationsActive) {
    connection = await getMigrationConnection();
  }
  if (multipleStatements) {
    connection = await getMultipleStatementsConnection();
  }
  if (!connection) {
    connection = await loadPool();
  }

  const timeoutID = setTimeout(
    () => databaseMonitor.reportLaggingQuery(statement.sql),
    queryWarnTime,
  );
  const scriptContext = getScriptContext();
  try {
    const sql = statement.sql.trim();
    if (
      scriptContext &&
      scriptContext.dryRun &&
      (sql.startsWith('INSERT') ||
        sql.startsWith('DELETE') ||
        sql.startsWith('UPDATE'))
    ) {
      console.log(rawSQL(statement));
      return ([fakeResult]: any);
    }
    return await connection.query(statement);
  } catch (e) {
    if (e.errno === MYSQL_DEADLOCK_ERROR_CODE && triesLeft > 0) {
      console.log('deadlock occurred, trying again', e);
      return await dbQuery(statement, { ...options, triesLeft: triesLeft - 1 });
    }
    e.query = statement.sql;
    throw e;
  } finally {
    clearTimeout(timeoutID);
    if (multipleStatements) {
      connection.end();
    }
  }
}

function rawSQL(statement: SQLStatementType): string {
  return mysql.format(statement.sql, statement.values);