Function connectToDatabase

src/commands.ts:30–106

(
  context: vscode.ExtensionContext,
  connectionsSidepanel: SQLNotebookConnections
)

}

export function connectToDatabase(
  context: vscode.ExtensionContext,
  connectionsSidepanel: SQLNotebookConnections
) {
  return async (item?: ConnectionListItem) => {
    let selectedName: string;
    if (!item) {
      const names = context.globalState
        .get(storageKey, [])
        .map(({ name }) => name);
      const namePicked = await vscode.window.showQuickPick(names, {
        ignoreFocusOut: true,
      });
      if (!namePicked) {
        vscode.window.showErrorMessage(`Invalid database connection name.`);
        return;
      }
      selectedName = namePicked;
    } else {
      selectedName = item.config.name;
    }

    const match = context.globalState
      .get<ConnData[]>(storageKey, [])
      .find(({ name }) => name === selectedName);
    if (!match) {
      vscode.window.showErrorMessage(
        `"${selectedName}" not found. Please add the connection config in the sidebar before connecting.`
      );
      return;
    }

    let password: string | undefined;
    try {
      if (match.driver === 'sqlite') {
        globalConnPool.pool = await getPool({
          driver: 'sqlite',
          path: match.path,
        });
      } else {
        password = await context.secrets.get(match.passwordKey);
        if (password === undefined) {
          // can also mean that the platform doesn't work with `keytar`, see #18
          vscode.window.showWarningMessage(
            `Connection password not found in secret store. There may be a problem with the system keychain.`
          );
          // continue so that Linux users without a keychain can use empty password configurations
        }

        globalConnPool.pool = await getPool({
          ...match,
          password,
          queryTimeout: getQueryTimeoutConfiguration(),
        } as PoolConfig);
      }
      const conn = await globalConnPool.pool.getConnection();
      await conn.query('SELECT 1'); // essentially a ping to see if the connection works
      connectionsSidepanel.setActive(match.name);