nestjs连接hive

要在 NestJS 中连接 Hive 数据库，您需要使用适当的驱动程序。常用的驱动程序是 `node-thrift-hive` 和 `thrift-hive`。您可以使用以下步骤在 NestJS 中连接 Hive 数据库：

1. 安装 Hive 驱动程序

使用以下命令安装 `node-thrift-hive` 驱动程序：

npm install node-thrift-hive

或者使用以下命令安装 `thrift-hive` 驱动程序：

npm install thrift-hive

2. 创建 HiveService

在您的 NestJS 应用程序中创建一个 HiveService。在此服务中，您可以创建 Hive 连接并执行查询。以下是一个示例 HiveService：

import { Injectable } from '@nestjs/common';
import { createConnection, TCLIService } from 'thrift-hive';

@Injectable()
export class HiveService {
  private client: TCLIService.Iface;

  constructor() {
    this.client = createConnection({
      host: 'localhost',
      port: 10000,
      username: 'hive',
      password: '',
    });
  }

  async query(sql: string): Promise<any[]> {
    const session = await this.client.openSession('default', 'anonymous', {});
    const { operationHandle } = await this.client.executeStatement(session, sql);
    const { results } = await this.client.fetchResults(operationHandle);
    await this.client.closeOperation(operationHandle);
    await this.client.closeSession(session);
    return results.data;
  }
}

在上面的示例中，我们创建了一个 `HiveService`，它使用 `thrift-hive` 驱动程序创建了一个连接，然后执行了一个查询。

3. 使用 HiveService

在您的控制器或其他服务中使用 `HiveService`。以下是一个示例控制器：

import { Controller, Get } from '@nestjs/common';
import { HiveService } from './hive.service';

@Controller()
export class AppController {
  constructor(private readonly hiveService: HiveService) {}

  @Get()
  async getQuery(): Promise<any[]> {
    const sql = 'SELECT * FROM my_table';
    return await this.hiveService.query(sql);
  }
}

在上面的示例中，我们注入了 `HiveService`，并在控制器中使用它来执行查询。

这就是连接 Hive 数据库的基本步骤。您可以根据需要进行调整。